WebSocket Streams

wss://wscollectpure.com?apiKey=YOUR_API_KEY

wss://wscollectpure.com?apiKey=YOUR_API_KEY&compressed=true

{
  "action": "subscribe" | "unsubscribe",
  "event": "listings" | "offers",
  "filter": {
    "productId": "uuid",
    "variantId": "uuid"
  }
}

{
  "type": "subscribed",
  "event": "offers",
  "filter": { "productId": "3fa85f64-5717-4562-b3fc-2c963f66afa6" },
  "topic": "offers:product:3fa85f64-5717-4562-b3fc-2c963f66afa6"
}

{
  "type": "unsubscribed",
  "event": "offers",
  "filter": null,
  "topic": "global:offers"
}

{
  "type": "error",
  "message": "Invalid action: \"ping\". Must be one of: subscribe, unsubscribe"
}

{
  "event": "listing.created",
  "action": "created",
  "data": { ... },
  "changedFields": null,
  "subscription": {
    "topic": "global:listings",
    "filter": null
  },
  "receivedAt": "2026-02-26T14:23:01.452Z",
  "requestId": "f47ac10b-58cc-4372-a567-0e02b2c3d479"
}

{
  "id": "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  "product_id": "3fa85f64-5717-4562-b3fc-2c963f66afa6",
  "variant_id": "1e6c3d8a-8e24-4f1a-a1c2-ef2b9b3c0d91",
  "price": 250000,
  "quantity": 2,
  "type": "fixed_pricing",
  "active": true,
  "premium_percent": 5.0,
  "premium_dollar": 100,
  "spot_premium": 4.5,
  "spot_premium_dollar": 80,
  "expires_at": "2026-03-01T00:00:00.000Z",
  "created_at": "2026-02-25T00:00:00.000Z",
  "updated_at": "2026-02-26T00:00:00.000Z"
}

{
  "id": "b2c3d4e5-f6a7-8901-bcde-f12345678901",
  "product_id": "3fa85f64-5717-4562-b3fc-2c963f66afa6",
  "variant_id": "1e6c3d8a-8e24-4f1a-a1c2-ef2b9b3c0d91",
  "price": 240000,
  "quantity": 1,
  "type": "premium_percentage_pricing",
  "active": true,
  "premium_percent": 3.0,
  "premium_dollar": 0,
  "spot_premium": 3.5,
  "spot_premium_dollar": 70,
  "expires_at": "2026-03-01T00:00:00.000Z",
  "created_at": "2026-02-25T00:00:00.000Z",
  "updated_at": "2026-02-26T00:00:00.000Z"
}

const seen = new Set();

ws.on("message", data => {
  const msg = JSON.parse(data.toString());
  if (!msg.requestId) return; // control message

  if (seen.has(msg.requestId)) return; // already processed
  seen.add(msg.requestId);

  // ... handle event once
});

npm install ws

const WebSocket = require("ws");

const API_KEY = "YOUR_API_KEY";
const ws = new WebSocket(`wss://wscollectpure.com?apiKey=${API_KEY}`);

// Keep the connection alive — server closes idle connections after 10 s
const keepAlive = setInterval(() => {
  if (ws.readyState === WebSocket.OPEN) {
    ws.ping();
  }
}, 8000);

ws.on("open", () => {
  console.log("Connected to Pure WebSocket");

  // Subscribe to all marketplace listings (global)
  ws.send(
    JSON.stringify({
      action: "subscribe",
      event: "listings",
    })
  );

  // Subscribe to offers for a specific product
  ws.send(
    JSON.stringify({
      action: "subscribe",
      event: "offers",
      filter: { productId: "3fa85f64-5717-4562-b3fc-2c963f66afa6" },
    })
  );
});

ws.on("message", raw => {
  const msg = JSON.parse(raw.toString());

  // Control messages have a `type` field
  if (msg.type === "subscribed") {
    console.log(`✓ Subscribed to ${msg.topic}`);
    return;
  }
  if (msg.type === "unsubscribed") {
    console.log(`✓ Unsubscribed from ${msg.topic}`);
    return;
  }
  if (msg.type === "error") {
    console.error(`WebSocket error: ${msg.message}`);
    return;
  }

  // Realtime event
  const { event, action, data, changedFields, receivedAt, requestId } = msg;
  console.log(`[${receivedAt}] ${event} (${action}) — requestId: ${requestId}`);

  if (event.startsWith("listing")) {
    // data.price is in cents — convert to dollars
    const dollars = data.price != null ? (data.price / 100).toFixed(2) : null;
    console.log(
      `  Product: ${data.product_id} | Ask: $${dollars} | Qty: ${data.quantity}`
    );
    if (changedFields) {
      console.log(`  Changed fields: ${changedFields.join(", ")}`);
    }
  }

  if (event.startsWith("offer")) {
    const dollars = data.price != null ? (data.price / 100).toFixed(2) : null;
    console.log(
      `  Product: ${data.product_id} | Bid: $${dollars} | Qty: ${data.quantity}`
    );
  }
});

ws.on("close", (code, reason) => {
  clearInterval(keepAlive);
  console.log(`Disconnected — code: ${code}, reason: ${reason.toString()}`);
});

ws.on("error", err => {
  console.error("WebSocket error:", err.message);
});

pip install websockets

import asyncio
import json
import websockets

API_KEY = "YOUR_API_KEY"
WS_URL = f"wss://wscollectpure.com?apiKey={API_KEY}"


def handle_event(msg: dict) -> None:
    """Process a realtime event from the server."""
    event = msg["event"]
    action = msg["action"]
    data = msg["data"]
    changed_fields = msg.get("changedFields")
    received_at = msg["receivedAt"]
    request_id = msg["requestId"]

    print(f"[{received_at}] {event} ({action}) — requestId: {request_id}")

    if event.startswith("listing"):
        price_cents = data.get("price")
        price_str = f"${price_cents / 100:.2f}" if price_cents is not None else "spot-priced"
        print(f"  Product: {data['product_id']} | Ask: {price_str} | Qty: {data['quantity']}")
        if changed_fields:
            print(f"  Changed fields: {', '.join(changed_fields)}")

    elif event.startswith("offer"):
        price_cents = data.get("price")
        price_str = f"${price_cents / 100:.2f}" if price_cents is not None else "spot-priced"
        print(f"  Product: {data['product_id']} | Bid: {price_str} | Qty: {data['quantity']}")


async def connect() -> None:
    # ping_interval sends a WebSocket ping every 8 s to prevent the
    # server's 10-second idle timeout from closing the connection
    async with websockets.connect(
        WS_URL,
        ping_interval=8,
        ping_timeout=5,
    ) as ws:
        print("Connected to Pure WebSocket")

        # Subscribe to all marketplace listings (global)
        await ws.send(json.dumps({
            "action": "subscribe",
            "event": "listings",
        }))

        # Subscribe to offers for a specific product
        await ws.send(json.dumps({
            "action": "subscribe",
            "event": "offers",
            "filter": {"productId": "3fa85f64-5717-4562-b3fc-2c963f66afa6"},
        }))

        async for raw in ws:
            msg = json.loads(raw)

            # Control messages have a "type" field
            msg_type = msg.get("type")
            if msg_type == "subscribed":
                print(f"✓ Subscribed to {msg['topic']}")
            elif msg_type == "unsubscribed":
                print(f"✓ Unsubscribed from {msg['topic']}")
            elif msg_type == "error":
                print(f"WebSocket error: {msg['message']}")
            else:
                # Realtime event
                handle_event(msg)


if __name__ == "__main__":
    asyncio.run(connect())