email reminders

scripts/book-on-behalf.ts

@@ -18,6 +18,8 @@ import { findSlots } from "../src/lib/availability";
 import { loadAvailabilityState } from "../src/lib/availability-loader";
 import { confirmHold, createHold } from "../src/lib/booking";
 import { sendBookingConfirmation } from "../src/lib/email";
+import { scheduleReminderForBooking } from "../src/lib/reminders";
+import { stopJobs } from "../src/lib/jobs";
 
 async function main() {
   const [customerEmail, serviceName, localIso] = process.argv.slice(2);
@@ -92,10 +94,13 @@ async function main() {
     await confirmHold(db, hold.id);
 
     const result = await sendBookingConfirmation({ db, bookingId: hold.id });
+    await scheduleReminderForBooking(hold.id, startsAt);
     console.log(`  Booking:   ${hold.id} (CONFIRMED)`);
     console.log(`  Email:     ${result.status} (notification ${result.notificationId})`);
+    console.log(`  Reminder:  scheduled for 24h before`);
     console.log(`  View:      http://localhost:8025`);
   } finally {
+    await stopJobs();
     await db.$disconnect();
   }
 }

scripts/worker.ts

@@ -0,0 +1,78 @@
+// Long-lived worker process. Runs alongside Next.js (separate container in prod).
+// Handles:
+//   - booking-reminder    fired 24h before each CONFIRMED booking
+//   - expire-stale-holds  recurring every minute; cancels timed-out HOLD bookings
+
+import "dotenv/config";
+import { PrismaPg } from "@prisma/adapter-pg";
+import { PrismaClient } from "../src/generated/prisma/client";
+import { jobs, QUEUES, type BookingReminderPayload, stopJobs } from "../src/lib/jobs";
+import { handleReminderJob } from "../src/lib/reminders";
+import { expireStaleHolds } from "../src/lib/booking";
+
+const adapter = new PrismaPg({ connectionString: process.env.DATABASE_URL });
+const db = new PrismaClient({ adapter });
+
+async function main() {
+  const boss = jobs();
+  await boss.start();
+  console.log("[worker] pg-boss started");
+
+  // pg-boss 12+ requires queues to be created before send/schedule/work.
+  // createQueue is idempotent — safe to call on every boot.
+  await boss.createQueue(QUEUES.BOOKING_REMINDER);
+  await boss.createQueue(QUEUES.EXPIRE_STALE_HOLDS);
+
+  // Booking reminders.
+  await boss.work(
+    QUEUES.BOOKING_REMINDER,
+    async (incoming) => {
+      const items = Array.isArray(incoming) ? incoming : [incoming];
+      for (const job of items) {
+        const data = job.data as BookingReminderPayload;
+        try {
+          const result = await handleReminderJob(db, data);
+          console.log(
+            `[worker] booking-reminder bookingId=${data.bookingId} ${
+              result.sent ? "SENT" : `SKIP(${result.reason})`
+            }`,
+          );
+        } catch (err) {
+          console.error(
+            `[worker] booking-reminder bookingId=${data.bookingId} FAILED:`,
+            err,
+          );
+          throw err; // pg-boss will retry per the job's retryLimit
+        }
+      }
+    },
+  );
+
+  // Hold expiry — recurring every minute.
+  await boss.schedule(QUEUES.EXPIRE_STALE_HOLDS, "* * * * *");
+  await boss.work(QUEUES.EXPIRE_STALE_HOLDS, async () => {
+    const count = await expireStaleHolds(db);
+    if (count > 0) {
+      console.log(`[worker] expire-stale-holds expired ${count}`);
+    }
+  });
+
+  console.log("[worker] handlers registered, idling");
+
+  // Graceful shutdown.
+  const shutdown = async (signal: string) => {
+    console.log(`[worker] ${signal} received, shutting down`);
+    await stopJobs();
+    await db.$disconnect();
+    process.exit(0);
+  };
+  process.on("SIGTERM", () => shutdown("SIGTERM"));
+  process.on("SIGINT", () => shutdown("SIGINT"));
+}
+
+main().catch(async (err) => {
+  console.error("[worker] fatal:", err);
+  await stopJobs();
+  await db.$disconnect();
+  process.exit(1);
+});