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 · 70 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071import type { AppRouter } from "@openstatus/api";import * as Sentry from "@sentry/nextjs";import type { HTTPBatchLinkOptions, HTTPHeaders, TRPCLink } from "@trpc/client";import { httpBatchLink, loggerLink } from "@trpc/client";import superjson from "superjson";
/** * tRPC logger link that reports failed queries to Sentry directly instead of * letting captureConsoleIntegration scrape tRPC's styled console.error format * string (which surfaces as noise like "%c << query #1 %c...%c %O"). * * Only the operation `path` is attached — never `input`, which can carry * secrets (page passwords, subscriber tokens, emails). */export const sentryLoggerLink = (): TRPCLink<AppRouter> => loggerLink<AppRouter>({ enabled: (opts) => process.env.NODE_ENV === "development" || (opts.direction === "down" && opts.result instanceof Error), logger: (opts) => { if (opts.direction === "down" && opts.result instanceof Error) { Sentry.captureException(opts.result, { extra: { path: opts.path }, }); if (process.env.NODE_ENV === "development") { console.warn("[tRPC error]", opts.path, opts.result); } return; } if (process.env.NODE_ENV === "development") { console.log(opts); } }, });
/** * Filter out requests that don't come from our tRPC clients. * Our server and client links always set `x-trpc-source`. * This is a convention filter for bots/crawlers, not a security boundary — * the header is trivially spoofable. Auth is enforced by protectedProcedure. */export function guardTRPCSource(req: Request): Response | null { const source = req.headers.get("x-trpc-source"); if (source !== "server" && source !== "client") { return new Response(null, { status: 401 }); } return null;}
const getBaseUrl = () => { if (typeof window !== "undefined") return ""; if (process.env.VERCEL_ENV === "production") return "https://www.openstatus.dev"; if (process.env.VERCEL_URL) return `https://${process.env.VERCEL_URL}`; // Vercel return "http://localhost:3000"; // Local dev};
// The whole tRPC surface is served from a single Node.js endpoint — there is// no longer an Edge/Node split, so all calls go to one link.export const endingLink = (opts?: { headers?: HTTPHeaders | (() => HTTPHeaders | Promise<HTTPHeaders>); }): TRPCLink<AppRouter> => (runtime) => httpBatchLink({ headers: opts?.headers, // REMINDER: fails when trying to `getTotalActiveMonitors()` transformer: superjson, url: `${getBaseUrl()}/api/trpc/lambda`, // oxlint-disable-next-line typescript/no-explicit-any -- FIXME: remove any } satisfies Partial<HTTPBatchLinkOptions<any>>)(runtime);