Method transferBundleToRemote

src/node/runtime/SSHRuntime.ts:1851–1934

* Transfer a git bundle to the remote and return its path. * Callers are responsible for cleanup of the remote bundle file.

(
    projectPath: string,
    remoteBundlePath: string,
    initLogger: InitLogger,
    abortSignal?: AbortSignal
  )

   * Callers are responsible for cleanup of the remote bundle file.
   */
  private async transferBundleToRemote(
    projectPath: string,
    remoteBundlePath: string,
    initLogger: InitLogger,
    abortSignal?: AbortSignal
  ): Promise<string> {
    await this.transport.acquireConnection({
      abortSignal,
      onWait: (waitMs) => logSSHBackoffWait(initLogger, waitMs),
    });

    if (abortSignal?.aborted) {
      throw new Error("Bundle creation aborted");
    }

    initLogger.logStep("Creating git bundle...");
    // Use --branches --tags instead of --all to exclude refs/remotes/origin/*
    // from the bundle. Those tracking refs are from the local machine's last
    // fetch and can be arbitrarily stale — importing them into the shared bare
    // base repo would give worktrees a wrong "commits behind" count.
    const gitProc = spawn(
      "git",
      ["-C", projectPath, "bundle", "create", "-", "--branches", "--tags"],
      {
        stdio: ["ignore", "pipe", "pipe"],
        windowsHide: true,
      }
    );

    // Handle stderr manually - do NOT use streamProcessToLogger here.
    // It attaches a stdout listener that drains data before pipeReadableToWebWritable
    // can consume it, corrupting the bundle.
    let stderr = "";
    gitProc.stderr?.on("data", (data: Buffer) => {
      const chunk = data.toString();
      stderr += chunk;
      for (const line of chunk.split("\n").filter(Boolean)) {
        initLogger.logStderr(line);
      }
    });

    const remoteAbortController = createAbortController(300_000, abortSignal);
    const remoteStream = await this.exec(`cat > ${this.quoteForRemote(remoteBundlePath)}`, {
      cwd: "~",
      abortSignal: remoteAbortController.signal,
    });

    try {
      try {
        await pipeReadableToWebWritable(gitProc.stdout, remoteStream.stdin, abortSignal);
      } catch (error) {
        gitProc.kill();
        throw error;
      }

      const [gitExitCode, remoteExitCode] = await Promise.all([
        waitForProcessExit(gitProc),
        remoteStream.exitCode,