Solana data, streamed in real time.

{
  "slot": 315256016,
  "signature": "2BpJTsumysXzfX7BZS8u3o8xaZUdov3QGSijfB9asBfWowsRuvGwFY88FqaeWZzbywHobTE5uvDPzcV4LnaGdAbX",
  "blockTime": 1737393555,
  "swap": {
      "ammAccount": "CDHWtKhraDWyp57B2bp7DM5DwHGiyRD8f6n5sKKR7VWo",
      "baseTokenMint": "BwyMeGp9kqCQ7zYn1mEj5REkMFKZhRRHfCEJ8eqcmoon",
      "quoteTokenMint": "So11111111111111111111111111111111111111112",
      "walletAccount": "5S2fWgsbzqTTGVkUUrk83iH17h9T8C5ojYxhrDUWbg6L",
      "quotePrice": "4.665456971e-06",
      "usdValue": 466.04,
      "baseAmount": "398674773250",
      "swapType": "buy"
  }
}

wscat --connect wss://api.solanastreaming.com --header X-API-KEY:923aeea0ac3549a80dcd9f881986eaf7 --execute '{"id":1,"method":"newPairSubscribe","include_pumpfun": true}' -w 600

# For bash:
# 1. Install wscat with npm install -g wscat
# 2. Get your api key
# 3. Copy and paste the command above into your terminal with your api key.

// go get github.com/gorilla/websocket
// Connect
c, _, err := websocket.DefaultDialer.Dial("wss://api.solanastreaming.com/", http.Header{
    "X-Api-Key": []string{"923aeea0ac3549a80dcd9f881986eaf7"}
})
if err != nil {
    log.Fatal("dial:", err)
}
defer c.Close()

// Start the pair / price stream
err = c.WriteMessage(websocket.TextMessage, []byte(`{"id":1,"method":"newPairSubscribe","include_pumpfun": true}`))
if err != nil {
    log.Fatal("write:", err)
}

for {
    // Continuously read pairs / prices
    _, message, err := c.ReadMessage()
    if err != nil {
        log.Fatal("read:", err)
    }
    log.Printf("recv: %s\n", message)
}

// composer require textalk/websocket
$client = new \WebSocket\Client("wss://api.solanastreaming.com/", [
    'headers' => [
        'X-Api-Key'=>'923aeea0ac3549a80dcd9f881986eaf7'
    ], 
    'timeout' => -1
]);
$client->text('{"id":1,"method":"newPairSubscribe","include_pumpfun": true}');

while(true){
    $message =  $client->receive();
    echo "Received: ", $message, "\n";
}

# pip3 install websockets
import asyncio
import websockets
import json

async def main():
    uri = "wss://api.solanastreaming.com"
    async with websockets.connect(uri, additional_headers={"X-API-KEY": "923aeea0ac3549a80dcd9f881986eaf7"}) as websocket:
        # Subscribe to new pairs
        await websocket.send(json.dumps({"method":"newPairSubscribe","include_pumpfun": true}))
        
        # Listen for messages
        async for message in websocket:
            print(json.loads(message))

asyncio.get_event_loop().run_until_complete(main())