import json, os, httpx

with httpx.stream(
    "POST", "https://api.onecortex.io/v1/agents/agt_.../agui",
    headers={"Authorization": f"Bearer {os.environ['ONECORTEX_API_KEY']}"},
    json={"threadId": "user-42", "messages": [{"id": "m1", "role": "user", "content": "hello"}]},
) as response:
    for line in response.iter_lines():
        if line.startswith("data: "):
            event = json.loads(line[6:])
            if event["type"] == "TEXT_MESSAGE_CONTENT":
                print(event["delta"], end="", flush=True)
            elif event["type"] == "RUN_ERROR":
                raise RuntimeError(event["message"])

import { HttpAgent } from '@ag-ui/client'

const agent = new HttpAgent({
  url: 'https://api.onecortex.io/v1/agents/agt_.../agui',
  headers: { Authorization: `Bearer ${process.env.ONECORTEX_API_KEY}` },
  threadId: 'user-42',
})
agent.addMessage({ id: 'm1', role: 'user', content: 'hello' })

await agent.runAgent({}, {
  onTextMessageContentEvent: ({ event }) => { process.stdout.write(event.delta) },
})

curl -N https://api.onecortex.io/v1/agents/agt_.../agui \
  -H "Authorization: Bearer $ONECORTEX_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"threadId":"user-42","messages":[{"id":"m1","role":"user","content":"hello"}]}'

"data: {\"type\":\"RUN_STARTED\",\"threadId\":\"user-42\",\"runId\":\"run-1\"}"

{
  "error": {
    "code": "invalid_request",
    "message": "Send at least one user message, or a resume to answer a paused run.",
    "requestId": "req_01K0000000000000000000000"
  }
}

{
  "error": {
    "code": "unauthenticated",
    "message": "A valid Onecortex API key is required.",
    "requestId": "req_01K0000000000000000000000"
  }
}

{
  "error": {
    "code": "not_found",
    "message": "That agent does not exist.",
    "requestId": "req_01K0000000000000000000000"
  }
}

{
  "error": {
    "code": "validation_failed",
    "message": "<string>",
    "requestId": "<string>",
    "details": {}
  }
}