Method writeFileViaExec

src/node/runtime/DevcontainerRuntime.ts:333–403

(
    filePath: string,
    abortSignal?: AbortSignal
  )

  }

  private writeFileViaExec(
    filePath: string,
    abortSignal?: AbortSignal
  ): WritableStream<Uint8Array> {
    const quotedPath = this.quoteForContainer(filePath);
    const tempPath = getAtomicWriteTempPath(filePath);
    const quotedTempPath = this.quoteForContainer(tempPath);
    const writeCommand = `mkdir -p $(dirname ${quotedPath}) && cat > ${quotedTempPath} && mv ${quotedTempPath} ${quotedPath}`;

    let execPromise: Promise<ExecStream> | null = null;
    const writeAbortController = new AbortController();
    const abortWrite = () => writeAbortController.abort();
    if (abortSignal?.aborted) {
      writeAbortController.abort();
    } else {
      abortSignal?.addEventListener("abort", abortWrite, { once: true });
    }
    const cleanupAbortForwarder = () => {
      abortSignal?.removeEventListener("abort", abortWrite);
    };

    const getExecStream = () => {
      execPromise ??= this.exec(writeCommand, {
        cwd: this.getContainerBasePath(),
        timeout: 300,
        abortSignal: writeAbortController.signal,
      });
      return execPromise;
    };

    return new WritableStream<Uint8Array>({
      write: async (chunk) => {
        const stream = await getExecStream();
        const writer = stream.stdin.getWriter();
        try {
          await writer.write(chunk);
        } finally {
          writer.releaseLock();
        }
      },
      close: async () => {
        try {
          const stream = await getExecStream();
          await stream.stdin.close();
          const exitCode = await stream.exitCode;

          if (exitCode !== 0) {
            const stderr = await streamToString(stream.stderr);
            throw new RuntimeError(`Failed to write file ${filePath}: ${stderr}`, "file_io");
          }
        } finally {
          cleanupAbortForwarder();
        }
      },
      abort: async (reason?: unknown) => {
        writeAbortController.abort();
        if (execPromise) {
          try {