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.
4.6 kB · 151 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152import { and, eq, inArray, isNull } from "@openstatus/db";import { monitor, notification } from "@openstatus/db/src/schema";import { type NotificationProvider, discordDataSchema, emailDataSchema, googleChatDataSchema, grafanaOncallDataSchema, msTeamsDataSchema, ntfyDataSchema, opsgenieDataSchema, pagerdutyDataSchema, phoneDataSchema, slackDataSchema, telegramDataSchema, webhookDataSchema, whatsappDataSchema,} from "@openstatus/db/src/schema";import type { ZodType } from "zod";
import type { DB } from "../context";import { ForbiddenError, LimitExceededError, NotFoundError, ValidationError,} from "../errors";import type { Workspace } from "../types";import type { NotificationDataInput } from "./schemas";
/** Load a notification by id, scoped to the workspace. Throws on miss. */export async function getNotificationInWorkspace(args: { tx: DB; id: number; workspaceId: number;}) { const { tx, id, workspaceId } = args; const row = await tx .select() .from(notification) .where( and(eq(notification.id, id), eq(notification.workspaceId, workspaceId)), ) .get(); if (!row) throw new NotFoundError("notification", id); return row;}
/** Validate that monitor ids exist and belong to the workspace (not soft-deleted). */export async function validateMonitorIds(args: { tx: DB; workspaceId: number; monitorIds: ReadonlyArray<number>;}): Promise<number[]> { const { tx, workspaceId, monitorIds } = args; if (monitorIds.length === 0) return []; const ids = Array.from(new Set(monitorIds)); const rows = await tx .select({ id: monitor.id }) .from(monitor) .where( and( inArray(monitor.id, ids), eq(monitor.workspaceId, workspaceId), isNull(monitor.deletedAt), ), ) .all(); const valid = new Set(rows.map((r) => r.id)); for (const id of ids) { if (!valid.has(id)) { throw new ForbiddenError(`Monitor ${id} is not accessible.`); } } return ids;}
/** * Providers gated behind plan flags. The workspace plan must have the flag * enabled for the service to accept a `new`/`update` referencing that * provider. `email`, `slack`, `discord`, `webhook`, `telegram`, `ntfy`, * `google-chat` are always allowed by the existing UI. */const PLAN_GATED_PROVIDERS = [ "sms", "pagerduty", "opsgenie", "grafana-oncall", "whatsapp",] as const satisfies ReadonlyArray<NotificationProvider>;
type PlanGatedProvider = (typeof PLAN_GATED_PROVIDERS)[number];
function isPlanGated(provider: string): provider is PlanGatedProvider { return (PLAN_GATED_PROVIDERS as ReadonlyArray<string>).includes(provider);}
// Creation is closed by plan flags; existing channels must stay editable.export const DEPRECATED_PROVIDERS = new Set<NotificationProvider>(["sms"]);
export function assertProviderAllowed( workspace: Workspace, provider: NotificationProvider,): void { if (!isPlanGated(provider)) return; const allowed = workspace.limits[provider]; if (!allowed) { throw new LimitExceededError(provider, 0); }}
// Provider → canonical data schema. Each provider-specific schema is// keyed by the provider name itself, so validating against the exact// schema guarantees both (a) the key is present, and (b) its payload has// the right shape. Just asserting `provider in data` would let a case// like `{ discord: "invalid-url", slack: "valid-url" }` slip through —// the union parse picks the slack variant and the key check sees discord.const providerDataSchemas = { discord: discordDataSchema, email: emailDataSchema, "google-chat": googleChatDataSchema, "grafana-oncall": grafanaOncallDataSchema, "ms-teams": msTeamsDataSchema, ntfy: ntfyDataSchema, opsgenie: opsgenieDataSchema, pagerduty: pagerdutyDataSchema, slack: slackDataSchema, sms: phoneDataSchema, telegram: telegramDataSchema, webhook: webhookDataSchema, whatsapp: whatsappDataSchema,} as const satisfies Record<NotificationProvider, ZodType>;
/** * Validate that `data` is the canonical payload for the given `provider`. * Runs the provider-specific Zod schema — this checks both key presence * and the value's shape/content in one pass. */export function validateNotificationData( provider: NotificationProvider, data: NotificationDataInput,): void { const schema = providerDataSchemas[provider]; const parsed = schema.safeParse(data); if (!parsed.success) { throw new ValidationError( `Invalid data for provider "${provider}".`, parsed.error, ); }}