Something went wrong. Try again.
leaflet fork for copy edit / bug fixes forked from leaflet.pub/leaflet
Something went wrong. Try again.
3.5 kB · 101 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102"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;}