// @effect-diagnostics nodeBuiltinImport:off -- Isolated child-process streams; no desktop session is touched.
import * as NodeEvents from "node:events";
import * as NodeStream from "node:stream";
import { afterEach, beforeEach, expect, it, vi } from "vite-plus/test";

const spawn = vi.hoisted(() => vi.fn());
vi.mock("node:child_process", () => ({ spawn }));
import { startNativeCaptureFeedback } from "./NativeCaptureFeedback.ts";

const options = {
  bounds: { x: -800, y: 0, width: 800, height: 600 },
  pid: 123,
  flash: true,
  animate: true,
};
let child: NodeEvents.EventEmitter & {
  stdin: NodeStream.PassThrough;
  stdout: NodeStream.PassThrough;
  kill: ReturnType<typeof vi.fn>;
};
let commands: string[];
beforeEach(() => {
  vi.useFakeTimers();
  commands = [];
  child = Object.assign(new NodeEvents.EventEmitter(), {
    stdin: new NodeStream.PassThrough(),
    stdout: new NodeStream.PassThrough(),
    kill: vi.fn(),
  });
  child.stdin.on("data", (value: Buffer) => commands.push(value.toString()));
  spawn.mockReturnValue(child);
});
afterEach(() => {
  child.emit("close");
  vi.useRealTimers();
});
function event(value: unknown) {
  child.stdout.write(`${JSON.stringify(value)}\n`);
}

it("waits for compositor readiness and landing, then waits for cleanup on acknowledgement", async () => {
  const starting = startNativeCaptureFeedback("/helper", "/private", options);
  let ready = false;
  void starting.then(() => {
    ready = true;
  });
  await Promise.resolve();
  expect(ready).toBe(false);
  event({ event: "ready", animate: true });
  const feedback = (await starting)!;
  expect(feedback.animationStarted).toBe(true);
  const frame = { x: 0.1, y: 0.7, width: 0.2, height: 0.1 };
  const flight = feedback.animateTo('My "Draft"', frame);
  let completed = false;
  const complete = feedback.complete().then(() => {
    completed = true;
  });
  expect(commands.map((line) => JSON.parse(line))).toEqual([
    { command: "animate", title: 'My "Draft"', frame },
  ]);
  event({ event: "landed" });
  await flight;
  expect(commands.map((line) => JSON.parse(line))).toHaveLength(2);
  expect(completed).toBe(false);
  child.emit("close");
  await complete;
  expect(completed).toBe(true);
  expect(child.kill).not.toHaveBeenCalled();
  expect(vi.getTimerCount()).toBe(0);
});

it("doesn't claim a flight when the compositor disables motion; flash still works", async () => {
  const starting = startNativeCaptureFeedback("/helper", "/private", options);
  event({ event: "ready", animate: false });
  const feedback = (await starting)!;
  expect(feedback.animationStarted).toBe(false);
  await feedback.animateTo("Draft", { x: 0, y: 0, width: 1, height: 1 });
  expect(commands).toEqual([]);
  const complete = feedback.complete();
  child.emit("close");
  await complete;
});

it("falls back on startup failure, malformed replies, and timeout without leaving timers", async () => {
  const starting = startNativeCaptureFeedback("/helper", "/private", options);
  child.stdout.write("not JSON\n");
  expect(commands).toEqual(['{"command":"close"}\n']);
  await vi.advanceTimersByTimeAsync(1000);
  expect(child.kill).toHaveBeenCalledOnce();
  child.emit("close");
  expect(await starting).toBeUndefined();
  expect(vi.getTimerCount()).toBe(0);
});

it("bounds a missing ready receipt and cancels an in-flight animation on compositor failure", async () => {
  const timed = startNativeCaptureFeedback("/helper", "/private", options);
  await vi.advanceTimersByTimeAsync(2000);
  child.emit("close");
  expect(await timed).toBeUndefined();
});

it("releases waiters if the overlay closes during flight", async () => {
  const starting = startNativeCaptureFeedback("/helper", "/private", options);
  event({ event: "ready", animate: true });
  const feedback = (await starting)!;
  const flight = feedback.animateTo("Draft", { x: 0, y: 0, width: 1, height: 1 });
  event({ event: "done" });
  await flight;
  child.emit("close");
  await feedback.complete();
  expect(vi.getTimerCount()).toBe(0);
});