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.
2.5 kB · 79 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980import { privateLocation, privateLocationToMonitors, selectPrivateLocationSchema,} from "@openstatus/db/src/schema";
import { emitAudit } from "../audit";import { requireScope } from "../auth";import { type ServiceContext, withTransaction } from "../context";import type { PrivateLocation } from "../types";import { assertMonitorsInWorkspace } from "./internal";import { CreatePrivateLocationInput } from "./schemas";
/** * Create a private location and attach it to the given monitors. * * `token` is audited as part of the `after` snapshot because private- * location tokens are workspace-scoped agent credentials visible in the * dashboard UI — treating them as "secret" in the audit log but plain-text * in the settings screen would be inconsistent. If that ever changes, * strip it here the way invitation tokens are stripped. */export async function createPrivateLocation(args: { ctx: ServiceContext; input: CreatePrivateLocationInput;}): Promise<PrivateLocation> { const { ctx } = args; requireScope(ctx, "write"); const input = CreatePrivateLocationInput.parse(args.input);
// Callers that can't mint their own credential (the public API) omit it. const token = input.token ?? crypto.randomUUID();
// The pivot table has no UNIQUE (private_location_id, monitor_id) // constraint, so duplicate input ids would silently produce duplicate // FK rows. Dedupe before insert; the audit snapshot follows suit. const monitorIds = Array.from(new Set(input.monitors));
return withTransaction(ctx, async (tx) => { await assertMonitorsInWorkspace({ tx, workspaceId: ctx.workspace.id, monitorIds, });
const row = await tx .insert(privateLocation) .values({ name: input.name, token, metadata: input.metadata && Object.keys(input.metadata).length > 0 ? input.metadata : null, workspaceId: ctx.workspace.id, }) .returning() .get();
if (monitorIds.length > 0) { await tx.insert(privateLocationToMonitors).values( monitorIds.map((monitorId) => ({ privateLocationId: row.id, monitorId, })), ); }
const parsed = selectPrivateLocationSchema.parse(row); await emitAudit(tx, ctx, { action: "private_location.create", entityType: "private_location", entityId: parsed.id, after: { ...parsed, monitorIds }, });
return parsed; });}