import * as path from "path";
import * as stream from "stream";

import test from "ava";

import { getRunnerLogger } from "./logging";
import { extractTarZst } from "./tar";
import { setupTests } from "./testing-utils";
import { withTmpDir } from "./util";

setupTests(test);

test("extractTarZst rejects if the input stream errors", async (t) => {
  await withTmpDir(async (tmpDir) => {
    const archive = new stream.PassThrough();
    const promise = extractTarZst(
      archive,
      path.join(tmpDir, "dest"),
      { type: "gnu", version: "1.34" },
      getRunnerLogger(true),
    );

    archive.destroy(
      Object.assign(new Error("socket hang up"), {
        code: "ECONNRESET",
      }),
    );

    await t.throwsAsync(promise, {
      message: /Error while downloading and extracting tar/,
    });
  });
});