import * as vars from "jsr:@denops/std@~7.6.0/variable";
import * as fn from "jsr:@denops/std@~7.6.0/function";
import type { Denops } from "jsr:@denops/std@~7.6.0";

const PRECOMMIT_ADDRESS = "PRECOMMIT_ADDRESS";

export async function main(denops: Denops): Promise<void> {
  const { finished } = Deno.serve({
    hostname: "127.0.0.1",
    port: 0, // Automatically select free port
    handler: async (req, _info) => {
      if (req.body === null) {
        return new Response("No body", { status: 400 });
      }
      const lines = [];
      for await (
        const line of req.body.pipeThrough(new TextDecoderStream()).values()
      ) {
        lines.push(line);
      }
      const params = JSON.parse(lines.join("\n"));
      const bufinfos = await fn.getbufinfo(denops, { bufmodified: true });
      const bufs = (await Promise.all(bufinfos.map(async (bufinfo) => {
        const buftype = await fn.getbufvar(denops, bufinfo.bufnr, "&buftype");
        return {
          name: bufinfo.name,
          bufnr: bufinfo.bufnr,
          buftype,
        };
      })))
        .filter((buf) =>
          buf.buftype === "" && buf.name !== "" &&
          buf.name.startsWith(params.dir)
        );
      if (bufs.length === 0) {
        return new Response("ok");
      }
      const files = bufs
        .map((buf) => buf.name + "\n")
        .join();
      const msg = [
        bufs.length > 1 ? "There're dirty buffers." : "There's a dirty buffer.",
        "If you needs, you should save them before commit:\n",
        files,
        "Ignore them and continue?",
      ].join("\n");
      switch (
        await fn.confirm(denops, msg, "&Yes\n&No")
      ) {
        case 1: // Yes (Ignore them)
          return new Response("ok");
        case 2: // No (Suspend)
          return new Response("skip");
      }
      return new Response("unsupported status", { status: 500 });
    },
    onListen: async ({ hostname, port }) => {
      await vars.e.set(
        denops,
        PRECOMMIT_ADDRESS,
        `${hostname}:${port}`,
      );
    },
  });
  await finished;
}