dexter/BTerminal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor(agent-dispatcher): brand sessionId at sidecar boundary

Browse source
This commit is contained in:
Hibryda 2026-03-11 05:40:28 +01:00
parent a06b9d5053
commit 889adcb004
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
v2/src/lib/agent-dispatcher.ts
View file

@ -1,6 +1,7 @@
// Agent Dispatcher — connects sidecar bridge events to agent store // Agent Dispatcher — connects sidecar bridge events to agent store
// Thin coordinator that routes sidecar messages to specialized modules // Thin coordinator that routes sidecar messages to specialized modules
import { SessionId, type SessionId as SessionIdType } from './types/ids';
import { onSidecarMessage, onSidecarExited, restartAgent, type SidecarMessage } from './adapters/agent-bridge'; import { onSidecarMessage, onSidecarExited, restartAgent, type SidecarMessage } from './adapters/agent-bridge';
import { adaptMessage } from './adapters/message-adapters'; import { adaptMessage } from './adapters/message-adapters';
import type { InitContent, CostContent, ToolCallContent } from './adapters/claude-messages'; import type { InitContent, CostContent, ToolCallContent } from './adapters/claude-messages';
@ -68,8 +69,8 @@ export async function startAgentDispatcher(): Promise<void> {
restartAttempts = 0; restartAttempts = 0;
} }
const sessionId = msg.sessionId; if (!msg.sessionId) return;
if (!sessionId) return; const sessionId = SessionId(msg.sessionId);
switch (msg.type) { switch (msg.type) {
case 'agent_started': case 'agent_started':
@ -139,7 +140,7 @@ export async function startAgentDispatcher(): Promise<void> {
}); });
} }
function handleAgentEvent(sessionId: string, event: Record<string, unknown>): void { function handleAgentEvent(sessionId: SessionIdType, event: Record<string, unknown>): void {
const provider = getSessionProvider(sessionId); const provider = getSessionProvider(sessionId);
const messages = adaptMessage(provider, event); const messages = adaptMessage(provider, event);