Swap Events Stream

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 family	Endpoint	Event
EVM	`wss://stream-evm-prod.mobula.io/`	`swap`
Solana	`wss://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"
  }
}

Introduction

Market & Token Data

Trades & OHLCV

Pulse Streams

Filter Tokens

Multi-Events & Raw Data

Data Models

Holders & Positions

Perps Streams

Webhooks

Misc

Endpoint Details

Subscription Payload

Response Frame

Common Filters

Pool Types

Pool Address Batch

Pool Type and Sender

Parameters

Keepalive

Unsubscribe

​Endpoint Details

​Subscription Payload

​Response Frame

​Common Filters

​Pool Types

​Pool Address Batch

​Pool Type and Sender

​Parameters

​Keepalive

​Unsubscribe

Endpoint Details

Subscription Payload

Response Frame

Common Filters

Pool Types

Pool Address Batch

Pool Type and Sender

Parameters

Keepalive

Unsubscribe