Solana DEX Pools gRPC Stream

The dex_pools gRPC Stream provides real-time DEX pool liquidity and balance change data across supported Solana protocols.

---

Overview

Subscribe to live DEX pool events: liquidity adds, removes, swaps, and pool creation. Each event includes base/quote changes, market info, and balance updates. Data is in protobuf format — use bitquery-corecast-proto to parse.

Configuration

To subscribe to DEX pool events, configure your stream as follows:

stream:
  type: "dex_pools"

Available Data

The DEX pools stream provides comprehensive pool information including:

• Transaction details: Slot, signature, status, fees (in native and USD)
• Account information: Signers, token accounts, program IDs
• Token context: Mint addresses, decimals, owners, metadata
• Pool specifics: Market addresses, base/quote currencies, liquidity changes
• Balance updates: Pre/post balances showing pool liquidity changes and token account updates
• Instruction details: Parsed instruction data with arguments and account names

Sample Data Structure

Here's an example of the data structure you'll receive:

{
  "Block": {
    "Slot": 370028492
  },
  "Transaction": {
        ...
  },
  "PoolEvent": {
    "InstructionIndex": 8,
    "Dex": {
      "ProgramAddress": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
      "ProtocolName": "pump_amm",
      "ProtocolFamily": "Pumpswap"
    },
    "Market": {
      "MarketAddress": "DMoLXDc89o5cUUuvXiteSC3egpcKFwpcjevZrzqLU1o8",
      "BaseCurrency": {
        "Name": "Wrapped Solana",
        "Decimals": 9,
        "Symbol": "WSOL",
        "MintAddress": "So11111111111111111111111111111111111111112",
        "ProgramAddress": "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"
      },
      "QuoteCurrency": {
        "Name": "10/1",
        "Decimals": 6,
        "Symbol": "10/1",
        "MintAddress": "BvtbWHDU5sNwtNitWYmNBAEu6Dfu5TWDBnTBHR7w4HZt",
        "ProgramAddress": "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"
      }
    },
    "BaseCurrency": {
      "ChangeAmount": 38023549,
      "PostAmount": 166166127607
    },
    "QuoteCurrency": {
      "ChangeAmount": -76102597,
      "PostAmount": 333332214494
    },
    "Instruction": {
      "Index": 8,
      "Program": {
        "Address": "pAMMBay6oceH9fJKBRHGP5D4bD4sWpmSwMn52FMfXEA",
        "Name": "pump_amm",
        "Method": "sell"
      },
      "Arguments": [
        {
          "Name": "base_amount_in",
          "Type": "u64",
          "UInt": 38023549
        },
        {
          "Name": "min_quote_amount_out",
          "Type": "u64",
          "UInt": 38103732
        }
      ],
    ...
    },
    "BalanceUpdates": [
      {
        "PreBalance": 40062829,
        "PostBalance": 2039280,
        "AccountIndex": 1
      }
    ],
    "TokenBalanceUpdates": [
      {
        "PreBalance": 166128104058,
        "PostBalance": 166166127607,
        "AccountIndex": 3
      },
      {
        "PreBalance": 333408317091,
        "PostBalance": 333332214494,
        "AccountIndex": 4
      }
    ]
  }
}

Filtering Options

The filter options are defined in the request.proto file. You can filter DEX pool events using the following filters:

message SubscribePoolsRequest  {
  AddressFilter program;
  AddressFilter pool;
  AddressFilter token;
}

Available filters:

• program: Filter by DEX program address
• pool: Filter by specific pool/market address
• token: Filter by token mint address (e.g., WSOL, USDC)

Pool Event Types

The DEX pools stream captures various pool-related events:

• Liquidity additions: When liquidity is added to pools
• Liquidity removals: When liquidity is withdrawn from pools
• Swap events: When trades occur that affect pool balances
• Pool creation: When new pools are created
• Pool updates: When pool parameters are modified

Schema Reference

• Protobuf Schema: dex_block_message.proto
• Sample Data: solana_pool_event.json

Python Installation

For Python development, install the protobuf package:

pip install bitquery-corecast-proto

NPM Package

npm install bitquery-corecast-proto

This package includes all necessary protobuf definitions without requiring manual downloads.

---

Related

• CoreCast Introduction — Topics and concepts
• DEX Trades gRPC — DEX swap stream
• Pump.fun gRPC Example — Uses dex_pools
• Authorization — Token setup