import type { Readable, Writable } from "node:stream"; import type { DispatchAdviceProgress } from "../dispatch/advice.js"; import type { DispatchIntent } from "../dispatch/intent.js"; export declare const CONDUCTOR_BRIDGE_TOOLS: readonly ["propose_goal", "prepare_dispatch", "advise_dispatch", "propose_dispatch", "manage_worker", "start_team", "process_result"]; export declare const MAX_CONDUCTOR_BRIDGE_FRAME_BYTES: number; export declare const CONDUCTOR_BRIDGE_TOOL_SCHEMA_FILES: Readonly<{ readonly propose_goal: "conductor-goal-proposal.schema.json"; readonly prepare_dispatch: "conductor-dispatch-preparation.schema.json"; readonly advise_dispatch: "conductor-dispatch-intent.schema.json"; readonly propose_dispatch: "conductor-dispatch-proposal.schema.json"; readonly manage_worker: "conductor-manage-worker.schema.json"; readonly start_team: "conductor-start-team.schema.json"; readonly process_result: "conductor-process-result.schema.json"; }>; export interface ConductorWorkerControlRequest { readonly action: "observe" | "park" | "resume" | "stop"; readonly dispatch_id: string; readonly reason: string | null; readonly parked_until: string | null; } interface JsonRpcResponse { readonly jsonrpc: "2.0"; readonly id: string | number | null; readonly result?: unknown; readonly error?: { readonly code: number; readonly message: string; }; } export interface ConductorBridge { handleMessage(message: unknown): JsonRpcResponse | undefined; handleLine(line: string | Buffer): string | undefined; } export interface ConductorBridgeOptions { readonly packageRoot: string; readonly configRoot?: string; readonly workspaceRoot: string; readonly stateRoot: string; readonly sessionId: string; readonly actorId: string; readonly clock?: () => string; readonly adviseDispatch?: (intent: DispatchIntent) => DispatchAdviceProgress; readonly deliverAcceptedDispatch?: (eventId: string) => unknown; readonly manageWorker?: (request: ConductorWorkerControlRequest) => unknown; readonly startTeam?: (dispatchIds: readonly string[]) => unknown; readonly processResult?: (dispatchId: string) => unknown; } export declare function createConductorBridge(options: ConductorBridgeOptions): ConductorBridge; export declare function runConductorBridge(options: ConductorBridgeOptions & { readonly input: Readable; readonly output: Writable; }): Promise; export {};