Method writeStdin

packages/runtime/src/shell-run-manager.ts:336–479

(input: ShellRunWriteInput)

  }

  async writeStdin(input: ShellRunWriteInput): Promise<ShellRunToolResult> {
    validateWriteStdinInput(input);
    const target = parseShellRunResourceRef(input.ref);
    if (!target) throw backgroundTaskRefError(input.ref);
    const live = this.liveResource(input.sessionId, target.shellRunId);
    if (!live) return this.writeStdinWithoutLive(input, target.shellRunId);
    if (live.mode !== 'pty') throw new Error('WriteStdin requires a PTY background task ref');
    if (live.driverExit) {
      const record = await this.markObserved(await live.finished.join());
      return shellRunContent(
        record,
        ptyControlOperation(input, {
          inputQueued: false,
          resizeApplied: false,
          resizeChanged: false,
        }),
      );
    }
    if (!isPtyControlOpen(live)) {
      throw new ShellRunPtyControlClosedError();
    }
    if (input.abortSignal?.aborted)
      throw abortError('WriteStdin aborted before the control operation was committed');

    let inputQueued = false;
    let resizeApplied = false;
    let resizeChanged = false;
    let operationFailed = false;
    let exitBeforeControlCut = false;
    const controlCut = live.collector.mutateAndSnapshotAtCut(() => {
      if (input.abortSignal?.aborted) {
        throw abortError('WriteStdin aborted before the control operation was committed');
      }
      if (live.driverExit) {
        exitBeforeControlCut = true;
        return;
      }
      if (live.termination) throw new ShellRunPtyControlClosedError();
      const terminalInput =
        input.input ??
        (input.actions
          ? encodeTerminalInputActions(input.actions, {
              ...live.collector.currentInputState(),
              ...(input.size ? { cols: input.size.cols, rows: input.size.rows } : {}),
            })
          : undefined);
      if (input.size) {
        const currentSize = live.collector.currentSize();
        if (currentSize.cols === input.size.cols && currentSize.rows === input.size.rows) {
          resizeApplied = true;
        } else {
          live.driver.resize(input.size.cols, input.size.rows);
          resizeApplied = true;
          resizeChanged = true;
          try {
            live.collector.resize(input.size.cols, input.size.rows);
          } catch (error) {
            operationFailed = true;