Method createWorkspaceTurn

src/node/services/taskService.ts:2913–3180

(
    args: WorkspaceTurnCreateArgs
  )

  }

  async createWorkspaceTurn(
    args: WorkspaceTurnCreateArgs
  ): Promise<Result<WorkspaceTurnCreateResult, string>> {
    const ownerWorkspaceId = coerceNonEmptyString(args.ownerWorkspaceId);
    if (!ownerWorkspaceId) {
      return Err("Task.createWorkspaceTurn: ownerWorkspaceId is required");
    }
    const prompt = coerceNonEmptyString(args.prompt);
    if (!prompt) {
      return Err("Task.createWorkspaceTurn: prompt is required");
    }
    const title = coerceNonEmptyString(args.title) ?? "Workspace task";
    const mode = args.workspace?.mode ?? "new";
    if (mode !== "new" && mode !== "fork" && mode !== "existing") {
      return Err("Task.createWorkspaceTurn: unsupported workspace mode");
    }
    const queueDispatchMode = args.workspace?.queueDispatchMode ?? "tool-end";
    if (queueDispatchMode !== "tool-end" && queueDispatchMode !== "turn-end") {
      return Err("Task.createWorkspaceTurn: unsupported queueDispatchMode");
    }

    await using _lock = await this.mutex.acquire();

    const parentMetaResult = await this.aiService.getWorkspaceMetadata(ownerWorkspaceId);
    if (!parentMetaResult.success) {
      return Err(`Task.createWorkspaceTurn: owner workspace not found (${parentMetaResult.error})`);
    }
    const parentMeta = parentMetaResult.data;
    const cfg = this.config.loadConfigOrDefault();
    const taskSettings = cfg.taskSettings ?? DEFAULT_TASK_SETTINGS;
    const taskProjectConfig = cfg.projects.get(stripTrailingSlashes(parentMeta.projectPath));
    if ((parentMeta.projects?.length ?? 0) > 1) {
      // WorkspaceService.create only materializes one project checkout; fail loudly instead of
      // silently dropping secondary repos from a multi-project caller's task context.
      return Err("Task.createWorkspaceTurn: multi-project workspace turns are not supported yet");
    }
    if (!taskProjectConfig?.trusted) {
      return Err(
        "This project must be trusted before creating workspaces. Trust the project in Settings → Security, or create a workspace from the project page."
      );
    }

    const allWorkspaceTurns = await this.taskHandleStore.listAllWorkspaceTurns();
    const ownerWorkspaceTurns = allWorkspaceTurns.filter(
      (record) => record.ownerWorkspaceId === ownerWorkspaceId
    );
    const activeAgentCount = this.countActiveAgentTasks(cfg);
    const ensureParallelSlot = async (): Promise<Result<void, string>> => {
      const activeWorkspaceTurnCount = await this.countActiveWorkspaceTurns(allWorkspaceTurns);
      const activeCount = activeAgentCount + activeWorkspaceTurnCount;
      if (activeCount >= taskSettings.maxParallelAgentTasks) {
        return Err(
          `Task.createWorkspaceTurn: maxParallelAgentTasks exceeded (active=${activeCount}, max=${taskSettings.maxParallelAgentTasks})`
        );
      }
      return Ok(undefined);
    };