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.8 kB · 102 lines
TypeScript
at incident-api
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103import { createRoute } from "@hono/zod-openapi";import { and, db, eq } from "@openstatus/db";import { statusReport, statusReportUpdate } from "@openstatus/db/src/schema";import { dispatchStatusReportUpdate } from "@openstatus/subscriptions";
import { OpenStatusApiError, openApiErrorResponses } from "@/libs/errors";
import type { statusReportUpdatesApi } from "./index";import { StatusReportUpdateSchema } from "./schema";
const createStatusUpdate = createRoute({ method: "post", tags: ["status_report_update"], summary: "Create a status report update", path: "/", request: { body: { description: "The status report update to create", content: { "application/json": { schema: StatusReportUpdateSchema.omit({ id: true }), }, }, }, }, responses: { 200: { content: { "application/json": { schema: StatusReportUpdateSchema, }, }, description: "The created status report update", }, ...openApiErrorResponses, },});
export function registerPostStatusReportUpdate( api: typeof statusReportUpdatesApi,) { return api.openapi(createStatusUpdate, async (c) => { const workspaceId = c.get("workspace").id; const actorUserId = c.get("apiKey").createdById ?? null; const input = c.req.valid("json"); const limits = c.get("workspace").limits;
const _statusReport = await db.query.statusReport.findFirst({ where: and( eq(statusReport.id, input.statusReportId), eq(statusReport.workspaceId, workspaceId), ), with: { statusReportsToPageComponents: { with: { pageComponent: true, }, }, }, });
if (!_statusReport) { throw new OpenStatusApiError({ code: "NOT_FOUND", message: `Status Report ${input.statusReportId} not found`, }); }
const _statusReportUpdate = await db.transaction(async (tx) => { const update = await tx .insert(statusReportUpdate) .values({ ...input, date: new Date(input.date), statusReportId: _statusReport.id, createdBy: actorUserId, updatedBy: actorUserId, }) .returning() .get();
await tx .update(statusReport) .set({ status: input.status, updatedAt: new Date(), updatedBy: actorUserId, }) .where(eq(statusReport.id, _statusReport.id));
return update; });
if (limits["status-subscribers"] && _statusReport.pageId) { await dispatchStatusReportUpdate(_statusReportUpdate.id); }
const data = StatusReportUpdateSchema.parse(_statusReportUpdate);
return c.json(data, 200); });}