Method repairBaseRepoMissingObjectsFromLocal

src/node/runtime/SSHRuntime.ts:913–1004

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

  }

  private async repairBaseRepoMissingObjectsFromLocal(
    projectPath: string,
    baseRepoPathArg: string,
    initLogger: InitLogger,
    abortSignal?: AbortSignal
  ): Promise<void> {
    if (abortSignal?.aborted) {
      throw new Error(OPERATION_ABORTED_ERROR);
    }

    await this.transport.acquireConnection({
      abortSignal,
      onWait: (waitMs) => logSSHBackoffWait(initLogger, waitMs),
    });

    if (abortSignal?.aborted) {
      throw new Error(OPERATION_ABORTED_ERROR);
    }

    initLogger.logStep("Repairing shared base repository object cache...");
    const remoteAbortController = createAbortController(
      BASE_REPO_MISSING_OBJECT_REPAIR_TIMEOUT_MS,
      abortSignal
    );

    try {
      const remoteStream = await this.exec(`git -C ${baseRepoPathArg} unpack-objects -r`, {
        cwd: "/tmp",
        abortSignal: remoteAbortController.signal,
      });
      const remoteStdoutPromise = streamToString(remoteStream.stdout);
      const remoteStderrPromise = streamToString(remoteStream.stderr);

      // A normal fetch/push can be a no-op when the remote already has the
      // commit object but is missing blobs from the same tree. Stream a complete
      // non-thin local pack and let `unpack-objects -r` add only the missing
      // objects without deleting or recreating the shared gitdir used by siblings.
      const gitProc = spawn("git", ["-C", projectPath, "pack-objects", "--all", "--stdout"], {
        stdio: ["ignore", "pipe", "pipe"],
        windowsHide: true,
      });

      let packStderr = "";
      gitProc.stderr?.on("data", (data: Buffer) => {
        const chunk = data.toString();
        packStderr += chunk;
        for (const line of chunk.split("\n").filter(Boolean)) {
          initLogger.logStderr(line);
        }
      });
      const gitExitCodePromise = waitForProcessExit(gitProc);

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