feat: component subscriptions (#1901)

* feat: component subscriptions

* fix: build and test

* fix: review

* chore: email manage url link

* chore: empty state

* fix: review

* chore: overflow-y

* fix: component id form

* fix: test

* fix: review

* fix: structured data missing image

* fix: build

Author: mxkaske

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

@@ -24,35 +24,40 @@ import { columns } from "@/components/data-table/subscribers/columns";
 import { UpgradeDialog } from "@/components/dialogs/upgrade";
 import { DataTable } from "@/components/ui/data-table/data-table";
 import { useTRPC } from "@/lib/trpc/client";
+import type { RouterOutputs } from "@openstatus/api";
 import { useQuery } from "@tanstack/react-query";
 import { Lock } from "lucide-react";
 import { useParams } from "next/navigation";
 import { useState } from "react";
 
+type Subscriber = RouterOutputs["pageSubscriber"]["list"][number];
+
 const EXAMPLES = [
   {
     id: 1,
     email: "max@openstatus.dev",
     createdAt: new Date(),
-    updatedAt: null,
     pageId: 1,
-    token: null,
+    channelType: "email",
     acceptedAt: new Date(),
-    expiresAt: new Date(),
     unsubscribedAt: null,
+    components: [],
+    isEntirePage: true,
+    webhookUrl: null,
   },
   {
     id: 2,
     email: "thibault@openstatus.dev",
     createdAt: new Date(),
-    updatedAt: null,
     pageId: 1,
-    token: null,
+    channelType: "email",
     acceptedAt: new Date(),
-    expiresAt: new Date(),
     unsubscribedAt: null,
+    components: [],
+    isEntirePage: true,
+    webhookUrl: null,
   },
-];
+] satisfies Subscriber[];
 
 export default function Page() {
   const { id } = useParams<{ id: string }>();

apps/dashboard/src/components/forms/components/update.tsx

@@ -90,11 +90,8 @@ export function FormComponentsUpdate() {
         onSubmit={async (values) => {
           await updateComponentsMutation.mutateAsync({
             pageId: Number.parseInt(id),
-            components: values.components.map(({ id, ...rest }) => rest),
-            groups: values.groups.map(({ id, components, ...rest }) => ({
-              ...rest,
-              components: components.map(({ id, ...c }) => c),
-            })),
+            components: values.components,
+            groups: values.groups.map(({ id: _groupId, ...rest }) => rest),
           });
         }}
       />

apps/server/.dockerignore

@@ -1,4 +1,4 @@
-# This file is generated by Dofigen v2.6.0
+# This file is generated by Dofigen v2.7.0
 # See https://github.com/lenra-io/dofigen
 
 node_modules

apps/server/Dockerfile

@@ -1,5 +1,5 @@
 # syntax=docker/dockerfile:1.19.0
-# This file is generated by Dofigen v2.6.0
+# This file is generated by Dofigen v2.7.0
 # See https://github.com/lenra-io/dofigen
 
 # install
@@ -37,6 +37,7 @@ RUN \
     --mount=type=bind,target=packages/upstash/package.json,source=packages/upstash/package.json \
     --mount=type=bind,target=packages/utils/package.json,source=packages/utils/package.json \
     --mount=type=bind,target=packages/tsconfig/package.json,source=packages/tsconfig/package.json \
+    --mount=type=bind,target=packages/subscriptions/package.json,source=packages/subscriptions/package.json \
     --mount=type=bind,target=packages/assertions/package.json,source=packages/assertions/package.json \
     --mount=type=bind,target=packages/theme-store/package.json,source=packages/theme-store/package.json \
     --mount=type=cache,target=/root/.bun/install/cache,sharing=locked \
@@ -60,11 +61,11 @@ COPY \
 RUN bun build --compile --sourcemap src/index.ts --outfile=app
 
 # runtime
-FROM debian@sha256:b32674fb57780ad57d7b0749242d3f585f462f4ec4a60ae0adacd945f9cb9734 AS runtime
+FROM debian@sha256:4333240150a6924f878e05ec2c998aec95238010e0e4d2fec6161c90128c4652 AS runtime
 LABEL \
-    io.dofigen.version="2.6.0" \
+    io.dofigen.version="2.7.0" \
     org.opencontainers.image.authors="OpenStatus Team" \
-    org.opencontainers.image.base.digest="sha256:b32674fb57780ad57d7b0749242d3f585f462f4ec4a60ae0adacd945f9cb9734" \
+    org.opencontainers.image.base.digest="sha256:4333240150a6924f878e05ec2c998aec95238010e0e4d2fec6161c90128c4652" \
     org.opencontainers.image.base.name="docker.io/debian:bullseye-slim" \
     org.opencontainers.image.description="REST API server with Hono framework for OpenStatus" \
     org.opencontainers.image.source="https://github.com/openstatusHQ/openstatus" \

apps/server/dofigen.lock

@@ -15,8 +15,8 @@ effective: |
         path: oven/bun
         digest: sha256:f20d9cf365ab35529384f1717687c739c92e6f39157a35a95ef06f4049a10e4a
       label:
-        org.opencontainers.image.base.name: docker.io/oven/bun:1.3.6
         org.opencontainers.image.base.digest: sha256:f20d9cf365ab35529384f1717687c739c92e6f39157a35a95ef06f4049a10e4a
+        org.opencontainers.image.base.name: docker.io/oven/bun:1.3.6
         org.opencontainers.image.stage: install
       workdir: /app/
       run:
@@ -78,6 +78,8 @@ effective: |
         source: packages/utils/package.json
       - target: packages/tsconfig/package.json
         source: packages/tsconfig/package.json
+      - target: packages/subscriptions/package.json
+        source: packages/subscriptions/package.json
       - target: packages/assertions/package.json
         source: packages/assertions/package.json
       - target: packages/theme-store/package.json
@@ -87,8 +89,8 @@ effective: |
         path: oven/bun
         digest: sha256:f20d9cf365ab35529384f1717687c739c92e6f39157a35a95ef06f4049a10e4a
       label:
-        org.opencontainers.image.stage: build
         org.opencontainers.image.base.digest: sha256:f20d9cf365ab35529384f1717687c739c92e6f39157a35a95ef06f4049a10e4a
+        org.opencontainers.image.stage: build
         org.opencontainers.image.base.name: docker.io/oven/bun:1.3.6
       workdir: /app/apps/server
       env:
@@ -105,16 +107,16 @@ effective: |
       - bun build --compile --sourcemap src/index.ts --outfile=app
   fromImage:
     path: debian
-    digest: sha256:b32674fb57780ad57d7b0749242d3f585f462f4ec4a60ae0adacd945f9cb9734
+    digest: sha256:4333240150a6924f878e05ec2c998aec95238010e0e4d2fec6161c90128c4652
   label:
-    io.dofigen.version: 2.6.0
+    org.opencontainers.image.authors: OpenStatus Team
+    io.dofigen.version: 2.7.0
+    org.opencontainers.image.base.digest: sha256:4333240150a6924f878e05ec2c998aec95238010e0e4d2fec6161c90128c4652
+    org.opencontainers.image.description: REST API server with Hono framework for OpenStatus
     org.opencontainers.image.vendor: OpenStatus
-    org.opencontainers.image.base.digest: sha256:b32674fb57780ad57d7b0749242d3f585f462f4ec4a60ae0adacd945f9cb9734
     org.opencontainers.image.source: https://github.com/openstatusHQ/openstatus
-    org.opencontainers.image.base.name: docker.io/debian:bullseye-slim
-    org.opencontainers.image.description: REST API server with Hono framework for OpenStatus
-    org.opencontainers.image.authors: OpenStatus Team
     org.opencontainers.image.title: OpenStatus Server
+    org.opencontainers.image.base.name: docker.io/debian:bullseye-slim
   user:
     user: '1000'
     group: '1000'
@@ -141,17 +143,17 @@ effective: |
     retries: 3
 images:
   docker.io:
-    library:
-      debian:
-        bullseye-slim:
-          digest: sha256:b32674fb57780ad57d7b0749242d3f585f462f4ec4a60ae0adacd945f9cb9734
     oven:
       bun:
         1.3.6:
           digest: sha256:f20d9cf365ab35529384f1717687c739c92e6f39157a35a95ef06f4049a10e4a
+    library:
+      debian:
+        bullseye-slim:
+          digest: sha256:4333240150a6924f878e05ec2c998aec95238010e0e4d2fec6161c90128c4652
 resources:
   dofigen.yml:
-    hash: 534b1d0a16fe15d3ca9a01f090b1303ac7c2e011607e25167357592a6a987129
+    hash: d3a2fdcc47230fbc3d4bf7c1298d053cc7f7cc63b035b6c19809554394304328
     content: |
       # Files to exclude from Docker context
       ignore:
@@ -200,6 +202,7 @@ resources:
             - packages/upstash/package.json
             - packages/utils/package.json
             - packages/tsconfig/package.json
+            - packages/subscriptions/package.json
             - packages/assertions/package.json
             - packages/theme-store/package.json
           run: bun install --production --frozen-lockfile --verbose

apps/server/dofigen.yml

@@ -45,6 +45,7 @@ builders:
       - packages/upstash/package.json
       - packages/utils/package.json
       - packages/tsconfig/package.json
+      - packages/subscriptions/package.json
       - packages/assertions/package.json
       - packages/theme-store/package.json
     run: bun install --production --frozen-lockfile --verbose

apps/server/package.json

@@ -24,6 +24,7 @@
     "@logtape/otel": "2.0.1",
     "@logtape/sentry": "2.0.1",
     "@openstatus/analytics": "workspace:*",
+    "@openstatus/subscriptions": "workspace:*",
     "@openstatus/notification-discord": "workspace:*",
     "@openstatus/notification-google-chat": "workspace:*",
     "@openstatus/notification-grafana-oncall": "workspace:*",

apps/server/src/libs/test/preload.ts

@@ -1,5 +1,19 @@
 import { mock } from "bun:test";
 
+// Subscription dispatch spies — accessible in tests via globalThis.__subscriptionSpies
+const dispatchStatusReportUpdateSpy = mock((_id: number) => Promise.resolve());
+const dispatchMaintenanceUpdateSpy = mock((_id: number) => Promise.resolve());
+
+(globalThis as Record<string, unknown>).__subscriptionSpies = {
+  dispatchStatusReportUpdate: dispatchStatusReportUpdateSpy,
+  dispatchMaintenanceUpdate: dispatchMaintenanceUpdateSpy,
+};
+
+mock.module("@openstatus/subscriptions", () => ({
+  dispatchStatusReportUpdate: dispatchStatusReportUpdateSpy,
+  dispatchMaintenanceUpdate: dispatchMaintenanceUpdateSpy,
+}));
+
 const testRedisStore = new Map<string, string>();
 (globalThis as Record<string, unknown>).__testRedisStore = testRedisStore;
 

apps/server/src/routes/rpc/services/maintenance/__tests__/maintenance.test.ts

@@ -1,4 +1,4 @@
-import { afterAll, beforeAll, describe, expect, spyOn, test } from "bun:test";
+import { afterAll, beforeAll, describe, expect, test } from "bun:test";
 import { db, eq } from "@openstatus/db";
 import {
   maintenance,
@@ -7,15 +7,14 @@ import {
   pageComponent,
   pageSubscriber,
 } from "@openstatus/db/src/schema";
-import { EmailClient } from "@openstatus/emails";
 
 import { app } from "@/index";
 
-// Mock the sendMaintenanceNotification method
-const sendMaintenanceNotificationMock = spyOn(
-  EmailClient.prototype,
-  "sendMaintenanceNotification",
-).mockResolvedValue(undefined);
+const subscriptionSpies = (globalThis as Record<string, unknown>)
+  .__subscriptionSpies as {
+  dispatchStatusReportUpdate: ReturnType<typeof import("bun:test").mock>;
+  dispatchMaintenanceUpdate: ReturnType<typeof import("bun:test").mock>;
+};
 
 /**
  * Helper to make ConnectRPC requests using the Connect protocol (JSON).
@@ -458,7 +457,7 @@ describe("MaintenanceService.CreateMaintenance", () => {
   });
 
   test("creates maintenance with notify=true", async () => {
-    sendMaintenanceNotificationMock.mockClear();
+    subscriptionSpies.dispatchMaintenanceUpdate.mockClear();
 
     const fromDate = new Date(Date.now() + 7 * 24 * 60 * 60 * 1000);
     const toDate = new Date(Date.now() + 7 * 24 * 60 * 60 * 1000 + 3600000);
@@ -483,12 +482,9 @@ describe("MaintenanceService.CreateMaintenance", () => {
     expect(data).toHaveProperty("maintenance");
     expect(data.maintenance.title).toBe(`${TEST_PREFIX}-with-notify`);
 
-    // Verify notification was sent
-    expect(sendMaintenanceNotificationMock).toHaveBeenCalledTimes(1);
-    const mockCall = sendMaintenanceNotificationMock.mock.calls[0][0];
-    expect(mockCall.maintenanceTitle).toBe(`${TEST_PREFIX}-with-notify`);
-    expect(mockCall.message).toBe(
-      "Notifying subscribers about this maintenance.",
+    // Verify dispatcher was called (dispatchers are mocked in preload.ts)
+    expect(subscriptionSpies.dispatchMaintenanceUpdate).toHaveBeenCalledTimes(
+      1,
     );
 
     // Clean up
@@ -506,7 +502,7 @@ describe("MaintenanceService.CreateMaintenance", () => {
   });
 
   test("creates maintenance with notify=false (default)", async () => {
-    sendMaintenanceNotificationMock.mockClear();
+    subscriptionSpies.dispatchMaintenanceUpdate.mockClear();
 
     const fromDate = new Date(Date.now() + 7 * 24 * 60 * 60 * 1000);
     const toDate = new Date(Date.now() + 7 * 24 * 60 * 60 * 1000 + 3600000);
@@ -531,8 +527,8 @@ describe("MaintenanceService.CreateMaintenance", () => {
     expect(data).toHaveProperty("maintenance");
     expect(data.maintenance.title).toBe(`${TEST_PREFIX}-no-notify`);
 
-    // Verify notification was NOT sent
-    expect(sendMaintenanceNotificationMock).not.toHaveBeenCalled();
+    // Verify dispatcher was NOT called
+    expect(subscriptionSpies.dispatchMaintenanceUpdate).not.toHaveBeenCalled();
 
     // Clean up
     await db