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.3 kB · 137 lines
TypeScript
at incident-api
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138import { statusReportUpdate, statusReportsToPageComponents,} from "@openstatus/db/src/schema";
import { emitAudit } from "../audit";import { requireScope } from "../auth";import { type ServiceContext, tryGetActorUserId, withTransaction,} from "../context";import { ConflictError, InternalServiceError } from "../errors";import type { StatusReport, StatusReportUpdate } from "../types";import { recomputeReportStatus } from "./derive-status";import { getCurrentImpactsForReport, getReportInWorkspace, insertUpdateComponentImpacts, validatePageComponentIds, withComponentImpacts,} from "./internal";import { AddStatusReportUpdateInput } from "./schemas";
export type AddStatusReportUpdateResult = { statusReport: StatusReport; statusReportUpdate: StatusReportUpdate;};
export async function addStatusReportUpdate(args: { ctx: ServiceContext; input: AddStatusReportUpdateInput;}): Promise<AddStatusReportUpdateResult> { const { ctx } = args; requireScope(ctx, "write"); const input = AddStatusReportUpdateInput.parse(args.input); const actorUserId = tryGetActorUserId(ctx.actor);
return withTransaction(ctx, async (tx) => { const report = await getReportInWorkspace({ tx, id: input.statusReportId, workspaceId: ctx.workspace.id, });
const date = input.date ?? new Date();
const componentImpacts = input.componentImpacts ?? []; if (componentImpacts.length > 0) { const validated = await validatePageComponentIds({ tx, workspaceId: ctx.workspace.id, pageComponentIds: componentImpacts.map((ci) => ci.pageComponentId), }); if ( validated.pageId !== null && report.pageId !== null && validated.pageId !== report.pageId ) { throw new ConflictError( `Components belong to page ${validated.pageId}, not the report's page ${report.pageId}.`, ); } // invariant: every impact row's component is in the report's membership // set — an update is the only way to add a component after creation. await tx .insert(statusReportsToPageComponents) .values( validated.componentIds.map((pageComponentId) => ({ statusReportId: report.id, pageComponentId, })), ) .onConflictDoNothing(); }
// resolve clears every still-non-operational component not named by this // update, so the page clears deterministically. Computed before this // update's rows are written; empty map (legacy report) stays legacy. let writtenImpacts = componentImpacts; if (input.status === "resolved") { const current = await getCurrentImpactsForReport(tx, report.id); const named = new Set(componentImpacts.map((ci) => ci.pageComponentId)); const clears = [...current] .filter( ([componentId, impact]) => impact !== "operational" && !named.has(componentId), ) .map(([pageComponentId]) => ({ pageComponentId, impact: "operational" as const, })); writtenImpacts = [...componentImpacts, ...clears]; }
const newUpdate = await tx .insert(statusReportUpdate) .values({ statusReportId: report.id, status: input.status, date, message: input.message, createdBy: actorUserId, updatedBy: actorUserId, }) .returning() .get();
await insertUpdateComponentImpacts({ tx, statusReportUpdateId: newUpdate.id, componentImpacts: writtenImpacts, });
// derived, not assigned — a back-dated update must not win const updatedReport = await recomputeReportStatus(tx, report.id, { touchIfLatestIs: newUpdate.id, updatedBy: actorUserId, });
if (!updatedReport) { throw new InternalServiceError( `failed to bump status report ${report.id} after adding update`, ); }
await emitAudit(tx, ctx, { action: "status_report_update.create", entityType: "status_report_update", entityId: newUpdate.id, after: withComponentImpacts(newUpdate, writtenImpacts), metadata: { statusReportId: report.id }, });
return { statusReport: updatedReport, statusReportUpdate: newUpdate }; });}