API & Communication

Event Types

Connection Management

• Capacity — up to 100 concurrent SSE connections; oldest evicted when cap is reached
• Slow consumers — connections closed when receive buffer hits 16 queued events
• Disconnect cleanup — closing the tab, cancelling the reader, or aborting the request all dispose the subscription deterministically

JavaScript Example

The standard EventSource API doesn't support custom headers, so use fetch() with manual SSE parsing:

const TOKEN = '<jwt>';
const res = await fetch(
  'http://localhost:3001/v1/events?conversationKey=my-conversation',
  { headers: { Authorization: `Bearer ${TOKEN}` } },
);

const reader = res.body.getReader();
const decoder = new TextDecoder();
let buf = '';

while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  buf += decoder.decode(value, { stream: true });
  const frames = buf.split('\n\n');
  buf = frames.pop() ?? '';

  for (const frame of frames) {
    const dataLine = frame.split('\n').find((l) => l.startsWith('data: '));
    if (!dataLine) continue;
    const event = JSON.parse(dataLine.slice(6));
    console.log(event.message.type, event.message);
  }
}