import { Hono } from "hono";
import { logger as honoLogger } from "hono/logger";

import { Logger } from "@crupest/base/log";

import {
  AliasRecipientMailHook,
  FallbackRecipientHook,
  MailDeliverer,
  RecipientFromHeadersHook,
} from "./mail.ts";
import { DovecotMailDeliverer } from "./dovecot.ts";
import { DumbSmtpServer } from "./dumb-smtp-server.ts";

export function createInbound(
  logger: Logger,
  {
    fallback,
    mailDomain,
    aliasFile,
    ldaPath,
  }: {
    fallback: string[];
    mailDomain: string;
    aliasFile: string;
    ldaPath: string;
  },
) {
  const deliverer = new DovecotMailDeliverer(logger, ldaPath);
  deliverer.preHooks.push(
    new RecipientFromHeadersHook(mailDomain),
    new FallbackRecipientHook(new Set(fallback)),
    new AliasRecipientMailHook(aliasFile),
  );
  return deliverer;
}

export function createHono(
  logger: Logger,
  outbound: MailDeliverer,
  inbound: MailDeliverer,
) {
  const hono = new Hono();

  hono.onError((err, c) => {
    logger.error("Hono handler throws an error.", err);
    return c.json({ msg: "Server error, check its log." }, 500);
  });
  hono.use(honoLogger());
  hono.post("/send/raw", async (context) => {
    const body = await context.req.text();
    if (body.trim().length === 0) {
      return context.json({ msg: "Can't send an empty mail." }, 400);
    } else {
      const result = await outbound.deliverRaw(body);
      return context.json({
        awsMessageId: result.awsMessageId,
      });
    }
  });
  hono.post("/receive/raw", async (context) => {
    await inbound.deliverRaw(await context.req.text());
    return context.json({ msg: "Done!" });
  });

  return hono;
}

export function createSmtp(logger: Logger, outbound: MailDeliverer) {
  return new DumbSmtpServer(logger, outbound);
}

export async function sendMail(logger: Logger, port: number) {
  const decoder = new TextDecoder();
  let text = "";
  for await (const chunk of Deno.stdin.readable) {
    text += decoder.decode(chunk);
  }

  const res = await fetch(`http://127.0.0.1:${port}/send/raw`, {
    method: "post",
    body: text,
  });
  logger.write(Deno.inspect(res), { level: res.ok ? "info" : "error" });
  logger.write(Deno.inspect(await res.text()), {
    level: res.ok ? "info" : "error",
  });
  if (!res.ok) Deno.exit(-1);
}