Новые сообщения в реальном времени через API

curl -X POST 'https://api.chatterfy.ai/public-api/chats/v1/realtime' \
  -H 'ApiKey: ВАШ_КЛЮЧ' \
  -H 'Content-Type: application/json' \
  -d '{"bot_id": "ID_БОТА"}'

{
  "channel": "messenger:list_019e1768-a39d-77d7-b444-4222455c14d8_bdb00b7759d6e539#01a035ee-9281-7043-acff-7ae77ba35ae0",
  "connection_token": "eyJhbGciOiJIUzI1NiIs...",
  "ws_url": "wss://rt.chatterfy.ai/connection/websocket",
  "expires_in_seconds": 43200
}

{
  "kind": "bump",
  "bot_id": "019e1768-a39d-77d7-b444-4222455c14d8",
  "chat_id": "019e0112-dab8-7600-b1b8-8fd8c213e6aa",
  "cursor": "2026-08-31T17:37:19.841476Z",
  "chat": { "id": "019e0112-dab8-7600-b1b8-8fd8c213e6aa", "status": "manual" }
}

import { Centrifuge } from "centrifuge";

const API = "https://api.chatterfy.ai/public-api";
const BOT_ID = "ID_БОТА";

async function subscribe() {
  const response = await fetch(`${API}/chats/v1/realtime`, {
    method: "POST",
    headers: { "ApiKey": process.env.CHATTERFY_API_KEY, "Content-Type": "application/json" },
    body: JSON.stringify({ bot_id: BOT_ID }),
  });
  if (!response.ok) throw new Error(await response.text());
  return response.json();
}

const first = await subscribe();

const centrifuge = new Centrifuge(first.ws_url, {
  token: first.connection_token,
  getToken: async () => (await subscribe()).connection_token,
});

const subscription = centrifuge.newSubscription(first.channel);

subscription.on("publication", ({ data }) => {
  console.log(data.kind, data.chat_id, data.chat?.last_message?.content ?? "");
});

subscription.subscribe();
centrifuge.connect();

setInterval(subscribe, first.expires_in_seconds * 500);