// Against a real hub when the binary exists: create a repository, an

// issue and a proposal through the client.

import { test } from "node:test";

import assert from "node:assert/strict";

import { spawn, execFileSync } from "node:child_process";

import { mkdtempSync, writeFileSync, existsSync, mkdirSync } from "node:fs";

import { tmpdir } from "node:os";

import { join } from "node:path";

import { HubClient, HubError } from "../out/hub.mjs";

const HUB = join(import.meta.dirname, "../../oxygenhub/target/release/oxygenhub");

const OXY = join(import.meta.dirname, "../../oxygen/target/release/oxy");

test("hub client end to end", { skip: !existsSync(HUB) || !existsSync(OXY) }, async () => {

  const data = mkdtempSync(join(tmpdir(), "hubvs-"));

  const port = 17300 + Math.floor(Math.random() * 1000);

  const base = `http://127.0.0.1:${port}`;

  writeFileSync(join(data, "hub.toml"), `[server]\nbind = "127.0.0.1:${port}"\nbase_url = "${base}"\n[auth]\npush_tokens = ["site"]\n[registration]\nmode = "open"\n`);

  execFileSync(HUB, ["--data", data, "init"], { stdio: "ignore" });

  execFileSync(HUB, ["--data", data, "admin", "user", "create", "andy", "--admin"], { stdio: "ignore" });

  const proc = spawn(HUB, ["--data", data, "serve"], { stdio: "ignore" });

  try {

    for (let i = 0; i < 50; i++) {

      try {

        await fetch(`${base}/health`);

        break;

      } catch {

        await new Promise((r) => setTimeout(r, 100));

      }

    }

    const client = new HubClient(base, "site");

    // The client has no createRepository method by design; use fetch directly.

    const res = await fetch(`${base}/api/v1/repos`, { method: "POST", headers: { authorization: "Bearer site", "content-type": "application/json" }, body: JSON.stringify({ owner: "andy", name: "demo" }) });

    assert.equal(res.status, 201);

    // Push a bookmark with oxy so a proposal has something to add.

    const work = mkdtempSync(join(tmpdir(), "hubvs-work-"));

    const env = { ...process.env, OXY_HOME: mkdtempSync(join(tmpdir(), "hubvs-home-")) };

    const oxy = (...args) => execFileSync(OXY, ["--plain", ...args], { cwd: work, env, stdio: ["ignore", "pipe", "pipe"] }).toString();

    oxy("init");

    oxy("remote", "add", "origin", `${base}/andy/demo`);

    oxy("config", "remote.origin.token", "site");

    mkdirSync(join(work, "src"), { recursive: true });

    writeFileSync(join(work, "src/a.txt"), "a\n");

    oxy("commit", "-m", "base");

    oxy("push", "origin");

    oxy("bookmark", "create", "feat");

    oxy("bookmark", "switch", "feat");

    writeFileSync(join(work, "src/b.txt"), "b\n");

    oxy("commit", "-m", "feat");

    oxy("push", "origin", "--bookmark", "feat");

    const p = await client.createProposal("andy", "demo", { title: "Feat", target: "main", source: "feat", body: "", draft: false });

    assert.equal(p.number, 1);

    assert.equal(p.changes.length, 1);

    const list = await client.proposals("andy", "demo");

    assert.equal(list[0].title, "Feat");

    const issue = await client.createIssue("andy", "demo", "Bug", "text");

    assert.equal(issue.number, 2);

    await client.commentIssue("andy", "demo", 2, "more");

    const closed = await client.setIssueState("andy", "demo", 2, "closed");

    assert.equal(closed.state, "closed");

    const me = await client.me();

    assert.equal(me.username, "andy");

    await assert.rejects(() => new HubClient(base, "nope").me(), (e) => e instanceof HubError && e.status === 401);

  } finally {

    proc.kill();

  }

});