import type { SSEEvent } from "./types.js"; /** * All Polpo SSE event types — must stay in sync with server-side ALL_EVENTS * in src/server/sse-bridge.ts. The EventSource API requires explicit * addEventListener() calls for each named event type; `onmessage` only * receives unnamed events. */ export declare const POLPO_SSE_EVENT_NAMES: readonly ["task:created", "task:transition", "task:updated", "task:removed", "agent:spawned", "agent:finished", "agent:activity", "assessment:started", "assessment:progress", "assessment:check:started", "assessment:check:complete", "assessment:complete", "assessment:corrected", "orchestrator:started", "orchestrator:tick", "orchestrator:deadlock", "orchestrator:shutdown", "task:retry", "task:retry:blocked", "task:fix", "task:maxRetries", "task:question", "task:answered", "deadlock:detected", "deadlock:resolving", "deadlock:resolved", "deadlock:unresolvable", "task:timeout", "agent:stale", "task:recovered", "mission:saved", "mission:executed", "mission:completed", "mission:resumed", "mission:deleted", "session:created", "message:added", "runtime:plan", "approval:requested", "approval:resolved", "approval:rejected", "approval:timeout", "escalation:triggered", "escalation:resolved", "escalation:human", "sla:warning", "sla:violated", "sla:met", "checkpoint:reached", "checkpoint:resumed", "delay:started", "delay:expired", "quality:gate:passed", "quality:gate:failed", "quality:threshold:failed", "schedule:triggered", "schedule:created", "schedule:completed", "watcher:created", "watcher:fired", "watcher:removed", "action:triggered", "file:changed", "log"]; export type ConnectionStatus = "connecting" | "connected" | "reconnecting" | "disconnected" | "error"; export interface EventSourceConfig { url: string; onEvent: (event: SSEEvent) => void; onStatusChange: (status: ConnectionStatus) => void; reconnectDelay?: number; maxReconnectDelay?: number; } export declare class EventSourceManager { private es; private lastEventId; private reconnectTimer; private currentDelay; private status; private disposed; private readonly config; private readonly maxDelay; private readonly initialDelay; constructor(config: EventSourceConfig); connect(): void; disconnect(): void; getStatus(): ConnectionStatus; private handleMessage; private scheduleReconnect; private cleanup; private setStatus; } //# sourceMappingURL=event-source.d.ts.map