Function startWorkspaceTurnForTest

src/node/services/taskService.test.ts:559–641

(
    options: {
      stableIds?: string[];
      disposable?: boolean;
      sendMessage?: ReturnType<typeof mock>;
      remove?: ReturnType<typeof mock>;
      isStreaming?: ReturnType<typeof mock>;
      hasQueuedMessages?: ReturnType<typeof mock>;
      hasPendingQueuedOrPreparingTurn?: ReturnType<typeof mock>;
      waitForPendingStreamErrorRecoveryDecision?: ReturnType<typeof mock>;
    } = {}
  )

  });

  async function startWorkspaceTurnForTest(
    options: {
      stableIds?: string[];
      disposable?: boolean;
      sendMessage?: ReturnType<typeof mock>;
      remove?: ReturnType<typeof mock>;
      isStreaming?: ReturnType<typeof mock>;
      hasQueuedMessages?: ReturnType<typeof mock>;
      hasPendingQueuedOrPreparingTurn?: ReturnType<typeof mock>;
      waitForPendingStreamErrorRecoveryDecision?: ReturnType<typeof mock>;
    } = {}
  ) {
    const config = await createTestConfig(rootDir);
    stubStableIds(config, options.stableIds ?? ["handle", "turn"]);
    const { parentId, projectPath } = await saveLocalParentWorkspace(config, rootDir);

    const createWorkspace = mock(
      async (...args: unknown[]): Promise<Result<{ metadata: WorkspaceMetadata }>> => {
        const tags = args[7] as Record<string, string> | undefined;
        await config.editConfig((cfg) => {
          const project = cfg.projects.get(projectPath);
          assert(project, "test project must exist");
          project.workspaces.push({
            path: path.join(projectPath, "workspace-turn"),
            id: "childworkspace",
            name: "workspace-turn",
            title: "Workspace turn",
            createdAt: "2026-06-19T00:00:00.000Z",
            runtimeConfig: { type: "local" },
            tags,
          });
          return cfg;
        });
        return Ok({ metadata: createWorkspaceTurnMetadata(projectPath) });
      }
    );
    const workspaceMocks = createWorkspaceServiceMocks({
      create: createWorkspace,
      ...(options.sendMessage != null ? { sendMessage: options.sendMessage } : {}),
      ...(options.remove != null ? { remove: options.remove } : {}),
      ...(options.hasQueuedMessages != null
        ? { hasQueuedMessages: options.hasQueuedMessages }
        : {}),
      ...(options.hasPendingQueuedOrPreparingTurn != null
        ? { hasPendingQueuedOrPreparingTurn: options.hasPendingQueuedOrPreparingTurn }
        : {}),
      ...(options.waitForPendingStreamErrorRecoveryDecision != null
        ? {
            waitForPendingStreamErrorRecoveryDecision:
              options.waitForPendingStreamErrorRecoveryDecision,
          }
        : {}),
    });
    const aiMocks = createAIServiceMocks(config, {
      ...(options.isStreaming != null ? { isStreaming: options.isStreaming } : {}),
    });
    const { historyService, taskService } = createTaskServiceHarness(config, {
      aiService: aiMocks.aiService,