Function createSessionHarness

src/node/services/agentSession.goalAutoPause.test.ts:67–107

(workspaceId: string)

}

async function createSessionHarness(workspaceId: string): Promise<SessionHarness> {
  const { historyService, config, cleanup } = await createTestHistoryService();
  await config.addWorkspace(PROJECT_PATH, {
    id: workspaceId,
    name: workspaceId,
    projectName: "mux-agent-session-goal-test-project",
    projectPath: PROJECT_PATH,
    runtimeConfig: { type: "local" },
  });

  const extensionMetadata = new ExtensionMetadataService(
    `${config.rootDir}/agent-session-goal-extension-metadata.json`
  );
  const analytics = { recordGoalLifecycleEvent: mock(() => undefined) };
  const goalService = new WorkspaceGoalService(
    config,
    historyService,
    extensionMetadata,
    analytics
  );
  const initStateManager = Object.assign(new EventEmitter(), {
    replayInit: mock((_workspaceId: string) => Promise.resolve()),
  }) as unknown as InitStateManager;
  const backgroundProcessManager = {
    cleanup: mock((_workspaceId: string) => Promise.resolve()),
    setMessageQueued: mock((_workspaceId: string, _queued: boolean) => undefined),
  } as unknown as BackgroundProcessManager;

  const aiService = createAiService(workspaceId);
  const session = new AgentSession({
    workspaceId,
    config,
    historyService,
    aiService,
    initStateManager,
    backgroundProcessManager,
    workspaceGoalService: goalService,
  });

  return { historyService, session, goalService, extensionMetadata, aiService, analytics, cleanup };
}

describe("AgentSession goal safety hooks", () => {
  const cleanups: Array<() => Promise<void>> = [];