Class: SessionOrchestrator

Makaio Framework / services-core / SessionOrchestrator

Class: SessionOrchestrator

Defined in: ../../../packages/services/core/src/session/session-orchestrator.ts:81

Slim framework session orchestrator.

Composes with SessionTurnManager (turn lifecycle, usage accumulation, completion), AdapterRegistry (adapterName to adapterId mapping), and the adapter-subsystem reverse lookup for canonical adapterId to adapterName validation when callers select a direct adapter instance.

Registers the core session.sendMessage handler only:

Get or create session (via getOrCreateSession)
Start agent if session has no agents — resolves the canonical adapterName from direct selections, uses adapterId directly when provided, otherwise resolves it via AdapterRegistry, then calls bare AdapterSubjects.startAgent
Resolve target agents (via resolveTargetAgents)
Verify agent liveness and build recovery context for dead agents (requestOptional AdapterSubjects.getAgent + buildRecoveryContext)
Get or create turn (via SessionTurnManager)
Generate message ID and store user message + routing records (requestOptional, fire-and-forget)
Emit session.turn.started + session.user_message.sent
Route to agents (via routeToAgentsCore, single shared context)
Return result with messageId, turnId, sessionId

Host-specific features (personas, MCP, execution targets, container spawn, connector swap, CWD/model enforcement, fork context, TurnContextEnricher) are handled by a host-provided orchestrator.

Example

const orchestrator = new SessionOrchestrator(MakaioBus, 'machine-id');

const { messageId, turnId, sessionId } = await MakaioBus.request(
  SessionSubjects.sendMessage,
  { sessionId: crypto.randomUUID(), adapterName: 'openai-node', message: 'Hello!' },
);