Function runCursorOnce

lib/services/cli/cursor.ts:768–921

(params: {
  projectId: string;
  repoPath: string;
  args: string[];
  env: NodeJS.ProcessEnv;
  requestId?: string;
  initialSessionId?: string;
  placeholderMessageId?: string;
})

}

async function runCursorOnce(params: {
  projectId: string;
  repoPath: string;
  args: string[];
  env: NodeJS.ProcessEnv;
  requestId?: string;
  initialSessionId?: string;
  placeholderMessageId?: string;
}): Promise<CursorRunResult> {
  const { projectId, repoPath, args, env, requestId, initialSessionId, placeholderMessageId } = params;

  const child = spawn(CURSOR_EXECUTABLE, args, {
    cwd: repoPath,
    env,
    stdio: ['ignore', 'pipe', 'pipe'],
  });

  const stderrLines: string[] = [];
  const assistantStreamer = createAssistantStreamer(projectId, requestId, {
    initialMessageId: placeholderMessageId,
  });
  let updatedSessionId = initialSessionId;
  let processError: Error | null = null;
  let detectedError: CursorErrorKind | undefined;
  let errorMessage: string | undefined;

  if (child.stderr) {
    child.stderr.setEncoding('utf8');
    child.stderr.on('data', (chunk: string) => {
      chunk
        .split(/\r?\n/)
        .map((line) => line.trim())
        .filter(Boolean)
        .forEach((line) => stderrLines.push(line));
    });
  }

  child.on('error', (error) => {
    processError = error;
    stderrLines.push(error.message);
  });

  publishStatus(projectId, 'running', requestId);

  const rl = child.stdout ? readline.createInterface({ input: child.stdout }) : null;

  if (rl) {
    try {
      for await (const line of rl) {
        const trimmed = line.trim();
        if (!trimmed) {
          continue;
        }

        let event: CursorEvent | null = null;
        try {
          event = JSON.parse(trimmed) as CursorEvent;
        } catch (error) {