WebSocket

import asyncio

from langbot import LangbotClient


async def main() -> None:
    lb = LangbotClient()  # LANGBOT_API_TOKEN, else the token `langbot login` saved, else anonymous
    async for evt in lb.stream(phrases=["tariff"], types=["phrase_detected"]):
        verdict = evt.verdict.counts if evt.verdict else None
        print(evt.event_id, evt.phrase, evt.t_spoken, "counts:", verdict)


asyncio.run(main())

import { LangbotClient } from "@langbotai/sdk";

const lb = new LangbotClient(); // LANGBOT_API_TOKEN when set, else anonymous
const stream = lb.stream(
  { phrases: ["tariff"], types: ["phrase_detected"] },
  { onStatus: (s) => console.error(s.state), onInvalid: (raw, err) => console.error("dropped", raw, err) },
);
for await (const evt of stream) {
  console.log(evt.event_id, evt.phrase, evt.t_spoken, "counts:", evt.verdict?.counts ?? null);
}

GET /v1/stream?events=ev_a,ev_b&phrases=tariff,recession&types=phrase_detected,speaker_change
Authorization: Bearer lb_…            (Node / server clients)

{"type":"hello","seq":48212,"ts":1793566860000,"filters":{"events":["ev_a"],"phrases":["tariff"],"types":[],"subjects":[],"context":[]},"delay_ms":60000,"plan":"anonymous","effective_plan":"free","user_id":null,"agent":null}

{"id":"evt_01M6CQ02PR3SVZ3TV7FCXH7E09","type":"phrase_detected","source_id":"src_example_public","event_id":"ev_kxexamplemention_26nov01","market_refs":["KXEXAMPLEMENTION-26NOV01-TARI"],"phrase":"tariff","raw":"we will talk about tariff today","speaker":{"label":"SPK_1","name":"Example Speaker","confidence":0.9},"confidence":0.93,"t_spoken":1793566809000,"t_detected":1793566809070,"t_emitted":1793566809076,"lag_vs_public_ms":null,"source_kind":"hls","seq":9,"hash":"aaaa…","prev_hash":"bbbb…","raw_hash":"cccc…","chain_seq":10,"fact":null,"class":"fact","verdict":{"counts":true,"reason":"mention 1 (1 needed)","role":null}}

{"op":"subscribe","events":["ev_c"],"phrases":["blackwell"],"types":["phrase_detected"]}
{"op":"ping"}
{"op":"stats"}

import asyncio

from langbot import LangbotClient, LangbotError, StreamRefused


async def follow(event_id: str) -> None:
    lb = LangbotClient()
    seen: set[str] = set()
    last_spoken = 0
    backoff = 1.0
    while True:
        if last_spoken:  # (re)connecting after a drop: fetch what was said meanwhile
            for missed in await lb.recent_events(event_id, since=last_spoken):
                if missed.id not in seen:
                    seen.add(missed.id)
                    print("backfilled", missed.phrase, missed.t_spoken)
        try:
            async for evt in lb.stream(
                events=[event_id], types=["phrase_detected"], reconnect=False
            ):
                backoff = 1.0
                if evt.id in seen:
                    continue
                seen.add(evt.id)
                last_spoken = max(last_spoken, evt.t_spoken)
                print(evt.phrase, evt.t_spoken)
        except StreamRefused:  # 1008: the connection cap; retrying cannot help
            raise
        except LangbotError:  # a drop: back off, backfill, reconnect
            pass
        await asyncio.sleep(backoff)
        backoff = min(backoff * 2, 30.0)


asyncio.run(follow("ev_kxexamplemention_26nov01"))

import { LangbotClient } from "@langbotai/sdk";

const lb = new LangbotClient();
const seen = new Set<string>();
let lastSpoken = 0;
const stream = lb.stream(
  { events: ["ev_kxexamplemention_26nov01"], types: ["phrase_detected"] },
  {
    onStatus: async (s) => {
      if (s.state !== "open" || !lastSpoken) return; // a reconnect: fetch what was missed
      const missed = await lb.recentEvents({ eventId: "ev_kxexamplemention_26nov01", since: lastSpoken });
      for (const e of missed) {
        if (seen.has(e.id)) continue;
        seen.add(e.id);
        console.log("backfilled", e.phrase);
      }
    },
  },
);
for await (const evt of stream) {
  if (seen.has(evt.id)) continue;
  seen.add(evt.id);
  lastSpoken = Math.max(lastSpoken, evt.t_spoken);
  console.log(evt.phrase, evt.t_spoken);
}

event: hello
data: {"type":"hello","seq":9032,"delay_ms":60000,"plan":"anonymous","effective_plan":"free",…}

event: phrase_detected
data: {"id":"evt_01M6…","type":"phrase_detected","phrase":"tariff",…}