shad0w/pelagia-portal
1
0
Fork 0
Code Issues 8 Pull requests Projects Releases 2 Packages Wiki Activity Actions

feat(crewing): land full Crewing module on master (Phases 1–5 + hardening) #93

Merged
shad0w merged 23 commits from feat/crewing-review-hardening into master 2026-06-23 08:44:55 +00:00
Conversation 0 Commits 23 Files changed 98 +8 -5
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 712e040fc2 - Show all commits

13
App/lib/notifier.ts
View file

@ -3,7 +3,10 @@ import { db } from "@/lib/db";
import type { PurchaseOrder, User } from "@prisma/client"; import type { PurchaseOrder, User } from "@prisma/client";
const isDev = process.env.NODE_ENV === "development"; const isDev = process.env.NODE_ENV === "development";
const resend = isDev ? null : new Resend(process.env.RESEND_API_KEY); // Construct the Resend client only when a key is actually present — in dev, CI,
// or any env without RESEND_API_KEY we fall back to console logging (the Resend
// v4 constructor throws on a missing key). `canSend` gates the real send path.
const resend = !isDev && process.env.RESEND_API_KEY ? new Resend(process.env.RESEND_API_KEY) : null;
const FROM = `${process.env.EMAIL_FROM_NAME ?? "PPMS"} <${process.env.EMAIL_FROM ?? "noreply@ppms.pelagiamarine.com"}>`; const FROM = `${process.env.EMAIL_FROM_NAME ?? "PPMS"} <${process.env.EMAIL_FROM ?? "noreply@ppms.pelagiamarine.com"}>`;
const APP_URL = (process.env.NEXTAUTH_URL ?? "https://portal.pelagiamarine.com").replace(/\/$/, ""); const APP_URL = (process.env.NEXTAUTH_URL ?? "https://portal.pelagiamarine.com").replace(/\/$/, "");
@ -84,13 +87,13 @@ export async function notify({ event, po, recipients, note }: NotifyParams) {
const link = buildInAppLink(event, po, recipient); const link = buildInAppLink(event, po, recipient);
let status = "sent"; let status = "sent";
if (isDev) { if (!resend) {
console.log( console.log(
`\n📧 [DEV EMAIL] To: ${recipient.email}\n Subject: ${subject}\n Body: ${buildEmailBody(event, po, note)}\n Link: ${APP_URL}${link}\n` `\n📧 [DEV EMAIL] To: ${recipient.email}\n Subject: ${subject}\n Body: ${buildEmailBody(event, po, note)}\n Link: ${APP_URL}${link}\n`
); );
} else { } else {
try { try {
const { error } = await resend!.emails.send({ const { error } = await resend.emails.send({
from: FROM, from: FROM,
to: recipient.email, to: recipient.email,
subject, subject,
@ -441,13 +444,13 @@ export async function notifyCrew({ event, recipients, subject, body, link }: Cre
await Promise.allSettled( await Promise.allSettled(
recipients.map(async (recipient) => { recipients.map(async (recipient) => {
let status = "sent"; let status = "sent";
if (isDev) { if (!resend) {
console.log( console.log(
`\n📧 [DEV EMAIL] To: ${recipient.email}\n Subject: ${subject}\n Body: ${body}\n Link: ${APP_URL}${link ?? ""}\n` `\n📧 [DEV EMAIL] To: ${recipient.email}\n Subject: ${subject}\n Body: ${body}\n Link: ${APP_URL}${link ?? ""}\n`
); );
} else { } else {
try { try {
const { error } = await resend!.emails.send({ const { error } = await resend.emails.send({
from: FROM, from: FROM,
to: recipient.email, to: recipient.email,
subject, subject,