Stream session events

curl -sSN https://app.syntic.ai/v1/sessions/sesn_01JC7M2K4P6R8T0V2X4Z/stream \
  -H "Authorization: Bearer $SYNTIC_API_KEY" \
  -H "syntic-beta: agents-2026-11-01" \
  -H "Last-Event-ID: evt_01JC7M3B"

import json
import os
 
import requests
 
url = "https://app.syntic.ai/v1/sessions/sesn_01JC7M2K4P6R8T0V2X4Z/stream"
headers = {"Authorization": f"Bearer {os.environ['SYNTIC_API_KEY']}", "syntic-beta": "agents-2026-11-01"}
last_id = None
 
while True:  # reconnect after the server closes the stream (every 10 minutes)
    if last_id:
        headers["Last-Event-ID"] = last_id
    with requests.get(url, headers=headers, stream=True, timeout=(10, 60)) as r:
        r.raise_for_status()
        for line in r.iter_lines(decode_unicode=True):
            if line.startswith("id: "):
                last_id = line[4:]
            elif line.startswith("data: "):
                event = json.loads(line[6:])
                if event["type"] == "message.delta":
                    print(event["delta"], end="", flush=True)
                elif event["type"] == "status.changed" and event["status"] == "archived":
                    raise SystemExit

const url = 'https://app.syntic.ai/v1/sessions/sesn_01JC7M2K4P6R8T0V2X4Z/stream'
const headers: Record<string, string> = {
  Authorization: `Bearer ${process.env.SYNTIC_API_KEY}`,
  'syntic-beta': 'agents-2026-11-01',
}
 
const res = await fetch(url, { headers })
if (!res.ok) throw new Error(`${res.status} ${await res.text()}`)
const reader = res.body!.pipeThrough(new TextDecoderStream()).getReader()
let buffer = ''
for (;;) {
  const { value, done } = await reader.read()
  if (done) break // reconnect with Last-Event-ID to resume
  buffer += value
  let cut: number
  while ((cut = buffer.indexOf('\n\n')) >= 0) {
    const block = buffer.slice(0, cut)
    buffer = buffer.slice(cut + 2)
    const data = block.split('\n').find((l) => l.startsWith('data: '))
    if (!data) continue // keep-alive comment
    const event = JSON.parse(data.slice(6))
    if (event.type === 'message.delta') process.stdout.write(event.delta)
    if (event.type === 'approval.required') console.log('\napproval needed for', event.name)
  }
}