KAP bildirim akışı (WebSocket)

wss://api.theportfoy.com/portgate/v1/kap-feed/stream

{"action": "auth", "api_key": "pg_live_…"}

{"type": "auth_ok", "plan": "tester"}

{"action": "subscribe", "ids": ["symbol:THYAO", "type:FR", "bist:THYAO"]}
{"action": "unsubscribe", "ids": ["type:FR"]}

{"type": "subscribed", "ids": ["symbol:THYAO", "type:FR"], "invalid": ["bist:THYAO"]}
{"type": "unsubscribed", "ids": ["type:FR"]}

{"type": "disclosure", "replay": false, "data": {
  "disclosure_index": 1671665,
  "type": "CA", "class": "ODA",
  "symbols": ["PCILT"], "filer_codes": ["PCILT"],
  "filer_title": "PC İLETİŞİM VE MEDYA HİZMETLERİ SANAYİ TİCARET A.Ş.",
  "published_at": "2026-10-03T09:56:03Z",
  "reason": "UPD", "related_index": 1671010,
  "subject": {"tr": "Payların Geri Alınmasına İlişkin Bildirim",
              "en": "Notification Regarding Share Buy-Back"},
  "summary": {"tr": "02.10.2026 Tarihli Pay Geri Alım İşlemleri", "en": null},
  "link": "https://www.kap.org.tr/Bildirim/1671665",
  "attachment_count": 0,
  "year": null, "period": null, "consolidation": null
}}

curl -H "X-API-Key: $PORTGATE_KEY" \
  "https://api.theportfoy.com/portgate/v1/kap-feed/disclosures/1671665"

{
  "disclosure_index": 1671665,
  "type": "CA",
  "reason": "UPD",
  "related_index": 1671010,
  "published_at": "2026-10-03T09:56:03Z",
  "symbols": ["PCILT"],
  "subject": {"tr": "Payların Geri Alınmasına İlişkin Bildirim",
              "en": "Notification Regarding Share Buy-Back"},
  "summary": {"tr": "02.10.2026 Tarihli Pay Geri Alım İşlemleri", "en": null},
  "link": "https://www.kap.org.tr/Bildirim/1671665",
  "attachment_count": 0,
  ...
}

{"action": "subscribe", "ids": ["all"], "last_seen_index": 1671664}

{"type": "subscribed", "ids": ["all"], "invalid": []}
{"type": "disclosure", "replay": true, "data": {"disclosure_index": 1671665, ...}}
{"type": "disclosure", "replay": true, "data": {"disclosure_index": 1671666, ...}}
{"type": "replay_done", "last_index": 1671666, "truncated": false}
{"type": "disclosure", "replay": false, "data": {"disclosure_index": 1671667, ...}}

const URL = "wss://api.theportfoy.com/portgate/v1/kap-feed/stream";
const TOPICS = ["symbol:THYAO", "type:FR"];

let lastSeen = loadLastSeen();   // your durable store; null on first run
const seen = new Set();          // recent indexes, for at-least-once dedupe
let backoff = 1000;

function connect() {
  const ws = new WebSocket(URL);
  let pingTimer;

  ws.onopen = () => ws.send(JSON.stringify({ action: "auth", api_key: KEY }));

  ws.onmessage = (ev) => {
    const msg = JSON.parse(ev.data);
    if (msg.type === "auth_ok") {
      backoff = 1000;
      const sub = { action: "subscribe", ids: TOPICS };
      if (lastSeen !== null) sub.last_seen_index = lastSeen;
      ws.send(JSON.stringify(sub));
      pingTimer = setInterval(
        () => ws.send(JSON.stringify({ action: "ping" })), 30_000);
    } else if (msg.type === "disclosure") {
      const d = msg.data;
      if (seen.has(d.disclosure_index)) return;   // duplicate
      seen.add(d.disclosure_index);
      handle(d);                                  // queue it; keep this fast
      lastSeen = Math.max(lastSeen ?? 0, d.disclosure_index);
      saveLastSeen(lastSeen);
    } else if (msg.type === "replay_done" && msg.truncated) {
      backfillFromRest(lastSeen);                 // GET /v1/kap-feed/disclosures
    } else if (msg.type === "error") {
      console.warn(msg.code, msg.message);
    }
  };

  ws.onclose = (ev) => {
    clearInterval(pingTimer);
    if (ev.code === 4401 || ev.code === 4403) return;   // fix the key
    setTimeout(connect, backoff + Math.random() * 1000);
    backoff = Math.min(backoff * 2, 60_000);
  };
}

connect();