SSE for Live Transcripts

1
const callId = "CALL-1758124225863-80752e";
2
const evtSource = new EventSource(
3
  `/api/v1/events?callId=${callId}`,
4
  { withCredentials: true }
5
);
6
7
evtSource.onmessage = (event) => {
8
  const data = JSON.parse(event.data);
9
10
  switch (data.event_type) {
11
    case "user_interim_transcription":
12
      // Update live transcription preview (partial, will change)
13
      console.log("[STT interim]", data.interim_transcription_text);
14
      break;
15
16
    case "user_transcription":
17
      // Final user speech for this turn
18
      console.log("[STT final]", data.user_transcription_text);
19
      break;
20
21
    case "tts_completed":
22
      // Agent finished speaking this segment
23
      console.log("[TTS]", data.tts_text);
24
      break;
25
26
    case "sse_close":
27
      // Call ended, clean up
28
      evtSource.close();
29
      break;
30
  }
31
};
32
33
evtSource.onerror = (err) => {
34
  console.error("SSE connection error:", err);
35
  evtSource.close();
36
};

1
import EventSource from "eventsource";
2
3
const BASE_URL = "https://api.smallest.ai/atoms/v1";
4
const callId = "CALL-1758124225863-80752e";
5
6
const es = new EventSource(
7
  `${BASE_URL}/events?callId=${callId}`,
8
  { headers: { Cookie: "your_session_cookie" } }
9
);
10
11
es.onmessage = (event) => {
12
  const data = JSON.parse(event.data);
13
14
  if (data.event_type === "user_transcription") {
15
    console.log(`User said: ${data.user_transcription_text}`);
16
  }
17
18
  if (data.event_type === "tts_completed") {
19
    console.log(`Agent said: ${data.tts_text}`);
20
  }
21
22
  if (data.event_type === "sse_close") {
23
    es.close();
24
  }
25
};