SendStreamingMessage

POST https://agent-{handle}.noorle.com/

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "SendStreamingMessage",
  "params": {
    "message": {
      "messageId": "0198f0c2-1a3d-7c41-9b2e-8f5a6d3c1e07",
      "role": "ROLE_USER",
      "parts": [{ "text": "Summarize this week's escalations." }]
    }
  }
}

data: {"jsonrpc":"2.0","id":1,"result":{"task":{"id":"0198f0c2-2b4e-7d52-ac3f-9061e4d2f118","contextId":"0198f0c2-0b11-7a2f-8c9d-4e1b2a7f6c35","status":{"state":"TASK_STATE_WORKING"},"artifacts":[]}}}

data: {"jsonrpc":"2.0","id":1,"result":{"statusUpdate":{"taskId":"0198f0c2-2b4e-7d52-ac3f-9061e4d2f118","contextId":"0198f0c2-0b11-7a2f-8c9d-4e1b2a7f6c35","status":{"state":"TASK_STATE_WORKING"}}}}

data: {"jsonrpc":"2.0","id":1,"result":{"task":{"id":"0198f0c2-2b4e-7d52-ac3f-9061e4d2f118","contextId":"0198f0c2-0b11-7a2f-8c9d-4e1b2a7f6c35","status":{"state":"TASK_STATE_COMPLETED"},"artifacts":[{"artifactId":"...","parts":[{"text":"Three escalations opened this week."}]}]}}}

const resp = await fetch("https://agent-my-agent.noorle.com/", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${token}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    jsonrpc: "2.0",
    id: 1,
    method: "SendStreamingMessage",
    params: { message: { messageId: crypto.randomUUID(), role: "ROLE_USER", parts: [{ text }] } },
  }),
});

const reader = resp.body!.pipeThrough(new TextDecoderStream()).getReader();
let buffer = "";

while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  buffer += value;

  // SSE frames are separated by a blank line.
  const frames = buffer.split("\n\n");
  buffer = frames.pop() ?? "";

  for (const frame of frames) {
    const line = frame.split("\n").find((l) => l.startsWith("data:"));
    if (!line) continue;
    const envelope = JSON.parse(line.slice(5).trim());

    if (envelope.error) { /* handle and stop */ continue; }

    const r = envelope.result;
    if (r.task) { /* snapshot — read r.task.artifacts for the final text once terminal */ }
    else if (r.message) { /* a complete agent message — tool-free run */ }
    else if (r.statusUpdate) { /* r.statusUpdate.status.state */ }
    else if (r.artifactUpdate) { /* an A2UI surface snapshot, not streamed text */ }
  }
}