Processor contracts

Maintains the stream's own reduced state.

Token-bucket rate limiter that trips the stream into paused state.

Tracks Project lifecycle facts and provisioning status.

Tracks Repo lifecycle facts and Git access state.

Maintains model-visible agent history and requests LLM work from a subscribed LLM request processor.

Renders chat ingress and visible responses into model-visible agent input.

Runs OS-owned host side effects for agent streams.

Executes agent LLM requests through Cloudflare AI and appends the agent-level output and terminal request event owed by the LLM request processor contract.

Observes arbitrary stream events, matches them with JSONata rules, and appends configured reaction events.

Executes agent LLM requests through OpenAI Responses WebSocket mode, recording raw socket transcript events and appending the agent-level output and terminal request event owed by the LLM request processor contract.

Runs project-scoped codemode scripts from durable stream events and records minimal script/function-call telemetry.

Routes raw Slack webhooks into Slack-backed agent streams.

Handles Slack-specific behavior for one routed Slack agent stream.