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.
6.7 kB · 223 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224import { and, asc, db as defaultDb, desc, eq, ne, sql } from "@openstatus/db";import { maintenance, page, pageComponent, pageComponentGroup, selectMaintenanceSchema, selectPageComponentGroupSchema, selectPageComponentSchema, selectPageSchema, statusReport,} from "@openstatus/db/src/schema";import { subdomainSafeList } from "@openstatus/db/src/schema/pages/constants";
import { type DB, type ServiceContext, batchReads, getReadDb,} from "../context";import { NotFoundError } from "../errors";import type { Maintenance, Page, PageComponent } from "../types";import { getPageInWorkspace } from "./internal";import { GetPageInput, GetSlugAvailableInput, ListPagesInput } from "./schemas";
type PageComponentGroupRow = typeof pageComponentGroup.$inferSelect;
export type PageListItem = Page & { /** Any non-resolved status report on this page — drives the sidebar dot. */ hasActiveStatusReport: boolean;};
export type PageWithRelations = Page & { maintenances: Maintenance[]; pageComponents: PageComponent[]; pageComponentGroups: PageComponentGroupRow[];};
export async function listPages(args: { ctx: ServiceContext; input: ListPagesInput;}): Promise<PageListItem[]> { const { ctx } = args; const input = ListPagesInput.parse(args.input); const db = getReadDb(ctx);
const dir = input.order === "asc" ? asc : desc;
// The probe is workspace-scoped, so it doesn't depend on the page ids and // both statements go out together. Distinct page ids of unresolved reports // rather than the reports themselves — the list view only needs the flag, // and the full history is unbounded. const [pageRows, unresolvedRows] = await batchReads(db, [ db .select() .from(page) .where(eq(page.workspaceId, ctx.workspace.id)) // id tiebreaker: createdAt ties would make offset pagination unstable .orderBy(dir(page.createdAt), dir(page.id)), db .selectDistinct({ pageId: statusReport.pageId }) .from(statusReport) .where( and( eq(statusReport.workspaceId, ctx.workspace.id), ne(statusReport.status, "resolved"), ), ), ]);
const pagesWithActiveReport = new Set<number>(); for (const r of unresolvedRows) { if (r.pageId != null) pagesWithActiveReport.add(r.pageId); }
return pageRows.map((p) => ({ ...selectPageSchema.parse(p), hasActiveStatusReport: pagesWithActiveReport.has(p.id), }));}
export async function getPage(args: { ctx: ServiceContext; input: GetPageInput;}): Promise<PageWithRelations> { const { ctx } = args; const input = GetPageInput.parse(args.input); const db = getReadDb(ctx);
const record = await getPageInWorkspace({ tx: db, id: input.id, workspaceId: ctx.workspace.id, });
const [maintenanceRows, componentRows, groupRows] = await Promise.all([ db .select() .from(maintenance) .where( and( eq(maintenance.pageId, record.id), eq(maintenance.workspaceId, ctx.workspace.id), ), ) .all(), db .select() .from(pageComponent) .where( and( eq(pageComponent.pageId, record.id), eq(pageComponent.workspaceId, ctx.workspace.id), ), ) .all(), db .select() .from(pageComponentGroup) .where( and( eq(pageComponentGroup.pageId, record.id), eq(pageComponentGroup.workspaceId, ctx.workspace.id), ), ) .all(), ]);
return { ...selectPageSchema.parse(record), maintenances: maintenanceRows.map((m) => selectMaintenanceSchema.parse(m)), pageComponents: componentRows.map((c) => selectPageComponentSchema.parse(c), ), pageComponentGroups: groupRows.map((g) => selectPageComponentGroupSchema.parse(g), ), };}
/** * Narrow "just the customDomain" read, scoped to the caller's workspace. * * The tRPC `updateCustomDomain` procedure needs the *pre-update* domain * so it can call Vercel add/remove before the db write — it can't use * the `existingDomain` returned from `updatePageCustomDomain` because * Vercel needs the old value up front. Using `getPage` (the full- * relations read) here would fire 3 extra batched queries for * maintenances / pageComponents / pageComponentGroups we don't need. * This one-column select replaces that with a single indexed lookup. */export async function getPageCustomDomain(args: { ctx: ServiceContext; input: GetPageInput;}): Promise<string> { const { ctx } = args; const input = GetPageInput.parse(args.input); const db = getReadDb(ctx);
const row = await db .select({ customDomain: page.customDomain }) .from(page) .where(and(eq(page.id, input.id), eq(page.workspaceId, ctx.workspace.id))) .get();
if (!row) throw new NotFoundError("page", input.id); return row.customDomain;}
/** NotFound rather than Forbidden so a miss is no existence oracle. */export async function assertCustomDomainInWorkspace(args: { ctx: ServiceContext; input: { domain: string };}): Promise<void> { const { ctx, input } = args; const row = await getReadDb(ctx) .select({ id: page.id }) .from(page) .where( and( sql`lower(${page.customDomain}) = ${input.domain.toLowerCase()}`, eq(page.workspaceId, ctx.workspace.id), ), ) .get();
if (!row) throw new NotFoundError("domain");}
/** * Cross-workspace lookup of a page by slug. Returns the raw row (not parsed * via `selectPageSchema`) because callers in the public status-page render * path expect the DB shape (`authEmailDomains` / `allowedIpRanges` as * comma-joined strings rather than arrays). Workspace scoping is the * caller's responsibility — slugs are globally unique, so the lookup * intentionally ignores `ctx.workspace`. */export async function getPageBySlug( args: { input: { slug: string } }, opts: { db?: DB } = {},): Promise<typeof page.$inferSelect | undefined> { const slug = args.input.slug.toLowerCase(); const db = opts.db ?? defaultDb; return db.select().from(page).where(eq(page.slug, slug)).get();}
/** Returns `true` when the slug is free (not reserved, not taken). */export async function getSlugAvailable(args: { ctx: ServiceContext; input: GetSlugAvailableInput;}): Promise<boolean> { const { ctx } = args; const input = GetSlugAvailableInput.parse(args.input); const db = getReadDb(ctx);
if (subdomainSafeList.includes(input.slug)) return false; const rows = await db .select({ id: page.id }) .from(page) .where(sql`lower(${page.slug}) = ${input.slug}`) .all(); return rows.length === 0;}