Persistent SSE connections

curl -N -H "Authorization: Bearer sess_..." \
  https://api.getsly.ai/v1/agents/$AGENT_ID/connect

event: task_assigned
data: {"task_id":"task_...","skill_id":"invoice.review","from_agent":"agt_..."}

event: transfer_completed
data: {"transfer_id":"tx_...","amount":"42.00","currency":"USDC","direction":"inbound"}

event: approval_requested
data: {"approval_id":"apr_...","amount":"300.00","merchant":"mer_..."}

event: stream_alert
data: {"stream_id":"str_...","severity":"warning","runway_seconds":3600}

event: policy_violation
data: {"policy_id":"pol_...","reason":"velocity_exceeded","attempted_amount":"150.00"}

event: key_rotated
data: {"key_id":"auth_...","new_public_key":"..."}

event: heartbeat
data: {}

curl -N -H "Authorization: Bearer sess_..." \
     -H "Last-Event-ID: evt_abc123" \
  https://api.getsly.ai/v1/agents/$AGENT_ID/connect

import { EventSource } from 'eventsource';

const es = new EventSource(`https://api.getsly.ai/v1/agents/${AGENT_ID}/connect`, {
  fetch: (url, init) => fetch(url, {
    ...init,
    headers: { ...init?.headers, Authorization: `Bearer ${sessionToken}` },
  }),
});

es.addEventListener('task_assigned', (e) => {
  const task = JSON.parse(e.data);
  console.log('new task', task);
});

es.addEventListener('error', (e) => {
  // Reconnect logic — EventSource auto-reconnects, but if it fails
  // persistently, re-run the Ed25519 handshake for a fresh session
});

import httpx

headers = {"Authorization": f"Bearer {session_token}"}
with httpx.stream("GET", url, headers=headers, timeout=None) as r:
    for line in r.iter_lines():
        if line.startswith("data:"):
            handle(json.loads(line[5:].strip()))

import { Sly } from '@sly_ai/sdk';

const sly = new Sly({ agentId, privateKey, autoReauth: true });

await sly.connect({
  onTask: async (task) => { ... },
  onTransfer: async (t) => { ... },
  onApproval: async (a) => { ... },
  onAlert: async (a) => { ... },
});

curl "https://api.getsly.ai/v1/agents?connected=true" \
  -H "Authorization: Bearer pk_live_..."

curl "https://api.getsly.ai/v1/agents/$AGENT_ID/liveness" \
  -H "Authorization: Bearer pk_live_..."

{
  "connected": true,
  "connectedAt": "2026-04-22T13:15:00Z",
  "lastHeartbeatAt": "2026-04-22T14:42:30Z",
  "connectionDuration": 5250
}