Function startProcess

desktop/terminal/terminal-process.ts:20–128

(record: TerminalSessionRecord, reason: 'started' | 'restarted')

}

export async function startProcess(record: TerminalSessionRecord, reason: 'started' | 'restarted') {
  clearSessionBindings(record)
  const adapter = getTerminalAdapter()
  const request = {
    projectId: record.snapshot.projectId,
    sessionPath: record.snapshot.sessionPath,
    cwd: record.snapshot.cwd,
    launchMode: record.snapshot.launchMode,
    cols: record.snapshot.cols,
    rows: record.snapshot.rows,
  } as TerminalOpenRequest
  const command = resolveTerminalCommand(request)

  try {
    const processHandle = await adapter.spawn({
      shell: command.shell,
      args: command.args,
      cwd: record.snapshot.cwd,
      cols: record.snapshot.cols,
      rows: record.snapshot.rows,
      env: resolveTerminalEnv(request),
    })

    if (getTerminalSession(record.snapshot.sessionId) !== record) {
      processHandle.kill()
      return
    }

    record.process = processHandle
    record.snapshot = {
      ...record.snapshot,
      status: 'running',
      pid: processHandle.pid,
      exitCode: null,
      exitSignal: null,
      updatedAt: nowIso(),
    }

    record.cleanup.push(
      processHandle.onData((data) => {
        record.snapshot = {
          ...record.snapshot,
          history: clampHistory(record.snapshot.history + data),
          hasVisibleContent:
            record.snapshot.hasVisibleContent ||
            (!record.suppressOutputVisibilityUntilInput && hasVisibleTerminalContent(data)),
          updatedAt: nowIso(),
        }
        persistSession(record)
        emitTerminalEvent({
          type: 'output',
          sessionId: record.snapshot.sessionId,
          data,
          createdAt: nowIso(),
        })
      }),
    )