Goody-bag feed

# Watch the 2,000 best-ranked live rooms (the lane keeps the set full as rooms end):
curl -sX PUT 'https://api.toktikhq.com/v1/goodybag/watch-set' \
  -H "Authorization: Bearer $TOKTIK_API_KEY" -H 'Content-Type: application/json' \
  -d '{ "mode": "top", "size": 2000 }'

# …or watch specific creators (handles or numeric creator ids; each is reported live/offline/not_tracked):
curl -sX PUT 'https://api.toktikhq.com/v1/goodybag/watch-set' \
  -H "Authorization: Bearer $TOKTIK_API_KEY" -H 'Content-Type: application/json' \
  -d '{ "mode": "custom", "size": 500, "entries": ["@creator_handle", "7298720060985852961"] }'

# How many rooms you can still ask for:
curl -s 'https://api.toktikhq.com/v1/goodybag/capacity' -H "Authorization: Bearer $TOKTIK_API_KEY"

import WebSocket from "ws";

const API = process.env.TOKTIK_API ?? "https://api.toktikhq.com";

async function connect() {
  // 1. A short-lived handshake token (it carries goodybag:read only while your grant is in force).
  const res = await fetch(`${API}/v1/live/stream/token`, { method: "POST", headers: { Authorization: `Bearer ${process.env.TOKTIK_API_KEY}` } });
  if (!res.ok) throw new Error(`token: ${res.status} ${await res.text()}`);
  const { token, wsUrl } = await res.json();

  // 2. Open the socket with the token in the Authorization header (never in the URL).
  const ws = new WebSocket(process.env.TOKTIK_WS ?? wsUrl, { headers: { Authorization: `Bearer ${token}` } });
  ws.on("open", () => ws.send(JSON.stringify({ type: "goodybag.subscribe", requestId: "r1" })));
  ws.on("message", (data) => {
    const frame = JSON.parse(data.toString());
    if (frame.type === "goodybag.status") console.log("feed", frame.status);
    else if (frame.type === "goodybag.error") console.error("error", frame.code, frame.retryable ? "(retry)" : "");
    else if (frame.type === "goodybag.event") {
      const bag = frame.goodyBag;
      const leadSeconds = bag.unpackAt - Math.floor(Date.parse(frame.provenance.observedAt) / 1000);
      console.log(`bag ${bag.goodyBagId} in room ${frame.roomId} (@${frame.creatorId}): ${bag.diamondCount} diamonds, opens in ${leadSeconds}s`);
    }
  });
  // Tokens are short-lived: when the socket closes, mint a new token and reconnect (with backoff).
  ws.on("close", () => setTimeout(connect, 5000));
}
connect();

{ "type": "goodybag.subscribe", "filters": { "minCoins": 500, "minCoinsPerPerson": 20, "maxLevel": 2, "maxViewers": 300 }, "requestId": "r1" }

{ "type": "goodybag.status", "status": "subscribed", "filters": { "minCoins": 500, "minCoinsPerPerson": 20, "maxLevel": 2, "maxViewers": 300 }, "requestId": "r1" }

{
  "type": "goodybag.event",
  "event": "goodyBag",
  "eventId": "evt_goody_bag:7699967922753145632:7700088522992667425",
  "roomId": "7699967922753145632",
  "creatorId": "harisfarmer2",
  "creatorUid": "7298720060985852961",
  "goodyBag": {
    "roomId": "7699967922753145632",
    "goodyBagId": "7700088522992667425",
    "biz": "Cau lac bo fan",
    "diamondCount": 200,
    "peopleCount": 100,
    "countDownMinutes": 10,
    "unpackAt": 1792817215,
    "joinedHeadcount": 61,
    "participateMethod": "Chia se",
    "participateMethodContent": "",
    "participateThresholdSelected": "Level: 3"
  },
  "is_bxh": 1,
  "provenance": {
    "observedAt": "2026-10-24T04:37:26.069Z",
    "freshness": "near_realtime",
    "source": "platform_observed_goody_bag_poll",
    "coverageStatus": "observed",
    "methodologyVersion": "goodybag-watch-v1"
  }
}

{ "type": "goodybag.error", "code": "goodybag_forbidden", "message": "The goody-bag feed requires the goodybag:read scope.", "retryable": false, "requestId": "r1" }