import { mkdtempSync, rmSync } from "node:fs";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { registerEnvConformance } from "@earendil-works/pi-durable/testing";
import { afterAll, describe, expect, it } from "vitest";
import { Connection } from "../src/connection.ts";
import { LocalExecutionEnv } from "../src/list-files.ts";
import { RemoteExecutionEnv } from "../src/remote-env.ts";
import { daemon } from "./daemon.ts";

const connection = new Connection({ command: [daemon] });
afterAll(() => connection.close());

const windows = process.platform === "win32";
const gitBash = join(process.env.ProgramFiles ?? "C:\\Program Files", "Git", "bin", "bash.exe");

registerEnvConformance(
	{ describe, expect, it },
	"RemoteExecutionEnv over a pipe",
	async (use) => {
		const cwd = mkdtempSync(join(tmpdir(), "pi-env-conformance-"));
		try {
			await use(new RemoteExecutionEnv({ connection, id: "pi-env:test", cwd, watch: { pollIntervalMs: 100 } }));
		} finally {
			// On Windows a killed command's processes can hold the directory for a moment.
			rmSync(cwd, { recursive: true, force: true, maxRetries: 50, retryDelay: 100 });
		}
	},
	// Git Bash's `ln -s` copies instead of linking unless native symlinks are enabled.
	windows ? { shell: [gitBash, "-c"], symlinks: false, listFiles: true } : { listFiles: true },
);

registerEnvConformance(
	{ describe, expect, it },
	"LocalExecutionEnv",
	async (use) => {
		const cwd = mkdtempSync(join(tmpdir(), "pi-env-local-conformance-"));
		try {
			await use(new LocalExecutionEnv({ connection, cwd, watch: { pollIntervalMs: 100 } }));
		} finally {
			rmSync(cwd, { recursive: true, force: true, maxRetries: 50, retryDelay: 100 });
		}
	},
	windows ? { shell: [gitBash, "-c"], symlinks: false, listFiles: true } : { listFiles: true },
);