import { afterAll, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import os from "node:os";
import path from "node:path";

import { PermanentImportError } from "./errors.ts";
import {
  credentialEnv,
  fetchFailure,
  listRefs,
  presentCommits,
} from "./git.ts";

const never = new AbortController().signal;
const dir = await mkdtemp(path.join(os.tmpdir(), "importer-git-test-"));
afterAll(() => rm(dir, { recursive: true, force: true }));

const env = {
  GIT_AUTHOR_NAME: "t",
  GIT_AUTHOR_EMAIL: "t@t",
  GIT_COMMITTER_NAME: "t",
  GIT_COMMITTER_EMAIL: "t@t",
};
function git(...args: string[]) {
  const result = Bun.spawnSync(["git", "-C", dir, ...args], {
    env: { ...process.env, ...env },
  });
  if (result.exitCode !== 0) throw new Error(result.stderr.toString());
  return result.stdout.toString().trim();
}

git("init", "--quiet", "-b", "main");
git("commit", "--allow-empty", "--quiet", "-m", "first");
git("tag", "v1");
const head = git("rev-parse", "HEAD");

test("credentialEnv scopes a basic header to one origin", () => {
  expect(credentialEnv("https://github.com", "x-access-token", "tok")).toEqual({
    GIT_TERMINAL_PROMPT: "0",
    GIT_CONFIG_COUNT: "1",
    GIT_CONFIG_KEY_0: "http.https://github.com/.extraHeader",
    GIT_CONFIG_VALUE_0: `Authorization: Basic ${btoa("x-access-token:tok")}`,
  });
});

test("listRefs lists branches and tags", async () => {
  expect(await listRefs(dir, never)).toEqual(
    new Set(["refs/heads/main", "refs/tags/v1"]),
  );
});

test("presentCommits keeps only commits the history has", async () => {
  expect(await presentCommits(dir, [head, "f".repeat(40)], never)).toEqual(
    new Set([head]),
  );
  expect(await presentCommits(dir, [], never)).toEqual(new Set());
});

test("a failing git command reports its stderr", async () => {
  await expect(listRefs(path.join(dir, "missing"), never)).rejects.toThrow(
    /git -C .* for-each-ref .* exited with/,
  );
});

test("fetchFailure retries only a token that expired after working", () => {
  const auth = new Error(
    "fatal: Authentication failed for 'https://github.com/o/r.git/'",
  );
  expect(fetchFailure(auth, false)).toBeInstanceOf(PermanentImportError);
  const expired = fetchFailure(auth, true);
  expect(expired).not.toBeInstanceOf(PermanentImportError);
  expect(expired.message).toContain("expired");

  const missing = new Error("remote: Repository not found.");
  expect(fetchFailure(missing, true)).toBeInstanceOf(PermanentImportError);
  const network = new Error("fatal: unable to access: Could not resolve host");
  expect(fetchFailure(network, true)).toBe(network);
});