PolySocket Documentation

{ "type": "auth", "api_key": "YOUR_API_KEY", "scope": "account" }

{ "type": "subscribe", "wallets": ["0x885278f0e304bc2d53f805af2ab779cb6011c569"] }

{
  "type": "auth_ok",
  "connection_id": "conn_1777766498121579485_100",
  "account_id": "acct_sample",
  "plan": "basic_weekly_2",
  "wallet_count": 0,
  "wallet_limit": 2,
  "include_tx": false
}

{
  "type": "subscribed",
  "scope": "custom",
  "wallet_count": 1
}

wss://feed.polysocket.dev/v1

{
  "event_id": "polygon:0x71a325...bf2ce:0x885278...1c569",
  "observed_at_unix_ns": 1777766595870568021,
  "wallet": "0x885278f0e304bc2d53f805af2ab779cb6011c569",
  "tx_hash": "0x71a325019e713fb2234578d55e66e17b25a6f3868f6075a126356e7cc96bf2ce",
  "role": "maker",
  "side": "buy",
  "side_raw": 0,
  "price": 0.17,
  "shares": 9.19,
  "notional_usd": 1.5623,
  "token_id": "70244509752957369974591345556629529797103276141600347856253643886913568219784",
  "outcome_token_id": "70244509752957369974591345556629529797103276141600347856253643886913568219784",
  "exchange_contract": "0xe111180000d2663c0091e4f400237545b87b996b",
  "maker": "0x885278f0e304bc2d53f805af2ab779cb6011c569",
  "signer": "0xa928b536ee1fedc96655820da2593ac50b1abb46",
  "maker_amount_raw": "1562300",
  "taker_amount_raw": "9190000"
}

{
  "type": "auth",
  "api_key": "YOUR_API_KEY",
  "include_tx": true,
  "scope": "account"
}

const apiKey = process.env.POLYSOCKET_API_KEY;
const wallets = ["0x885278f0e304bc2d53f805af2ab779cb6011c569"];
const ws = new WebSocket("wss://feed.polysocket.dev/v1");

ws.addEventListener("open", () => {
  ws.send(JSON.stringify({
    type: "auth",
    api_key: apiKey,
    scope: "account"
  }));
});

ws.addEventListener("message", (event) => {
  const msg = JSON.parse(event.data);

  if (msg.type === "auth_ok") {
    console.log("connected", msg.connection_id);
    ws.send(JSON.stringify({
      type: "subscribe",
      wallets
    }));
  }

  if (msg.observed_at_unix_ns && msg.tx_hash) {
    routeToYourSystem(msg);
  }
});

import asyncio
import json
import os
import websockets

async def main():
    api_key = os.environ["POLYSOCKET_API_KEY"]
    wallets = ["0x885278f0e304bc2d53f805af2ab779cb6011c569"]

    async with websockets.connect("wss://feed.polysocket.dev/v1", ping_interval=None, max_queue=None) as ws:
        await ws.send(json.dumps({
            "type": "auth",
            "api_key": api_key,
            "scope": "account"
        }))

        async for raw in ws:
            msg = json.loads(raw)
            if msg.get("type") == "auth_ok":
                await ws.send(json.dumps({
                    "type": "subscribe",
                    "wallets": wallets
                }))

            if "observed_at_unix_ns" in msg and "tx_hash" in msg:
                print(msg["wallet"], msg["tx_hash"], msg["observed_at_unix_ns"])

asyncio.run(main())

use futures_util::{SinkExt, StreamExt};
use serde_json::{json, Value};
use tokio_tungstenite::connect_async;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let api_key = std::env::var("POLYSOCKET_API_KEY")?;
    let wallets = ["0x885278f0e304bc2d53f805af2ab779cb6011c569"];
    let (mut ws, _) = connect_async("wss://feed.polysocket.dev/v1").await?;

    ws.send(json!({
        "type": "auth",
        "api_key": api_key,
        "scope": "account"
    }).to_string().into()).await?;

    while let Some(msg) = ws.next().await {
        let parsed: Value = serde_json::from_str(&msg?.into_text()?)?;
        if parsed["type"] == "auth_ok" {
            ws.send(json!({
                "type": "subscribe",
                "wallets": wallets
            }).to_string().into()).await?;
        }

        if parsed["observed_at_unix_ns"].is_number() && parsed["tx_hash"].is_string() {
            println!("wallet={} tx={}", parsed["wallet"], parsed["tx_hash"]);
        }
    }

    Ok(())
}