SSE stream of new messages on the conversation.

curl --request GET \
  --url https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

"<string>"

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

GET

api

agents

{agentId}

conversations

{convId}

events

SSE stream of new messages on the conversation.

curl --request GET \
  --url https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://openapi.beeos.ai/api/v1/agents/{agentId}/conversations/{convId}/events")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

"<string>"

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

{
  "success": false,
  "error": {
    "code": "agent_not_found",
    "message": "<string>",
    "type": "api_error",
    "request_id": "<string>",
    "param": "<string>",
    "metadata": {}
  }
}

Authorizations

Authorization

string

header

required

Pass a user JWT or a oag_ User API Key on the Authorization: Bearer <token> header. Both are validated by openapi-gateway against the Auth service.

Both credential types are user-scoped: every key (and every JWT) is bound to exactly one owner, and every route grants the caller full access to that owner's own resources. Cross-tenant access is denied by owner-ACL inside the handlers — there is no per-route scope vocabulary on this API.

Removed in v1.1.0: the legacy agents:* / tasks:* / files:* / instances:* scope set has been dropped together with the 403 insufficient_scope error. Existing oag_ keys automatically gain full owner-level access and do not need to be re-issued. SDK calls that previously passed scopes to createAPIKey should drop the argument. See the changelog at the bottom of this spec for the full migration note.

Path Parameters

agentId

string

required

Maximum string length: 128

convId

string

required

Maximum string length: 128

Query Parameters

since

integer<int64>

Replay cursor. Matches the offset field on the last received event — clients persist this value and pass it back on reconnect to resume without gaps or duplicates (Last-Event-ID semantics; the wire spelling stays since for backward compatibility with the pre-v2 SSE clients).

Special values:

omitted / 0 — full history replay.
<offset> — resume strictly AFTER the given offset.

Unlike the task variant, this stream never auto-closes on a terminal envelope — conversations stay open across many turns and emit further agent_reply events. Persist since across reconnect ranges to avoid dropping turns during network blips.

Required range: x >= 0

Response

SSE stream of channel-message envelopes.

Server-Sent Events stream.

Per-event JSON payload format (v3 envelope fields body, state, stop_reason, updated_at are populated whenever the underlying row was written via the v3 path; legacy v1 / v2 rows leave them empty — consumers should fall back to payload.text

type to detect terminality):

event: message
data: {
  "type": "agent_message_chunk",   // see below
  "message_id": "msg-uuid",
  "offset": 5,                     // monotonic per-channel offset
  "in_reply_to": "msg-source-uuid",
  "publisher_id": "agent-identity",
  "payload": { ... },              // opaque, per-type
  "body": "Hello, world",          // v3 cumulative text (optional)
  "state": "streaming",            // v3 lifecycle (optional)
  "stop_reason": "",               // v3 terminal reason (only set when state != streaming)
  "created_at": "2026-05-14T18:00:00.000Z",
  "updated_at": "2026-05-14T18:00:00.123Z"
}

Backfill truncation frame — emitted ONCE when the server caps the historical replay window (see since=<offset> semantics above). Field shape matches TaskSSEBackfillTruncated. Clients should resume from oldest_redis_offset after seeing this frame:

event: backfill_truncated
data: {
  "since": 100,
  "oldest_redis_offset": 1500,
  "hint": "stream evicted entries older than oldest_redis_offset"
}

Terminal events:

event: end
data: { "reason": "task_terminal" }    # task only: auto-close after agent_reply / agent_reply_error / agent.refuse / agent_busy

event: end
data: { "reason": "stream_closed" }    # MS closed the upstream stream

event: end
data: { "reason": "channel_closed" }   # conversation only: caller (or peer) deleted the conversation

end.reason enum:

reason	surface	when
`task_terminal`	task	terminal reply auto-closed the SSE
`stream_closed`	task + conversation	MS closed the upstream stream
`channel_closed`	conversation	the underlying channel was deleted

Well-known message type values:

type	meaning
`chat_message`	caller's prompt
`agent_reasoning`	agent reasoning / chain-of-thought as an independent append-only row (v3; `body` carries the cumulative reasoning text, `state` transitions streaming→completed). Never terminal — it never closes the SSE.
`agent_thought_chunk`	agent reasoning (incremental, legacy pre-v3)
`agent_message_chunk`	agent reply delta (incremental)
`agent_reply_delta`	terminal-bound streaming delta
`agent_reply`	terminal success reply
`agent_reply_error`	terminal failure reply
`agent.input_required`	pause awaiting `user.continue`
`agent.auth_required`	pause awaiting `user.auth_grant`
`user.continue`	caller resume of `input_required`
`user.auth_grant`	caller resume of `auth_required`
`chat_cancel`	caller-initiated cancel

deploy

instances

computer

mobile

files

agents

tasks

conversations

API Reference

SSE stream of new messages on the conversation.

Authorizations

Path Parameters

Query Parameters

Response