Method startPty

packages/runtime/src/shell-run-manager.ts:805–905

(
    input: ShellRunBashInput,
    shellRunId: string,
    timeoutMs: number | undefined,
    stack: PtyStack,
    slotReservation: ShellRunSlotReservation,
    sessionEpoch: number,
  )

  }

  private async startPty(
    input: ShellRunBashInput,
    shellRunId: string,
    timeoutMs: number | undefined,
    stack: PtyStack,
    slotReservation: ShellRunSlotReservation,
    sessionEpoch: number,
  ): Promise<LivePtyShellRun> {
    const pending: Array<(live: LivePtyShellRun) => void> = [];
    let live: LivePtyShellRun | undefined;
    let driver: PtyProcessDriver | undefined;
    const dispatch = (callback: (target: LivePtyShellRun) => void): void => {
      if (live) callback(live);
      else pending.push(callback);
    };
    let collector: PtyScreenCollector | undefined;
    let startingRecord: ShellRunRecord | undefined;
    try {
      collector = new PtyScreenCollector({
        stack,
        cols: PTY_INITIAL_COLS,
        rows: PTY_INITIAL_ROWS,
        onProtocolReply: (data) => {
          if (!live || !driver)
            throw new Error('PTY protocol reply arrived before driver admission');
          if (live.driverExit || live.termination || live.integrityFailure) return;
          driver.write(data);
        },
        onDirty: () => dispatch((target) => this.scheduleAutomaticFlush(target)),
        onFailure: (error) => dispatch((target) => this.handleIntegrityFailure(target, error)),
      });
      const plan = buildPtyShellSpawnPlan(
        input.shell ?? defaultShellPlan(),
        input.command,
        input.env ?? process.env,
      );
      startingRecord = await this.createStartingRecord(
        input,
        shellRunId,
        timeoutMs,
        collector.lastGoodSnapshot(),
      );
      this.assertStartupAllowed(input.sessionId, sessionEpoch, input.abortSignal);
      driver = new PtyProcessDriver({
        stack,
        file: plan.file,
        args: plan.args,
        cwd: input.cwd,
        env: plan.env ?? input.env ?? process.env,
        cols: PTY_INITIAL_COLS,
        rows: PTY_INITIAL_ROWS,
        onData: (data) => dispatch((target) => this.onPtyData(target, data)),
        onExit: (exit) => {
          dispatch((target) => {
            this.publishPtyData(target);
            this.onNativeRootExit(target);
          });
          dispatch((target) => this.onDriverExit(target, { mode: 'pty', value: exit }));