Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 🫖 Status page with uptime monitoring & API monitoring as code 🫖 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
1.8 kB · 53 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354import { db as defaultDb, eq } from "@openstatus/db";import { maintenance, maintenanceUpdate } from "@openstatus/db/src/schema";import { dispatchMaintenanceUpdate } from "@openstatus/subscriptions";
import { requireScope } from "../auth";import type { ServiceContext } from "../context";import { ForbiddenError, NotFoundError } from "../errors";import { NotifyMaintenanceInput } from "./schemas";
/** * Dispatch subscriber notifications for one timeline entry (the announcement * is the first update). Separate from the mutations because the dashboard * runs on Edge and cannot fire-and-forget — callers invoke this as a second * awaited call, mirroring `notifyStatusReport`. * * Enforces: * - Workspace owns the target update (via join to the parent maintenance). * - Plan has `status-subscribers` enabled — otherwise no-op. * * Returns true only when a dispatch actually ran. */export async function notifyMaintenance(args: { ctx: ServiceContext; input: NotifyMaintenanceInput;}): Promise<boolean> { const { ctx } = args; requireScope(ctx, "write"); const input = NotifyMaintenanceInput.parse(args.input); const db = ctx.db ?? defaultDb;
const row = await db .select({ workspaceId: maintenance.workspaceId }) .from(maintenanceUpdate) .innerJoin(maintenance, eq(maintenanceUpdate.maintenanceId, maintenance.id)) .where(eq(maintenanceUpdate.id, input.maintenanceUpdateId)) .get();
if (!row) { throw new NotFoundError("maintenance_update", input.maintenanceUpdateId); } if (row.workspaceId !== ctx.workspace.id) { throw new ForbiddenError( "Maintenance update does not belong to this workspace.", ); }
if (!ctx.workspace.limits["status-subscribers"]) { return false; }
await dispatchMaintenanceUpdate(input.maintenanceUpdateId); return true;}