Threads und Runs

# Open a thread with the assistant.
curl https://api.learnya.ai/v1/thread \
  -H "Authorization: Bearer $LEARNYA_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"assistantId": "ASSISTANT_ID", "title": "Ticket 42"}'

# Post the question.
curl https://api.learnya.ai/v1/thread/THREAD_ID/messages \
  -H "Authorization: Bearer $LEARNYA_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"content": "Where is my invoice?"}'

# Start the run on it. The answer carries the run id.
curl https://api.learnya.ai/v1/thread/THREAD_ID/runs \
  -H "Authorization: Bearer $LEARNYA_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"triggerMessageId": "MESSAGE_ID"}'

def post(path, body):
    reply = requests.post(
        f"{API}{path}", headers=HEADERS, json=body
    )
    reply.raise_for_status()
    return reply.json()


thread = post("/thread", {"assistantId": assistant["id"]})
question = post(
    f"/thread/{thread['id']}/messages",
    {"content": "Where is my invoice?"},
)
run = post(
    f"/thread/{thread['id']}/runs",
    {"triggerMessageId": question["id"]},
)
run_id = run["id"]

async function post(path, body) {
  const r = await fetch(`${API}${path}`, {
    method: "POST",
    headers,
    body: JSON.stringify(body),
  })
  if (!r.ok) throw new Error(`${r.status} on ${path}`)
  return r.json()
}

const thread = await post("/thread", {
  assistantId: assistant.id,
})
const question = await post(`/thread/${thread.id}/messages`, {
  content: "Where is my invoice?",
})
const run = await post(`/thread/${thread.id}/runs`, {
  triggerMessageId: question.id,
})
const runId = run.id

async function post<T>(path: string, body: unknown) {
  const r = await fetch(`${API}${path}`, {
    method: "POST",
    headers,
    body: JSON.stringify(body),
  })
  if (!r.ok) throw new Error(`${r.status} on ${path}`)
  return (await r.json()) as T
}

const thread = await post<{ id: string }>("/thread", {
  assistantId: assistant.id,
})
const question = await post<{ id: string }>(
  `/thread/${thread.id}/messages`,
  { content: "Where is my invoice?" },
)
const run = await post<{ id: string; status: string }>(
  `/thread/${thread.id}/runs`,
  { triggerMessageId: question.id },
)
const runId = run.id

import time

while True:
    reply = requests.get(f"{API}/run/{run_id}", headers=HEADERS)
    run = reply.json()
    if run["status"] in ("completed", "failed", "canceled"):
        break
    time.sleep(1)

if run["status"] == "completed":
    print(run["output"][0]["text"])
else:
    print(run["status"], run.get("error"))

const DONE = ["completed", "failed", "canceled"]
let run
do {
  await new Promise((done) => setTimeout(done, 1000))
  run = await fetch(`${API}/run/${runId}`, { headers }).then(
    (r) => r.json(),
  )
} while (!DONE.includes(run.status))

const done = run.status === "completed"
console.log(done ? run.output[0].text : run.error)

type RunStatus =
  | "queued"
  | "in_progress"
  | "completed"
  | "failed"
  | "canceled"
interface Run {
  id: string
  status: RunStatus
  output?: { type: "text"; text: string }[] | null
  error?: string | null
}

const DONE: RunStatus[] = ["completed", "failed", "canceled"]
let run: Run
do {
  await new Promise((done) => setTimeout(done, 1000))
  const r = await fetch(`${API}/run/${runId}`, { headers })
  run = (await r.json()) as Run
} while (!DONE.includes(run.status))

const done = run.status === "completed"
console.log(done ? run.output?.[0].text : run.error)