WSS /ws/market

WSS wss://ws-gateway.dev.predictstreet.sde.adifoundation.ai/ws/market

Market-data gateway. Use for the public trade tape (matcher + chain settlements), orderbook snapshots + deltas, OHLC candles, the live probability chart, market lifecycle, underlying crypto prices, and platform-wide firehoses and trade feed. Trying to subscribe to a private channel (user_orders, user_fills, vault_positions) on this gateway returns { "code": "forbidden" } in the rejected[] array — use /ws/user for own-activity streams.

Authentication

Same X-Api-Key scheme as the rest of the API — no separate auth scheme for market data:

How to send it
`X-Api-Key: ps_live_<keyId>_<secret>` header on the upgrade request
`?key=<token>` query parameter — for browser clients that can’t set custom headers on the WebSocket upgrade

Market channels do not require any specific scope — any active key can subscribe. An invalid key is rejected at handshake with 4401 <reason> (same close-code matrix as /ws/user); an invalid or expired bearer token closes with 1008 unauthorized. Supplying credentials commits the handshake to that path: a bad credential never falls back to an anonymous session. Revoking a key immediately closes every live socket bound to that keyId with 4401 api_key_revoked. A request that supplies no credentials at all connects anonymously — the greeting reports "authMethod": "anon" — and may subscribe to every public channel on this gateway. Where the gateway enforces an origin allowlist, an anonymous upgrade must carry an allowed Origin header or it is closed with 1008 forbidden origin, while a key-authenticated upgrade may omit Origin. Use a key anyway when you have one, so the session is attributed to your partner account (partnerId in the greeting). The per-connection limits (resource limits) are the same either way.

Connect greeting

{
  "type": "connected",
  "data": {
    "gateway":         "market",
    "authMethod":      "api_key",
    "protocolVersion": 2,
    "partnerId":       "cmofzsb0r0000b401xfeiyk2c"
  }
}

partnerId is the platform-side partner-record id corresponding to your API key. Useful for correlating WS sessions to your own audit trail without a separate REST call. Absent on JWT-authenticated sockets (retail web-app sessions).

Available channels

Channel	`ids` shape	Server pushes
`token_trade_matches`	one or more `tokenId` (decimal string)	`trade_matched` per matcher fill
`token_trade_settlements`	one or more `tokenId` (decimal string)	`trade_settled` on chain `OrderFilled`
`token_book`	one or more `tokenId` (decimal string)	`book_snapshot` (depth 100) on subscribe, then `book_update` / `book_delta`; `book_snapshot_failed` on snapshot fetch errors
`token_ohlc`	one or more `tokenId`	`ohlc_update` (`interval: "s5"`)
`market_price_tick`	one or more `<symbol>:<outcomeIndex>` (market symbol, 0-based outcome index)	`price_tick` — the outcome’s mark for the live chart, at most about once a second
`condition_lifecycle`	one or more `conditionId` (lowercased bytes32 hex)	`condition_trading_paused` / `condition_trading_unpaused` (on-chain per-condition trading pause)
`market_lifecycle`	one or more market `symbol` (lowercased)	`status_changed` / `market_disputed` / `market_resolved` / `crypto_window_opened` / `crypto_window_closed`
`crypto_price_tick`	one or more crypto `instrumentId` (`BTC-USD`, `ETH-USD`)	`crypto_price_tick` — live underlying-asset price
`system`	must be `["platform_status"]`	nothing yet — `platform_status` is reserved for the freeze / maintenance status (see note)
`all_trade_matches`	none — every token	`trade_matched` for every token (same frames as `token_trade_matches`)
`all_trade_settlements`	none — every token	`trade_settled` for every token (same frames as `token_trade_settlements`)
`all_books`	none — every token	`book_update` / `book_delta` for every token (same frames as `token_book`, no `book_snapshot`)
`global_activity`	none	`global_activity` — one frame per trade platform-wide, taker’s view, with market titles and username

See Server events for full payload shapes per type.

Live status: token_trade_matches, token_trade_settlements, token_book, token_ohlc, market_price_tick, market_lifecycle, crypto_price_tick, the all_* channels and global_activity push reliably today; market_price_tick only sends when a price input changes, so a quiet market is silent. condition_lifecycle carries only the on-chain trading pause / unpause of a condition, so it is usually silent; follow status and resolution on market_lifecycle. system accepts subscribes, but no platform_status frames are published yet; poll GET /api/platform/status for the freeze flag.

crypto_price_tick is keyed by instrument, not market symbol — one subscription per coin serves every crypto market on that asset. See Crypto price feeds.

Firehoses. all_trade_matches, all_trade_settlements, all_books and global_activity take no ids and carry every market on the platform. all_books in particular sends a full-depth book_update plus a book_delta for every book change; a client that can’t keep up is disconnected once its outbound buffer fills (resource limits). Token channels accept explicit token ids only — there is no * wildcard — and a connection that holds both token_book and all_books receives each frame once per sid. For an activity feed, global_activity sends one frame per trade instead of the two all_trade_matches sends for a binary trade.

`tokenId` and `conditionId` come from REST

Subscribe by on-chain native ids, never by app symbol.

# Pass the market SLUG (not the symbol) to the market-detail
# endpoint — see Markets overview.
curl -H "X-Api-Key: ps_live_..." \
  https://core.api.dev.predictstreet.sde.adifoundation.ai/api/markets/{slug}

{
  "symbol":      "NC26-BIN-83479265",
  "conditionId": "0x22a88c544e7ab9...",
  "yesTokenId":  "60550363974013526351721227761627460394700175914670861601864197814576471666136",
  "noTokenId":   "3448474776790199743770418424395373406530354266022486190942562054524211572097",
  ...
}

Neg-risk (multi-outcome) events are listed as one market per question, and each question market carries its own conditionId, yesTokenId and noTokenId (also under outcomes[].tokenId) — subscribe with those. To go the other way, GET /api/markets/by-token/{id} and GET /api/markets/by-condition/{id} resolve a token or condition id back to its market.

import WebSocket from 'ws';

const KEY = process.env.PREDICTSTREET_API_KEY;
const ws = new WebSocket(
  'wss://ws-gateway.dev.predictstreet.sde.adifoundation.ai/ws/market',
  { headers: { 'X-Api-Key': KEY } },
);

ws.on('open', () => {
  ws.send(JSON.stringify({
    id: 1,
    cmd: 'subscribe',
    params: {
      subscriptions: [
        { channel: 'token_trade_matches',     ids: ['60550363974013526351721227761627460394700175914670861601864197814576471666136'] },
        { channel: 'token_trade_settlements', ids: ['60550363974013526351721227761627460394700175914670861601864197814576471666136'] },
        { channel: 'token_book',              ids: ['60550363974013526351721227761627460394700175914670861601864197814576471666136'] },
        { channel: 'token_ohlc',              ids: ['60550363974013526351721227761627460394700175914670861601864197814576471666136'] },
        { channel: 'market_price_tick',       ids: ['NC26-BIN-83479265:0'] },
        { channel: 'condition_lifecycle',     ids: ['0x22a88c544e7ab9...'] },
        { channel: 'market_lifecycle',        ids: ['btc15m-20260729t1730'] },
        { channel: 'crypto_price_tick',       ids: ['BTC-USD'] },
        { channel: 'system',                  ids: ['platform_status'] },
      ],
    },
  }));
});

ws.on('message', (raw) => {
  const ev = JSON.parse(raw.toString('utf8'));
  // route on ev.type / ev.channel / ev.sid / ev.id
});

const KEY = 'ps_live_<keyId>_<secret>';
const url = `wss://ws-gateway.dev.predictstreet.sde.adifoundation.ai/ws/market?key=${encodeURIComponent(KEY)}`;
const ws  = new WebSocket(url);

ws.addEventListener('open', () => {
  ws.send(JSON.stringify({
    id: 1, cmd: 'subscribe',
    params: { subscriptions: [{ channel: 'token_trade_matches', ids: ['60550363974013526351721227761627460394700175914670861601864197814576471666136'] }] },
  }));
});

import asyncio, json, websockets

KEY = 'ps_live_<keyId>_<secret>'
URL = 'wss://ws-gateway.dev.predictstreet.sde.adifoundation.ai/ws/market'

async def run():
    async with websockets.connect(
        URL, additional_headers={'X-Api-Key': KEY},  # websockets >= 14
    ) as ws:
        await ws.send(json.dumps({
            'id': 1, 'cmd': 'subscribe',
            'params': {'subscriptions': [
                {'channel': 'token_trade_matches', 'ids': ['60550363974013526351721227761627460394700175914670861601864197814576471666136']},
            ]},
        }))
        async for raw in ws:
            ev = json.loads(raw)

asyncio.run(run())

{
  "id": 1,
  "type": "subscribed",
  "accepted": [
    { "sid": 10, "channel": "token_trade_matches",     "ids": ["60550363974013526351721227761627460394700175914670861601864197814576471666136"] },
    { "sid": 11, "channel": "token_trade_settlements", "ids": ["60550363974013526351721227761627460394700175914670861601864197814576471666136"] },
    { "sid": 12, "channel": "token_book",              "ids": ["60550363974013526351721227761627460394700175914670861601864197814576471666136"] },
    { "sid": 13, "channel": "token_ohlc",              "ids": ["60550363974013526351721227761627460394700175914670861601864197814576471666136"] },
    { "sid": 14, "channel": "market_price_tick",       "ids": ["nc26-bin-83479265:0"] },
    { "sid": 15, "channel": "condition_lifecycle",     "ids": ["0x22a88c544e7ab9..."] },
    { "sid": 16, "channel": "market_lifecycle",        "ids": ["btc15m-20260729t1730"] },
    { "sid": 17, "channel": "crypto_price_tick",       "ids": ["btc-usd"] },
    { "sid": 18, "channel": "system",                  "ids": ["platform_status"] }
  ],
  "rejected": []
}

Ids are normalized before the ack: market symbols (also inside market_price_tick ids) and crypto instrument ids come back lower-cased, so BTC-USD and btc-usd resolve to the same feed. The channels that take no ids (all_*, global_activity) are acknowledged without an ids field — { "sid": 19, "channel": "all_books" }.

Rejection codes

`code`	When
`invalid_params`	unknown channel, malformed `tokenId` / `conditionId` / market `symbol` / crypto `instrumentId` / `market_price_tick` id (`<symbol>:<outcomeIndex>`, no leading zeros in the index), missing required `ids` (`crypto_price_tick`, `market_lifecycle` and `market_price_tick` all require at least one), `ids` sent to `all_*` or `global_activity` (`"all_books does not accept ids"`), or `system` `ids` not `["platform_status"]`
`forbidden`	tried a private channel (`user_orders`, `user_fills`, `vault_positions`, `notifications`, …) on this gateway
`subscription_cap_exceeded`	connection already holds the maximum number of subscriptions (200 by default)
`subscription_too_many_ids`	the subscription would hold more than 100 ids. Message: `"subscription accepts at most 100 ids"`. Split your ids across multiple subscriptions on the same connection. On `update_subscription` `add_ids` the limit applies to the resulting id set, and the failure arrives as an `error` frame rather than in `rejected[]` (see Commands).

Commands

update_subscription / unsubscribe / list_subscriptions / ping.

Server events

Full event payload catalog per channel.

Introduction

Endpoints

WebSocket

Authentication

Connect greeting

Available channels

`tokenId` and `conditionId` come from REST

Rejection codes

Commands

Server events

​Authentication

​Connect greeting

​Available channels

​tokenId and conditionId come from REST

​Subscribe example

​Subscribe response

​Rejection codes

​Related

Commands

Server events

Authentication

Connect greeting

Available channels

`tokenId` and `conditionId` come from REST

Subscribe example

Subscribe response

Rejection codes

Related