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.
1.3 kB · 45 lines
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546import { Events } from "@openstatus/analytics";import { PreviewImportInput, RunImportInput, previewImport, runImport,} from "@openstatus/services/import";
import { toServiceCtx, toTRPCError } from "../service-adapter";import { createTRPCRouter, protectedProcedure } from "../trpc";
export const importRouter = createTRPCRouter({ preview: protectedProcedure .meta({ track: Events.PreviewImport, trackProps: ["provider"] }) .input(PreviewImportInput) .mutation(async ({ ctx, input }) => { try { return await previewImport({ ctx: toServiceCtx(ctx), input }); } catch (err) { toTRPCError(err); } }),
run: protectedProcedure .meta({ track: Events.RunImport, trackProps: ["provider"], // A summary is returned for failed runs too; only count imports that // actually wrote something. trackResult: ({ data }) => { const status = (data as { status?: string } | undefined)?.status; return status === "completed" || status === "partial" ? { status } : null; }, }) .input(RunImportInput) .mutation(async ({ ctx, input }) => { try { return await runImport({ ctx: toServiceCtx(ctx), input }); } catch (err) { toTRPCError(err); } }),});