import { assert, describe, expect, it } from "@effect/vitest";
import * as DateTime from "effect/DateTime";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as Option from "effect/Option";
import * as Sink from "effect/Sink";
import * as Stream from "effect/Stream";
import { ChildProcessSpawner } from "effect/unstable/process";
import { HostProcessPlatform } from "@t3tools/shared/hostProcess";

import * as ProcessDiagnostics from "./ProcessDiagnostics.ts";

const encoder = new TextEncoder();

function mockHandle(result: {
  readonly stdout?: string;
  readonly stderr?: string;
  readonly code?: number;
}) {
  return ChildProcessSpawner.makeHandle({
    pid: ChildProcessSpawner.ProcessId(1),
    exitCode: Effect.succeed(ChildProcessSpawner.ExitCode(result.code ?? 0)),
    isRunning: Effect.succeed(false),
    kill: () => Effect.void,
    unref: Effect.succeed(Effect.void),
    stdin: Sink.drain,
    stdout: Stream.make(encoder.encode(result.stdout ?? "")),
    stderr: Stream.make(encoder.encode(result.stderr ?? "")),
    all: Stream.empty,
    getInputFd: () => Sink.drain,
    getOutputFd: () => Stream.empty,
  });
}

function readWindowsRows(stdout: string) {
  const commands: Array<{ readonly command: string; readonly args: ReadonlyArray<string> }> = [];
  const spawnerLayer = Layer.mock(ChildProcessSpawner.ChildProcessSpawner)({
    spawn: (command) => {
      const childProcess = command as unknown as {
        readonly command: string;
        readonly args: ReadonlyArray<string>;
      };
      commands.push({ command: childProcess.command, args: childProcess.args });
      return Effect.succeed(mockHandle({ stdout }));
    },
  });

  return ProcessDiagnostics.readProcessRows.pipe(
    Effect.map((rows) => ({ rows, commands })),
    Effect.provide(spawnerLayer),
    Effect.provideService(HostProcessPlatform, "win32"),
  );
}

describe("ProcessDiagnostics", () => {
  it.effect("parses POSIX ps rows with full commands", () =>
    Effect.sync(() => {
      const rows = ProcessDiagnostics.parsePosixProcessRows(
        [
          "  10     1    10 Ss      0.0   1024   01:02.03 /usr/bin/node server.js",
          "  11    10    10 S+     12.5  20480      00:04 codex app-server --config /tmp/one two",
        ].join("\n"),
      );

      expect(rows).toEqual([
        {
          pid: 10,
          ppid: 1,
          pgid: 10,
          status: "Ss",
          cpuPercent: 0,
          rssBytes: 1024 * 1024,
          elapsed: "01:02.03",
          command: "/usr/bin/node server.js",
        },
        {
          pid: 11,
          ppid: 10,
          pgid: 10,
          status: "S+",
          cpuPercent: 12.5,
          rssBytes: 20480 * 1024,
          elapsed: "00:04",
          command: "codex app-server --config /tmp/one two",
        },
      ]);
    }),
  );

  it.effect("parses Windows PowerShell JSON rows through the child process layer", () =>
    Effect.gen(function* () {
      const { rows, commands } = yield* readWindowsRows(`[
        {
          "ProcessId": 100,
          "ParentProcessId": 1,
          "Name": "node.exe",
          "CommandLine": "node server.js",
          "Status": "Running",
          "WorkingSetSize": 4096.4,
          "PercentProcessorTime": 1.5
        },
        {
          "ProcessId": 101,
          "ParentProcessId": 100,
          "Name": "agent.exe",
          "CommandLine": null,
          "Status": null,
          "WorkingSetSize": -128,
          "PercentProcessorTime": -2
        },
        {
          "ProcessId": 0,
          "ParentProcessId": 100,
          "Name": "skip-zero-pid.exe"
        },
        {
          "ProcessId": 102,
          "Name": "skip-missing-parent.exe"
        },
        {
          "ProcessId": "bad",
          "ParentProcessId": 100,
          "Name": "skip-schema-invalid.exe"
        }
      ]`);

      assert.deepStrictEqual(rows, [
        {
          pid: 100,
          ppid: 1,
          pgid: null,
          status: "Running",
          cpuPercent: 1.5,
          rssBytes: 4096,
          elapsed: "",
          command: "node server.js",
        },
        {
          pid: 101,
          ppid: 100,
          pgid: null,
          status: "Live",
          cpuPercent: 0,
          rssBytes: 0,
          elapsed: "",
          command: "agent.exe",
        },
      ]);
      assert.strictEqual(commands[0]?.command, "powershell.exe");
      assert.deepStrictEqual(commands[0]?.args.slice(0, 3), [
        "-NoProfile",
        "-NonInteractive",
        "-Command",
      ]);
      assert.isTrue(commands[0]?.args[3]?.includes("Get-CimInstance Win32_Process") === true);
    }),
  );

  it.effect("parses a single Windows PowerShell JSON object", () =>
    Effect.gen(function* () {
      const { rows } = yield* readWindowsRows(`{
        "ProcessId": 200,
        "ParentProcessId": 100,
        "Name": "single.exe",
        "CommandLine": null,
        "Status": "",
        "WorkingSetSize": 2048,
        "PercentProcessorTime": 3
      }`);

      assert.deepStrictEqual(rows, [
        {
          pid: 200,
          ppid: 100,
          pgid: null,
          status: "Live",
          cpuPercent: 3,
          rssBytes: 2048,
          elapsed: "",
          command: "single.exe",
        },
      ]);
    }),
  );

  it.effect("returns no Windows rows for invalid JSON", () =>
    Effect.gen(function* () {
      const { rows } = yield* readWindowsRows("not-json");

      assert.deepStrictEqual(rows, []);
    }),
  );

  it.effect("aggregates only descendants of the server process", () =>
    Effect.sync(() => {
      const diagnostics = ProcessDiagnostics.aggregateProcessDiagnostics({
        serverPid: 100,
        readAt: DateTime.makeUnsafe("2026-05-05T10:00:00.000Z"),
        rows: [
          {
            pid: 100,
            ppid: 1,
            pgid: 100,
            status: "S",
            cpuPercent: 0,
            rssBytes: 1_000,
            elapsed: "01:00",
            command: "t3 server",
          },
          {
            pid: 101,
            ppid: 100,
            pgid: 100,
            status: "S",
            cpuPercent: 1.5,
            rssBytes: 2_000,
            elapsed: "00:20",
            command: "codex app-server",
          },
          {
            pid: 102,
            ppid: 101,
            pgid: 100,
            status: "R",
            cpuPercent: 3.25,
            rssBytes: 4_000,
            elapsed: "00:05",
            command: "git status",
          },
          {
            pid: 200,
            ppid: 1,
            pgid: 200,
            status: "S",
            cpuPercent: 99,
            rssBytes: 8_000,
            elapsed: "00:01",
            command: "unrelated",
          },
          {
            pid: 201,
            ppid: 100,
            pgid: 100,
            status: "R",
            cpuPercent: 9,
            rssBytes: 9_000,
            elapsed: "00:00",
            command: "ps -axo pid=,ppid=,pgid=,stat=,pcpu=,rss=,etime=,command=",
          },
        ],
      });

      expect(diagnostics.serverPid).toBe(100);
      expect(DateTime.formatIso(diagnostics.readAt)).toBe("2026-05-05T10:00:00.000Z");
      expect(diagnostics.processCount).toBe(2);
      expect(diagnostics.totalRssBytes).toBe(6_000);
      expect(diagnostics.totalCpuPercent).toBe(4.75);
      expect(diagnostics.processes.map((process) => process.pid)).toEqual([101, 102]);
      expect(diagnostics.processes.map((process) => process.depth)).toEqual([0, 1]);
      expect(Option.getOrNull(diagnostics.processes[0]!.pgid)).toBe(100);
      expect(diagnostics.processes[0]?.childPids).toEqual([102]);
    }),
  );

  it.effect("preserves ascending sibling order for nested descendants", () =>
    Effect.sync(() => {
      const diagnostics = ProcessDiagnostics.aggregateProcessDiagnostics({
        serverPid: 100,
        readAt: DateTime.makeUnsafe("2026-05-05T10:00:00.000Z"),
        rows: [
          {
            pid: 101,
            ppid: 100,
            pgid: 100,
            status: "S",
            cpuPercent: 0,
            rssBytes: 100,
            elapsed: "00:10",
            command: "agent",
          },
          {
            pid: 103,
            ppid: 101,
            pgid: 100,
            status: "S",
            cpuPercent: 0,
            rssBytes: 100,
            elapsed: "00:10",
            command: "child-b",
          },
          {
            pid: 102,
            ppid: 101,
            pgid: 100,
            status: "S",
            cpuPercent: 0,
            rssBytes: 100,
            elapsed: "00:10",
            command: "child-a",
          },
        ],
      });

      expect(diagnostics.processes.map((process) => process.pid)).toEqual([101, 102, 103]);
    }),
  );

  it.effect("queries processes through the ChildProcessSpawner service", () =>
    Effect.gen(function* () {
      const commands: Array<{ readonly command: string; readonly args: ReadonlyArray<string> }> =
        [];
      const spawnerLayer = Layer.succeed(
        ChildProcessSpawner.ChildProcessSpawner,
        ChildProcessSpawner.make((command) => {
          const childProcess = command as unknown as {
            readonly command: string;
            readonly args: ReadonlyArray<string>;
          };
          commands.push({ command: childProcess.command, args: childProcess.args });
          return Effect.succeed(
            mockHandle({
              stdout: [
                ` ${process.pid}     1 ${process.pid} Ss 0.0 1024 01:02.03 t3 server`,
                ` 4242 ${process.pid} ${process.pid} S  1.5 2048 00:04 agent`,
              ].join("\n"),
            }),
          );
        }),
      );
      const layer = ProcessDiagnostics.layer.pipe(Layer.provide(spawnerLayer));

      const diagnostics = yield* Effect.service(ProcessDiagnostics.ProcessDiagnostics).pipe(
        Effect.flatMap((pd) => pd.read),
        Effect.provide(layer),
      );

      expect(diagnostics.processes.map((process) => process.pid)).toEqual([4242]);
      expect(commands).toEqual([
        {
          command: "ps",
          args: ["-axo", "pid=,ppid=,pgid=,stat=,pcpu=,rss=,etime=,command="],
        },
      ]);
    }),
  );

  it.effect("keeps bounded command diagnostics when the process query exits unsuccessfully", () =>
    Effect.gen(function* () {
      const spawnerLayer = Layer.succeed(
        ChildProcessSpawner.ChildProcessSpawner,
        ChildProcessSpawner.make(() =>
          Effect.succeed(
            mockHandle({
              code: 17,
              stdout: "partial process output",
              stderr: "process access denied",
            }),
          ),
        ),
      );

      const error = yield* ProcessDiagnostics.readProcessRows.pipe(
        Effect.provide(spawnerLayer),
        Effect.provideService(HostProcessPlatform, "linux"),
        Effect.flip,
      );

      expect(error).toMatchObject({
        _tag: "ProcessDiagnosticsQueryFailedError",
        command: "ps",
        argCount: 2,
        cwd: process.cwd(),
        exitCode: 17,
        stdoutBytes: 22,
        stderrBytes: 21,
        stdoutTruncated: false,
        stderrTruncated: false,
      });
      expect(error.message).toBe(
        `Process diagnostics query 'ps' failed with exit code 17 in '${process.cwd()}'.`,
      );
    }),
  );

  it.effect("does not allow signaling the diagnostics query process", () =>
    Effect.gen(function* () {
      const spawnerLayer = Layer.succeed(
        ChildProcessSpawner.ChildProcessSpawner,
        ChildProcessSpawner.make(() =>
          Effect.succeed(
            mockHandle({
              stdout: [
                ` ${process.pid}     1 ${process.pid} Ss 0.0 1024 01:02.03 t3 server`,
                ` 4242 ${process.pid} ${process.pid} R  1.5 2048 00:00 ps -axo pid=,ppid=,pgid=,stat=,pcpu=,rss=,etime=,command=`,
              ].join("\n"),
            }),
          ),
        ),
      );
      const layer = ProcessDiagnostics.layer.pipe(Layer.provide(spawnerLayer));

      const result = yield* Effect.service(ProcessDiagnostics.ProcessDiagnostics).pipe(
        Effect.flatMap((pd) => pd.signal({ pid: 4242, signal: "SIGINT" })),
        Effect.provide(layer),
      );

      expect(result).toEqual({
        pid: 4242,
        signal: "SIGINT",
        signaled: false,
        message: Option.some("Process 4242 is not a live descendant of the T3 server."),
      });
    }),
  );
});