Call from TypeScript

const response = await fetch('https://api.onecortex.io/v1/agents/agt_.../invoke', {
  method: 'POST',
  headers: {
    Authorization: `Bearer ${process.env.ONECORTEX_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({ prompt: 'hello', stream: true }),
})

const reader = response.body.getReader()
const decoder = new TextDecoder()
let buffer = ''

while (true) {
  const { done, value } = await reader.read()
  if (done) break
  buffer += decoder.decode(value, { stream: true })

  // Frames are separated by a blank line. A partial frame stays buffered.
  const frames = buffer.split('\n\n')
  buffer = frames.pop() ?? ''

  for (const frame of frames) {
    const event = frame.match(/^event: (.*)$/m)?.[1]
    const data = frame.match(/^data: (.*)$/m)?.[1]
    if (!event || !data) continue

    if (event === 'text') process.stdout.write(JSON.parse(data).delta)
    if (event === 'tool_call_start') console.log(`[calling ${JSON.parse(data).name}]`)
    if (event === 'done') console.log()
    // Handle this, or a failure looks like an empty success.
    if (event === 'error') throw new Error(JSON.parse(data).message)
  }
}

[calling word_count]
You said: hello

const response = await fetch('https://api.onecortex.io/v1/agents/agt_.../invoke', {
  method: 'POST',
  headers: {
    Authorization: `Bearer ${process.env.ONECORTEX_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({ prompt: 'hello' }),
})

const body = await response.json()
// A failed run and a refused request both carry `error`.
if (!response.ok) throw new Error(body.error.message)
console.log(body.result)

You said: hello