import "server-only"; import { db } from "./db"; import { getSettings } from "./settings"; import { formatMoney, fmtDate, dateRange } from "./utils"; /** * AWS SES email layer. * Config precedence: admin System settings (ses.*) → environment variables → * disabled (every send is logged as SKIPPED so flows never break). */ export type SesConfig = { region: string; fromEmail: string; fromName: string; accessKeyId?: string; secretAccessKey?: string; source: "settings" | "env"; }; export async function getSesConfig(): Promise { const s = await getSettings(["ses.region", "ses.fromEmail", "ses.fromName", "ses.accessKeyId", "ses.secretAccessKey"]); if (s["ses.fromEmail"]) { return { region: s["ses.region"] || "ap-south-1", fromEmail: s["ses.fromEmail"], fromName: s["ses.fromName"] || "Confexe", accessKeyId: s["ses.accessKeyId"] || undefined, secretAccessKey: s["ses.secretAccessKey"] || undefined, source: "settings", }; } if (process.env.SES_FROM_EMAIL) { return { region: process.env.SES_REGION || "ap-south-1", fromEmail: process.env.SES_FROM_EMAIL, fromName: process.env.SES_FROM_NAME || "Confexe", source: "env", // credentials via SDK default chain (env / EC2 instance role) }; } return null; } export async function getBaseUrl(): Promise { const s = await getSettings(["platform.baseUrl"]); return (s["platform.baseUrl"] || process.env.BASE_URL || "http://localhost:3300").replace(/\/$/, ""); } /** Branded HTML shell shared by every trigger. */ function layout(opts: { title: string; bodyHtml: string; accent?: string; footer?: string }): string { const accent = opts.accent ?? "#6366f1"; return `

${opts.title}

${opts.bodyHtml}

${opts.footer ?? "Sent by Confexe — the conference operating system."}

`; } const btnHtml = (href: string, label: string, accent = "#6366f1") => `${label}`; /** Core send. Never throws — logs SENT / FAILED / SKIPPED to EmailLog. */ export async function sendEmail(opts: { to: string; subject: string; html: string; template: string; conferenceId?: string; }): Promise<"SENT" | "FAILED" | "SKIPPED"> { const log = async (status: string, error?: string) => { try { await db.emailLog.create({ data: { to: opts.to, subject: opts.subject, template: opts.template, status, error: error?.slice(0, 300), conferenceId: opts.conferenceId }, }); } catch { /* logging must never break the flow */ } }; try { const config = await getSesConfig(); if (!config) { await log("SKIPPED", "SES not configured (admin → System settings)"); return "SKIPPED"; } const { SESv2Client, SendEmailCommand } = await import("@aws-sdk/client-sesv2"); const client = new SESv2Client({ region: config.region, ...(config.accessKeyId && config.secretAccessKey ? { credentials: { accessKeyId: config.accessKeyId, secretAccessKey: config.secretAccessKey } } : {}), }); await client.send( new SendEmailCommand({ FromEmailAddress: `${config.fromName} <${config.fromEmail}>`, Destination: { ToAddresses: [opts.to] }, Content: { Simple: { Subject: { Data: opts.subject, Charset: "UTF-8" }, Body: { Html: { Data: opts.html, Charset: "UTF-8" } }, }, }, }) ); await log("SENT"); return "SENT"; } catch (e) { await log("FAILED", (e as Error).message); return "FAILED"; } } // ── Triggers ────────────────────────────────────────────── export async function sendRegistrationConfirmedEmail(registrationId: string) { const reg = await db.registration.findUnique({ where: { id: registrationId }, include: { conference: true, ticketType: true }, }); if (!reg) return; const base = await getBaseUrl(); const c = reg.conference; const ticketUrl = `${base}/c/${c.slug}/ticket/${reg.regCode}`; await sendEmail({ to: reg.email, subject: `🎟️ You're in! Ticket for ${c.name}`, template: "registration_confirmed", conferenceId: c.id, html: layout({ title: c.name, accent: c.primaryColor, bodyHtml: `

Hi ${reg.name},

Your registration is confirmed. Here are your details:

Registration ID	${reg.regCode}
Pass	${reg.ticketType.name} · ${formatMoney(reg.amount)}
Dates	${dateRange(c.startAt, c.endAt)}
Venue	${c.type === "VIRTUAL" ? "Online" : `${c.venueName ?? ""}${c.city ? ", " + c.city : ""}`}

${btnHtml(ticketUrl, "View my QR ticket", c.primaryColor)}

Show the QR code at the check-in desk. See the full schedule at ${base.replace(/^https?:\/\//, "")}/c/${c.slug}/schedule.

`, }), }); } export async function sendVolunteerWelcomeEmail(opts: { email: string; name: string; conferenceId: string; tempPassword: string | null; areas: string[] }) { const conf = await db.conference.findUnique({ where: { id: opts.conferenceId }, select: { name: true, primaryColor: true } }); if (!conf) return; const base = await getBaseUrl(); await sendEmail({ to: opts.email, subject: `🙋 You're a volunteer at ${conf.name}`, template: "volunteer_welcome", conferenceId: opts.conferenceId, html: layout({ title: conf.name, accent: conf.primaryColor, bodyHtml: `

Hi ${opts.name},

You've been added to the volunteer team for ${conf.name}.

Your duties: ${opts.areas.length ? opts.areas.join(", ") : "to be assigned"}

${opts.tempPassword ? `

A login was created for you:
Email: ${opts.email}
Temporary password: ${opts.tempPassword}

Please sign in and keep your password safe.

` : `

${btnHtml(`${base}/login`, "Open my volunteer dashboard", conf.primaryColor)}

`, }), }); } export async function sendSubmissionDecisionEmail(submissionId: string) { const sub = await db.submission.findUnique({ where: { id: submissionId }, include: { conference: true, user: true }, }); if (!sub) return; const base = await getBaseUrl(); const verdict = sub.status === "ACCEPTED" ? { subj: "🎉 Accepted", line: "Congratulations — your submission has been accepted!" } : sub.status === "REJECTED" ? { subj: "Submission decision", line: "We're sorry — your submission was not accepted this time." } : { subj: "Revision requested", line: "The committee has requested a revision of your submission." }; await sendEmail({ to: sub.user.email, subject: `${verdict.subj}: ${sub.title}`, template: "submission_decision", conferenceId: sub.conferenceId, html: layout({ title: sub.conference.name, accent: sub.conference.primaryColor, bodyHtml: `

Hi ${sub.user.name},

${verdict.line}

${sub.title}
${sub.category}

${btnHtml(`${base}/me/submissions`, "View my submissions", sub.conference.primaryColor)}

`, }), }); } export async function sendCertificateEmail(certId: string) { const cert = await db.certificate.findUnique({ where: { certId }, include: { conference: true } }); if (!cert) return; const base = await getBaseUrl(); const url = `${base}/verify/${cert.certId}`; await sendEmail({ to: cert.recipientEmail, subject: `🏅 Your certificate from ${cert.conference.name}`, template: "certificate_issued", conferenceId: cert.conferenceId, html: layout({ title: cert.conference.name, accent: cert.conference.primaryColor, bodyHtml: `

Hi ${cert.recipientName},

Your ${cert.type.toLowerCase()} certificate is ready. It carries a unique ID (${cert.certId}) and can be verified by anyone at the link below.

${btnHtml(url, "View & download certificate", cert.conference.primaryColor)}

Issued ${fmtDate(cert.issuedAt)} · printable A4 with QR verification.

`, }), }); } export async function sendReviewerAssignedEmail(reviewerEmail: string, conferenceId: string) { const conf = await db.conference.findUnique({ where: { id: conferenceId }, select: { name: true, primaryColor: true } }); if (!conf) return; const base = await getBaseUrl(); await sendEmail({ to: reviewerEmail, subject: `📄 New review assignment — ${conf.name}`, template: "reviewer_assigned", conferenceId, html: layout({ title: conf.name, accent: conf.primaryColor, bodyHtml: `

A paper has been assigned to you for review.

${btnHtml(`${base}/me/reviews`, "Open my review inbox", conf.primaryColor)}

Reviews are single-blind — authors will not see your name.

`, }), }); } /** Announcement blast to confirmed registrants (capped, best-effort). */ export async function sendAnnouncementBlast(conferenceId: string, title: string, body: string) { const conf = await db.conference.findUnique({ where: { id: conferenceId }, select: { name: true, slug: true, primaryColor: true } }); if (!conf) return; const regs = await db.registration.findMany({ where: { conferenceId, status: "CONFIRMED" }, select: { email: true, name: true }, distinct: ["email"], take: 200, // safety cap for the demo-scale blast }); const base = await getBaseUrl(); await Promise.allSettled( regs.map((r) => sendEmail({ to: r.email, subject: `📢 ${conf.name}: ${title}`, template: "announcement", conferenceId, html: layout({ title: conf.name, accent: conf.primaryColor, bodyHtml: `

Hi ${r.name},

${title}

${body || ""}

${btnHtml(`${base}/c/${conf.slug}`, "Open conference site", conf.primaryColor)}

`, }), }) ) ); } export async function sendWelcomeEmail(email: string, name: string, organizer: boolean) { const base = await getBaseUrl(); await sendEmail({ to: email, subject: "Welcome to Confexe 👋", template: "welcome", html: layout({ title: "Welcome to Confexe", bodyHtml: `

Hi ${name},

Your account is ready. ${organizer ? "Create your first conference and get a public website, registration engine, agenda builder and check-in tools out of the box." : "Browse conferences, register in a couple of clicks, and keep your tickets and certificates in one place."}

${btnHtml(base + (organizer ? "/dashboard" : "/me"), organizer ? "Open my dashboard" : "Open my conferences")}

`, }), }); }