fix: dashboard subscribers notification runtime (#2316)

* fix: runtime

* fix: nullish

Author: mxkaske

apps/dashboard/src/app/(dashboard)/status-pages/[id]/maintenances/page.tsx

@@ -32,7 +32,7 @@ export default function Page() {
     }),
   );
   const sendMaintenanceUpdateMutation = useMutation(
-    trpc.maintenance.notify.mutationOptions(),
+    trpc.subscriberNotification.maintenance.mutationOptions(),
   );
   const createMaintenanceMutation = useMutation(
     trpc.maintenance.new.mutationOptions({

apps/dashboard/src/app/(dashboard)/status-pages/[id]/status-reports/[reportId]/page.tsx

@@ -42,7 +42,7 @@ export default function Page() {
   );
 
   const sendStatusReportUpdateMutation = useMutation(
-    trpc.statusReport.notify.mutationOptions(),
+    trpc.subscriberNotification.statusReport.mutationOptions(),
   );
 
   const createStatusReportUpdateMutation = useMutation(

apps/dashboard/src/app/(dashboard)/status-pages/[id]/status-reports/page.tsx

@@ -34,7 +34,7 @@ export default function Page() {
     trpc.statusReport.list.queryOptions({ pageId: Number.parseInt(id) }),
   );
   const sendStatusReportUpdateMutation = useMutation(
-    trpc.statusReport.notify.mutationOptions(),
+    trpc.subscriberNotification.statusReport.mutationOptions(),
   );
   const createStatusReportMutation = useMutation(
     trpc.statusReport.create.mutationOptions({

apps/dashboard/src/components/data-table/status-report-updates/data-table.tsx

@@ -49,7 +49,7 @@ export function DataTable({
   const { id } = useParams<{ id: string }>();
   const queryClient = useQueryClient();
   const sendStatusReportUpdateMutation = useMutation(
-    trpc.statusReport.notify.mutationOptions(),
+    trpc.subscriberNotification.statusReport.mutationOptions(),
   );
   const createStatusReportUpdateMutation = useMutation(
     trpc.statusReport.createStatusReportUpdate.mutationOptions({

apps/dashboard/src/components/data-table/status-reports/data-table-row-actions.tsx

@@ -55,7 +55,7 @@ export function DataTableRowActions({ row }: DataTableRowActionsProps) {
   const currentImpacts = currentImpactsFromUpdates(row.original.updates);
   const nextStatus = getNextStatus(row.original.status);
   const sendStatusReportUpdateMutation = useMutation(
-    trpc.statusReport.notify.mutationOptions(),
+    trpc.subscriberNotification.statusReport.mutationOptions(),
   );
   const updateStatusReportMutation = useMutation(
     trpc.statusReport.updateStatus.mutationOptions({

apps/dashboard/src/lib/trpc/shared.ts

@@ -40,6 +40,7 @@ const lambdas = [
   "apiKeyRouter",
   "integrationRouter",
   "blob",
+  "subscriberNotification",
 ];
 
 export const endingLink = (opts?: {

packages/api/src/lambda.ts

@@ -3,6 +3,7 @@ import { blobRouter } from "./router/blob";
 import { emailRouter } from "./router/email";
 import { integrationRouter } from "./router/integration";
 import { stripeRouter } from "./router/stripe";
+import { subscriberNotificationRouter } from "./router/subscriber-notification";
 import { createTRPCRouter } from "./trpc";
 // Deployed to /trpc/lambda/**
 export const lambdaRouter = createTRPCRouter({
@@ -11,6 +12,7 @@ export const lambdaRouter = createTRPCRouter({
   apiKeyRouter: apiKeyRouter,
   integrationRouter: integrationRouter,
   blob: blobRouter,
+  subscriberNotification: subscriberNotificationRouter,
 });
 
 export { stripe } from "./router/stripe/shared";

packages/api/src/router/maintenance.ts

@@ -4,7 +4,6 @@ import {
   createMaintenance,
   deleteMaintenance,
   listMaintenances,
-  notifyMaintenance,
   updateMaintenance,
 } from "@openstatus/services/maintenance";
 import { z } from "zod";
@@ -66,21 +65,6 @@ export const maintenanceRouter = createTRPCRouter({
       }
     }),
 
-  notify: protectedProcedure
-    .meta({ track: Events.NotifyMaintenance })
-    .input(z.object({ id: z.number() }))
-    .mutation(async ({ ctx, input }) => {
-      try {
-        await notifyMaintenance({
-          ctx: toServiceCtx(ctx),
-          input: { maintenanceId: input.id },
-        });
-        return { success: true };
-      } catch (err) {
-        toTRPCError(err);
-      }
-    }),
-
   new: protectedProcedure
     .meta({ track: Events.CreateMaintenance })
     .input(

packages/api/src/router/statusReport.ts

@@ -10,7 +10,6 @@ import {
   deleteStatusReportUpdate,
   getStatusReport,
   listStatusReports,
-  notifyStatusReport,
   updateStatusReport,
   updateStatusReportUpdate,
 } from "@openstatus/services/status-report";
@@ -80,8 +79,9 @@ export const statusReportRouter = createTRPCRouter({
             message: input.message,
           },
         });
-        // Notification is a separate, client-driven step (statusReport.notify)
-        // so creation and dispatch stay split.
+        // Notification is a separate, client-driven step
+        // (subscriberNotification.statusReport) so creation and dispatch stay
+        // split — dispatch must run on lambda, this router is Edge-served.
         return { ...initialUpdate, notifySubscribers: input.notifySubscribers };
       } catch (err) {
         toTRPCError(err);
@@ -113,21 +113,6 @@ export const statusReportRouter = createTRPCRouter({
       }
     }),
 
-  notify: protectedProcedure
-    .meta({ track: Events.NotifyReport })
-    .input(z.object({ id: z.number() }))
-    .mutation(async ({ ctx, input }) => {
-      try {
-        await notifyStatusReport({
-          ctx: toServiceCtx(ctx),
-          input: { statusReportUpdateId: input.id },
-        });
-        return { success: true };
-      } catch (err) {
-        toTRPCError(err);
-      }
-    }),
-
   updateStatusReportUpdate: protectedProcedure
     .meta({ track: Events.UpdateReportUpdate })
     .input(updateStatusReportUpdateTRPCInput)

packages/api/src/router/subscriber-notification.ts

@@ -0,0 +1,44 @@
+import { Events } from "@openstatus/analytics";
+import { notifyMaintenance } from "@openstatus/services/maintenance";
+import { notifyStatusReport } from "@openstatus/services/status-report";
+import { z } from "zod";
+
+import { toServiceCtx, toTRPCError } from "../service-adapter";
+import { createTRPCRouter, protectedProcedure } from "../trpc";
+
+// Subscriber dispatch fans out across every channel (email + webhook), so it
+// must run on the lambda runtime: the email channel (Resend + react-email
+// render) can't run on Edge and would silently drop emails while webhooks
+// still go out. Kept off the statusReport/maintenance routers, which are
+// Edge-served — see the `lambdas` list in the dashboard tRPC client.
+export const subscriberNotificationRouter = createTRPCRouter({
+  statusReport: protectedProcedure
+    .meta({ track: Events.NotifyReport })
+    .input(z.object({ id: z.number() }))
+    .mutation(async ({ ctx, input }) => {
+      try {
+        await notifyStatusReport({
+          ctx: toServiceCtx(ctx),
+          input: { statusReportUpdateId: input.id },
+        });
+        return { success: true };
+      } catch (err) {
+        toTRPCError(err);
+      }
+    }),
+
+  maintenance: protectedProcedure
+    .meta({ track: Events.NotifyMaintenance })
+    .input(z.object({ id: z.number() }))
+    .mutation(async ({ ctx, input }) => {
+      try {
+        await notifyMaintenance({
+          ctx: toServiceCtx(ctx),
+          input: { maintenanceId: input.id },
+        });
+        return { success: true };
+      } catch (err) {
+        toTRPCError(err);
+      }
+    }),
+});