Function createMockAiService

src/node/services/agentSession.testHarness.ts:38–55

(args?: { emitter?: EventEmitter; overrides?: Partial<AIService> })

}

function createMockAiService(args?: { emitter?: EventEmitter; overrides?: Partial<AIService> }): {
  aiEmitter: EventEmitter;
  aiService: AIService;
} {
  const aiEmitter = args?.emitter ?? new EventEmitter();
  return {
    aiEmitter,
    aiService: Object.assign(aiEmitter, {
      isStreaming: mock((_workspaceId: string) => false),
      stopStream: mock((_workspaceId: string) => Promise.resolve(Ok(undefined))),
      getStreamInfo: mock((_workspaceId: string) => null),
      streamMessage: mock((_history: MuxMessage[]) =>
        Promise.resolve(Ok(undefined))
      ) as unknown as AIService["streamMessage"],
      ...args?.overrides,
    }) as unknown as AIService,
  };
}

export interface AgentSessionHarnessOptions {
  workspaceId: string;