diff --git a/apps/server/trpc/subscriptions.ts b/apps/server/trpc/subscriptions.ts index 97cf38b..027e055 100644 --- a/apps/server/trpc/subscriptions.ts +++ b/apps/server/trpc/subscriptions.ts @@ -40,7 +40,6 @@ export const ALL_EVENT_TYPES: DomainEventType[] = [ 'agent:account_switched', 'agent:deleted', 'agent:waiting', - 'agent:output', 'task:queued', 'task:dispatched', 'task:completed', @@ -84,7 +83,6 @@ export const AGENT_EVENT_TYPES: DomainEventType[] = [ 'agent:account_switched', 'agent:deleted', 'agent:waiting', - 'agent:output', ]; /** diff --git a/docs/server-api.md b/docs/server-api.md index 2b69321..f1faab4 100644 --- a/docs/server-api.md +++ b/docs/server-api.md @@ -204,13 +204,13 @@ Each procedure uses `require*Repository(ctx)` helpers that throw `TRPCError(INTE | Procedure | Type | Events | |-----------|------|--------| | onEvent | subscription | All event types | -| onAgentUpdate | subscription | agent:* events (8 types) | +| onAgentUpdate | subscription | agent:* events (7 types, excludes agent:output) | | onTaskUpdate | subscription | task:* + phase:* events (8 types) | | onPageUpdate | subscription | page:created/updated/deleted | | onPreviewUpdate | subscription | preview:building/ready/stopped/failed | | onConversationUpdate | subscription | conversation:created/answered | -Subscriptions use `eventBusIterable()` — queue-based async generator, max 1000 events, 30s heartbeat. +Subscriptions use `eventBusIterable()` — queue-based async generator, max 1000 events, 30s heartbeat. `agent:output` is excluded from all general subscriptions (it's high-frequency streaming data); use the dedicated `onAgentOutput` subscription instead. ## Coordination Module