Skip to main content
This endpoint is only available to Growth and Enterprise plans.

​
Endpoint Details

Use this stream when you need every raw swap event that matches your filters.
Chain familyEndpointEvent
EVMwss://stream-evm-prod.mobula.io/swap
Solanawss://stream-sol-prod.mobula.io/swap
Do not mix Solana chainIds on the EVM endpoint, or EVM chainIds on the Solana endpoint.
The EVM addresses used in filters must be lowercase.

​
Subscription Payload

{
  "type": "stream",
  "authorization": "YOUR_API_KEY",
  "payload": {
    "name": "SolanaRaydiumSwaps",
    "chainIds": ["solana:solana"],
    "events": ["swap"],
    "filters": {
      "or": [
        { "eq": ["poolType", "raydium"] },
        { "eq": ["poolType", "raydium-clmm"] }
      ]
    },
    "subscriptionId": "solana-raydium-swaps",
    "subscriptionTracking": true
  }
}

​
Response Frame

Every message uses the standard Multi-Events frame: 
{
  "data": {
    "type": "swap",
    "poolAddress": "4WYhS4JwJQsqfVfNx2uN9ZoRhrMTTsYo8kjdTLvFtSDy",
    "poolType": "raydium-clmm",
    "transactionHash": "snFJGsc6gUyZHpYTbxVQQnDYpWSuPUJ4NTdvTJHTX6Wyd2Amsb3MTbNeyDe9VzkRVf87DhQ1aV79Ptnq2fZufei",
    "swapSenderAddress": "7rhFTmUrRSQsL2b3YDoTuSC2sBQUeN9smbSHpne3vowa",
    "addressToken0": "So11111111111111111111111111111111111111112",
    "addressToken1": "HjgFP3f1nc9kxD71YQXxD1fWHZLNp6b5ARdvhfVKpgCP",
    "amount0": 0.32,
    "amount1": -2944849.817626,
    "amountUSD": 56.42,
    "date": "2026-06-08T00:18:34.613Z"
  },
  "chainId": "solana:solana",
  "duplicateCount": 1,
  "subscriptionId": "solana-raydium-swaps"
}
See the Curated Data Model for the swap fields.

​
Common Filters

​
Pool Types

{
  "or": [
    { "eq": ["poolType", "raydium"] },
    { "eq": ["poolType", "raydium-clmm"] }
  ]
}

​
Pool Address Batch

{
  "in": [
    "poolAddress",
    [
      "0xd0b53d9277642d899df5c87a3966a349a798f224",
      "0xedc625b74537ee3a10874f53d170e9c17a906b9c"
    ]
  ]
}

​
Pool Type and Sender

{
  "and": [
    { "in": ["poolType", ["uniswap-v2", "uniswap-v3", "uniswap-v4"]] },
    {
      "in": [
        "swapSenderAddress",
        [
          "0xd0b53d9277642d899df5c87a3966a349a798f224",
          "0xa6b579684e943f7d00d616a48cf99b5147fc57a5"
        ]
      ]
    }
  ]
}

​
Parameters

  • chainIds (required): Chain identifiers, for example ["evm:8453"] or ["solana:solana"].
  • events (required): Must include swap.
  • filters (optional): Filter conditions. See filters.
  • subscriptionId (optional): Identifier copied into matching responses.
  • subscriptionTracking (optional, default: false): Include subscription details in response logs.
  • tag (optional): Usage tag shown in the dashboard breakdown.

​
Keepalive

Send a ping periodically to keep long-lived connections active: 
{ "event": "ping" }

​
Unsubscribe

{
  "type": "unsubscribe",
  "authorization": "YOUR_API_KEY",
  "payload": {
    "subscriptionId": "solana-raydium-swaps"
  }
}