Turns and streaming

curl -N -X POST https://api.usenexio.com/api/v1/conversation-instances/workspace-assistant/conversations/9e4c7a12-5b3d-4f81-a6e0-2d8b1c4f7a93/turns \
  -H "Authorization: Bearer $NEXIO_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Accept: text/event-stream" \
  -d '{
    "end_user": "u_dana_ortiz",
    "message": "Summarize the runs that failed today.",
    "page_context": {"screen": "runs", "filter": "failed"}
  }'

import os
import json
import requests

with requests.post(
    "https://api.usenexio.com/api/v1/conversation-instances/workspace-assistant/conversations/9e4c7a12-5b3d-4f81-a6e0-2d8b1c4f7a93/turns",
    headers={"Authorization": "Bearer " + os.environ["NEXIO_API_KEY"], "Accept": "text/event-stream"},
    json={
        "end_user": "u_dana_ortiz",
        "message": "Summarize the runs that failed today.",
        "page_context": {"screen": "runs", "filter": "failed"},
    },
    stream=True,
    timeout=(10, 660),
) as resp:
    if resp.status_code != 200:
        raise RuntimeError(resp.json())
    event = None
    for line in resp.iter_lines(decode_unicode=True):
        if line.startswith("event: "):
            event = line[7:]
        elif line.startswith("data: "):
            print(event, json.loads(line[6:]))

const resp = await fetch(
  "https://api.usenexio.com/api/v1/conversation-instances/workspace-assistant/conversations/9e4c7a12-5b3d-4f81-a6e0-2d8b1c4f7a93/turns",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.NEXIO_API_KEY}`,
      "Content-Type": "application/json",
      Accept: "text/event-stream",
    },
    body: JSON.stringify({
      end_user: "u_dana_ortiz",
      message: "Summarize the runs that failed today.",
      page_context: { screen: "runs", filter: "failed" },
    }),
  },
)
if (resp.status !== 200) throw new Error(JSON.stringify(await resp.json()))
const reader = resp.body!.getReader()
const decoder = new TextDecoder()
let buffer = ""
for (;;) {
  const { value, done } = await reader.read()
  if (done) break
  buffer += decoder.decode(value, { stream: true })
  let sep: number
  while ((sep = buffer.indexOf("\n\n")) !== -1) {
    const frame = buffer.slice(0, sep)
    buffer = buffer.slice(sep + 2)
    const event = frame.match(/^event: (.*)$/m)?.[1]
    const data = frame.match(/^data: (.*)$/m)?.[1]
    if (event && data) console.log(event, JSON.parse(data))
  }
}