A governance harness with an API.

curl https://monopea-runtime.fly.dev/v1/chat \
  -H "Authorization: Bearer brain_live_..." \
  -H "Content-Type: application/json" \
  -d '{"message":"Reconcile this week'\''s invoices and propose the transfers"}'

# -> {"ok":true,"result":{"conversationId":"...","answer":"...",
#     "stopReason":"blocked_on_user","steps":7,"proposals":[...],
#     "citations":[...],"toolsExecuted":[...]}}

const ws = new WebSocket('wss://monopea-runtime.fly.dev/v1/ws?key=brain_live_...')

ws.onopen = () =>
  ws.send(JSON.stringify({ type: 'chat', message: 'Audit the inbound funnel' }))

// connection frames:  ready{tenant_id} -> accepted{conversation_id, request_id}
//                     -> ... -> result{request_id, ...} | error{error}
//
// turn frames, forwarded verbatim as the turn runs:
//   status{phase}         prepare | think | tool | answer
//   turn_start{tools_offered} / plan / step{thinking, tool_calls}
//   token / token_reset / reasoning        (the answer and the trace, streaming)
//   tool_call{...} / tool_result{...}
//   proposal{id, ...}     an outward mutation queued for approval
//   awaiting_choice{...}  the run is asking you to pick, not to approve
//   citation / artifact / ui_element / suggested_action / agent_mail
//   done{answer, stop_reason, steps}
//
// NOTE the case: the done frame carries snake_case stop_reason, while the REST
// response and the result frame carry the same value as stopReason.

// steer a run that is already in flight — folded in at the next step boundary.
// both fields are required; without conversation_id this is treated as a new turn.
ws.send(JSON.stringify({ type: 'steer', message: 'Skip the EU leads', conversation_id }))

// and stop one outright:
ws.send(JSON.stringify({ type: 'cancel', conversation_id }))