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.
5.7 kB · 204 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205import { AsyncLocalStorage } from "node:async_hooks";
import { configure, getConsoleSink, getLogger, jsonLinesFormatter, withContext,} from "@logtape/logtape";import { getOpenTelemetrySink } from "@logtape/otel";import { OTLPLogExporter } from "@opentelemetry/exporter-logs-otlp-http";import { resourceFromAttributes } from "@opentelemetry/resources";import { BatchLogRecordProcessor, LoggerProvider,} from "@opentelemetry/sdk-logs";import { ATTR_SERVICE_NAME } from "@opentelemetry/semantic-conventions";import { ATTR_DEPLOYMENT_ENVIRONMENT_NAME } from "@opentelemetry/semantic-conventions/incubating";import * as Sentry from "@sentry/deno";import { Hono } from "hono";import { showRoutes } from "hono/dev";import { requestId } from "hono/request-id";
import { checkerRoute } from "./checker";import "./lib/sentry";import { cronRouter } from "./cron";import { env } from "./env";import { pingRoute } from "./health";import { incidentRoute } from "./incident";
const { NODE_ENV } = env();
export type Env = { Variables: { event: Record<string, unknown>; };};
/** * Tail sampling strategy based on loggingsucks.com best practices * Makes sampling decisions post-request completion to capture: * - All errors (5xx status codes, explicit errors) * - Slow requests (above p99 threshold) * - Client errors (4xx) at higher rate than successful requests * - Random sample of remaining successful, fast requests */function shouldSample(event: Record<string, unknown>): boolean { const statusCode = event.status_code as number | undefined; const durationMs = event.duration_ms as number | undefined;
// Always capture: server errors if (statusCode && statusCode >= 500) return true;
// Always capture: explicit errors if (event.outcome === "error") return true;
// Always capture: slow requests (above p99 - 2s threshold) if (durationMs && durationMs > 2000) return true;
// Higher sampling for client errors (4xx) - 50% if (statusCode && statusCode >= 400 && statusCode < 500) { return true; }
// Random sample successful, fast requests at 20% return Math.random() < 0.2;}
// Build the LoggerProvider with a static OTLP exporter import so `deno bundle`// includes it. Letting @logtape/otel create the exporter triggers a dynamic// import of a bare specifier, which the compiled --node-modules-dir=none binary// can't resolve.const loggerProvider = new LoggerProvider({ resource: resourceFromAttributes({ [ATTR_SERVICE_NAME]: "openstatus-workflows", [ATTR_DEPLOYMENT_ENVIRONMENT_NAME]: env().NODE_ENV, }), processors: [ new BatchLogRecordProcessor( new OTLPLogExporter({ url: "https://eu-central-1.aws.edge.axiom.co/v1/logs", headers: { Authorization: `Bearer ${env().AXIOM_TOKEN}`, "X-Axiom-Dataset": env().AXIOM_DATASET, }, }), ), ],});
const defaultLogger = getOpenTelemetrySink({ loggerProvider,});
await configure({ sinks: { console: getConsoleSink({ formatter: jsonLinesFormatter }), // sentry: getSentrySink(), otel: defaultLogger, }, loggers: [ { category: "workflow", lowestLevel: "warning", sinks: ["console"], }, { category: "workflow-otel", lowestLevel: "info", sinks: ["otel"], }, ], contextLocalStorage: new AsyncLocalStorage(),});
const logger = getLogger(["workflow"]);const otelLogger = getLogger(["workflow-otel"]);
export const app = new Hono<Env>({ strict: false });
app.use("*", requestId());
app.use("*", async (c, next) => { const requestId = c.get("requestId"); const startTime = Date.now();
const event: Record<string, unknown> = { timestamp: new Date().toISOString(), }; c.set("event", event);
await withContext( { request_id: requestId, method: c.req.method, url: c.req.url, user_agent: c.req.header("User-Agent"), // ipAddress: c.req.header("CF-Connecting-IP") || c.req.header("X-Forwarded-For") }, async () => { // Build wide event context at request start event.request_id = requestId; event.method = c.req.method; event.path = c.req.path; event.url = c.req.url; event.user_agent = c.req.header("User-Agent"); event.content_type = c.req.header("Content-Type"); event.cf_ray = c.req.header("CF-Ray"); event.cf_connecting_ip = c.req.header("CF-Connecting-IP");
await next();
const duration = Date.now() - startTime;
event.status_code = c.res.status; event.outcome = c.error ? "error" : "success"; event.duration_ms = duration; // Emit canonical log line with all context (wide event pattern) if (shouldSample(event)) { otelLogger.info("request", event); } logger.debug("Request completed", { status_code: c.res.status, duration_ms: duration, request_id: requestId, }); }, );});
app.onError((err, c) => { logger.error("Unhandled request error", { error_name: err.name, error_message: err.message, error_stack: err.stack, method: c.req.method, path: c.req.path, url: c.req.url, request_id: c.get("requestId"), }); Sentry.captureException(err);
return c.json({ error: "Internal server error" }, 500);});
app.get("/", (c) => c.text("workflows", 200));
/** * Health check — probes the database and Tinybird and reports the Fly * machine answering. */app.route("/", pingRoute);
/** * Cron Routes */app.route("/cron", cronRouter);
app.route("/", checkerRoute);
app.route("/incident", incidentRoute);if (NODE_ENV === "development") { showRoutes(app, { verbose: true, colorize: true });}