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.
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475import type { AppRouter } from "@openstatus/api";import * as Sentry from "@sentry/nextjs";import type { HTTPHeaders, TRPCLink } from "@trpc/client";import { httpBatchStreamLink, 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 ""; // Note: dashboard has its own tRPC API routes if (process.env.VERCEL_URL) return "https://app.openstatus.dev"; // Vercel return "http://localhost:3000"; // Local dev and Docker (internal calls)};
// 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.// Streaming rather than plain batching: a batch mixing cheap queries with a// slow Tinybird pipe would otherwise deliver none of them until the slowest// one settles. Note this makes per-procedure errors arrive in-band on a 200 —// `sentryLoggerLink` above is what still reports them.export const endingLink = (opts?: { fetch?: typeof fetch; headers?: HTTPHeaders | (() => HTTPHeaders | Promise<HTTPHeaders>); }): TRPCLink<AppRouter> => (runtime) => httpBatchStreamLink<AppRouter>({ headers: opts?.headers, fetch: opts?.fetch, transformer: superjson, url: `${getBaseUrl()}/api/trpc/lambda`, })(runtime);