Function runHeadlessTaskMethod

src/workspaces/service.ts:488–534

(
    ws: WorkspaceMeta,
    adapter: CliAdapter,
    prompt: string,
    timeoutMs: number,
    // Dispatch-path extras: a taskId keys the on-disk task log; onSessionId
    // fires when the adapter's stdout scanner captures the agent's own session
    // id (recorded WHILE running, so the panel can offer "open as session").
    opts: { taskId?: string; onSessionId?: (id: string) => void } = {},
  )

  };

  const runHeadlessTaskMethod = async (
    ws: WorkspaceMeta,
    adapter: CliAdapter,
    prompt: string,
    timeoutMs: number,
    // Dispatch-path extras: a taskId keys the on-disk task log; onSessionId
    // fires when the adapter's stdout scanner captures the agent's own session
    // id (recorded WHILE running, so the panel can offer "open as session").
    opts: { taskId?: string; onSessionId?: (id: string) => void } = {},
  ): Promise<HeadlessTaskResult> => {
    if (!adapter.capabilities.headless || !adapter.composeHeadlessCommand) {
      throw new Error(`adapter "${adapter.id}" has no headless mode`);
    }
    await ensureAgentCredentialReady({
      meta: ws,
      agentId: adapter.id,
      adapter,
      logger: launcherLogger,
    });
    // Reuse a fresh interactive spawn's env/cwd (identical MCP injection),
    // then swap the interactive command for the one-shot headless argv. Inject
    // AQ_RUN_ID = this run's taskId so the agent's inbox pushes self-link to the
    // run server-side (via the `alice` shim header / opencode's MCP header) —
    // headless-only, agent never sees it. The taskId is the registry key the
    // route resolves issueId/agent from.
    const { cwd, env } = composeSpawnInputs(
      ws,
      adapter,
      undefined,
      undefined,
      opts.taskId ? { AQ_RUN_ID: opts.taskId } : undefined,
    );
    const command = adapter.composeHeadlessCommand(config.command, { cwd, env }, prompt);
    const logPaths = opts.taskId ? headlessLogPaths(headlessLogsDir, opts.taskId) : null;
    return runHeadlessTask({
      command,
      cwd,
      env,
      timeoutMs,
      logger: launcherLogger.child({ scope: 'headless', wsId: ws.id, agent: adapter.id }),
      ...(logPaths ? { stdoutFile: logPaths.stdout, stderrFile: logPaths.stderr } : {}),
      ...(adapter.extractHeadlessSessionId
        ? { extractSessionId: adapter.extractHeadlessSessionId.bind(adapter) }
        : {}),
      ...(opts.onSessionId ? { onSessionId: opts.onSessionId } : {}),
    });
  };

  /**
   * ASYNC dispatch: record the task, spawn it in the background, return the