/** * Noah — FleetBus Adapter * * Bridges the real FleetBus (which uses fleetSend()) to the * FleetBusClient interface expected by TemporalCortex and CronManager. * * Without this adapter, cortex.perceive() and cronManager.executeJob() * would call bus.send() / bus.broadcast() — methods that do not exist * on the real FleetBus class. Tests used MockFleetBus which implements * them, masking the production failure. * * Bug fix: FleetBus class does not have send()/broadcast() methods. */ import type { FleetBusClient } from './null-implementations.js'; interface FleetBusLike { getConfig(): { agentId: string; }; getCard(agentId: string): unknown; validateRouting(message: unknown): { allowed: boolean; reason?: string; }; audit(type: string, outcome: string, data: unknown): unknown; } interface TransportConfigLike { callGateway: (...args: unknown[]) => Promise; defaultTimeoutMs?: number; fireAndForget?: boolean; outputSanitizer?: unknown; shield?: unknown; } type FleetSendFn = (bus: FleetBusLike, transport: TransportConfigLike, options: { to: string; method: string; params: unknown; }) => Promise<{ success: boolean; error?: string; }>; export declare class FleetBusAdapter implements FleetBusClient { private readonly bus; private readonly transport; private readonly fleetSendFn; constructor(bus: FleetBusLike, transport: TransportConfigLike, fleetSendFn: FleetSendFn); send(method: string, to: string, params: unknown): Promise; broadcast(method: string, params: unknown): Promise; } export {}; //# sourceMappingURL=fleet-bus-adapter.d.ts.map