Class LocalUnpackSSHRuntime

src/node/runtime/SSHRuntime.syncContract.test.ts:103–164

}

class LocalUnpackSSHRuntime extends SSHRuntime {
  readonly commands: string[] = [];

  constructor(private readonly baseRepoPath: string) {
    const config: SSHRuntimeConfig = {
      host: "example.test",
      srcBaseDir: "/remote/src",
    };
    super(config, createMockTransport(config));
  }

  override exec(command: string, options: ExecOptions): Promise<ExecStream> {
    this.commands.push(command);
    if (!command.includes("unpack-objects -r")) {
      const result = spawnSync("sh", ["-c", command], {
        cwd: options.cwd,
        encoding: "utf8",
      });
      return Promise.resolve(
        createExecStream(result.stdout || "", result.stderr || "", result.status ?? 1)
      );
    }

    const chunks: Buffer[] = [];
    let resolveExitCode: (exitCode: number) => void = noop;
    const exitCode = new Promise<number>((resolve) => {
      resolveExitCode = resolve;
    });
    let unpackRan = false;
    const runUnpack = () => {
      if (unpackRan) {
        return;
      }
      unpackRan = true;
      const result = spawnSync("git", ["-C", this.baseRepoPath, "unpack-objects", "-r"], {
        input: Buffer.concat(chunks),
      });
      resolveExitCode(result.status ?? 1);
    };

    return Promise.resolve({
      stdout: createTextStream(""),
      stderr: createTextStream(""),
      stdin: new WritableStream<Uint8Array>({
        write(chunk) {
          chunks.push(Buffer.from(chunk));
          return Promise.resolve();
        },
        close() {
          runUnpack();
          return Promise.resolve();
        },
        abort() {
          resolveExitCode(1);
          return Promise.resolve();
        },
      }),
      exitCode,