"use server";

import { getCurrentDeploymentDomain } from "src/utils/getCurrentDeploymentDomain";
import { createServerClient } from "@supabase/ssr";
import { and, eq } from "drizzle-orm";
import { drizzle } from "drizzle-orm/node-postgres";
import { email_subscriptions_to_entity, entities } from "drizzle/schema";
import postgres from "postgres";
import type { PermissionToken } from "src/replicache";
import { Database } from "supabase/database.types";
import { pool } from "supabase/pool";

let supabase = createServerClient<Database>(
  process.env.NEXT_PUBLIC_SUPABASE_API_URL as string,
  process.env.SUPABASE_SERVICE_ROLE_KEY as string,
  { cookies: {} },
);
export async function sendPostToSubscribers({
  title,
  permission_token,
  mailboxEntity,
  messageEntity,
  contents,
}: {
  title: string;
  permission_token: PermissionToken;
  mailboxEntity: string;
  messageEntity: string;
  contents: {
    html: string;
    markdown: string;
  };
}) {
  let token_rights = await supabase
    .from("permission_tokens")
    .select("*, permission_token_rights(*)")
    .eq("id", permission_token.id)
    .single();
  let rootEntity = token_rights.data?.root_entity;
  if (!rootEntity || !token_rights.data) return { title: "Leaflet not found" };
  let { data } = await supabase.rpc("get_facts", {
    root: rootEntity,
  });

  const client = await pool.connect();
  const db = drizzle(client);
  let subscribers = await db
    .select()
    .from(email_subscriptions_to_entity)
    .innerJoin(entities, eq(email_subscriptions_to_entity.entity, entities.id))
    .where(eq(email_subscriptions_to_entity.entity, mailboxEntity));
  let entity_set = subscribers[0]?.entities.set;
  if (
    !token_rights.data.permission_token_rights.find(
      (r) => r.entity_set === entity_set,
    )
  ) {
    return;
  }
  let domain = await getCurrentDeploymentDomain();
  let res = await fetch("https://api.postmarkapp.com/email/batch", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      "X-Postmark-Server-Token": process.env.POSTMARK_API_KEY!,
    },
    body: JSON.stringify(
      subscribers.map((sub) => ({
        Headers: [
          {
            Name: "List-Unsubscribe-Post",
            Value: "List-Unsubscribe=One-Click",
          },
          {
            Name: "List-Unsubscribe",
            Value: `<${domain}/mail/unsubscribe?sub_id=${sub.email_subscriptions_to_entity.id}>`,
          },
        ],
        MessageStream: "broadcast",
        From: "Leaflet Mailbox <mailbox@leaflet.pub>",
        Subject: `New Mail in: ${title}`,
        To: sub.email_subscriptions_to_entity.email,
        HtmlBody: `
        You've got new mail from <a href="${domain}/${sub.email_subscriptions_to_entity.token}?sub_id=${sub.email_subscriptions_to_entity.id}&email=${sub.email_subscriptions_to_entity.email}&entity=${sub.email_subscriptions_to_entity.entity}&openPage=${messageEntity}">
        ${title}!
        </a>
        <hr style="margin-top: 1em; margin-bottom: 1em;">
        ${contents.html}
        <hr style="margin-top: 1em; margin-bottom: 1em;">
        <em>Manage your subscription at
        <a href="${domain}/${sub.email_subscriptions_to_entity.token}?sub_id=${sub.email_subscriptions_to_entity.id}&email=${sub.email_subscriptions_to_entity.email}&entity=${sub.email_subscriptions_to_entity.entity}&openPage=${messageEntity}">
        ${title}
        </a></em>
        `,
        TextBody: contents.markdown,
      })),
    ),
  });
  client.release();
  return;
}