raystack · rsbh · Apr 14, 2026 · Apr 14, 2026 · Apr 14, 2026 · Apr 14, 2026
diff --git a/bun.lock b/bun.lock
diff --git a/packages/chronicle/package.json b/packages/chronicle/package.json
@@ -36,6 +36,11 @@
     "@codemirror/theme-one-dark": "^6.1.3",
     "@codemirror/view": "^6.39.14",
     "@heroicons/react": "^2.2.0",
+    "@opentelemetry/api": "^1.9.1",
+    "@opentelemetry/exporter-prometheus": "^0.214.0",
+    "@opentelemetry/resources": "^2.6.1",
+    "@opentelemetry/sdk-metrics": "^2.6.1",
+    "@opentelemetry/semantic-conventions": "^1.40.0",
     "@raystack/apsara": "0.55.1",
     "@shikijs/rehype": "^4.0.2",
     "@vitejs/plugin-react": "^6.0.1",

diff --git a/packages/chronicle/src/server/api/metrics.ts b/packages/chronicle/src/server/api/metrics.ts
@@ -0,0 +1,23 @@
+import type { IncomingMessage, ServerResponse } from 'node:http'
+import { defineHandler } from 'nitro'
+import { getExporter } from '../telemetry'
+
+export default defineHandler(async () => {
+  const exporter = getExporter()
+  if (!exporter) {
+    return new Response('Telemetry not enabled', { status: 404 })
+  }
+
+  const metricsString = await new Promise<string>((resolve) => {
+    const mockRes = {
+      setHeader: () => mockRes,
+      end: (data: string) => resolve(data),
+    } as unknown as ServerResponse
+
+    exporter.getMetricsRequestHandler({} as unknown as IncomingMessage, mockRes)
+  })
-  const metricsString = await new Promise<string>((resolve) => {
-    const mockRes = {
-      setHeader: () => mockRes,
-      end: (data: string) => resolve(data),
-    } as unknown as ServerResponse
-
-    exporter.getMetricsRequestHandler({} as unknown as IncomingMessage, mockRes)
-  })
+  const metricsString = await new Promise<string>((resolve, reject) => {
+    const timeout = setTimeout(() => reject(new Error('Metrics collection timed out')), 5000)
+    const mockRes = {
+      setHeader: () => mockRes,
+      end: (data: string) => {
+        clearTimeout(timeout)
+        resolve(data)
+      },
+    } as unknown as ServerResponse
+
+    try {
+      exporter.getMetricsRequestHandler({} as unknown as IncomingMessage, mockRes)
+    } catch (error) {
+      clearTimeout(timeout)
+      reject(error)
+    }
+  }).catch((error) => {
+    throw new Error(`Failed to collect metrics: ${error.message}`)
+  })
-  const metricsString = await new Promise<string>((resolve) => {
-    const mockRes = {
-      setHeader: () => mockRes,
-      end: (data: string) => resolve(data),
-    } as unknown as ServerResponse
-
-    exporter.getMetricsRequestHandler({} as unknown as IncomingMessage, mockRes)
-  })
+  const metricsString = await new Promise<string>((resolve, reject) => {
+    const timeout = setTimeout(() => reject(new Error('Metrics collection timed out')), 5000)
+    const mockRes = {
+      setHeader: () => mockRes,
+      end: (data: string) => {
+        clearTimeout(timeout)
+        resolve(data)
+      },
+    } as unknown as ServerResponse
+
+    try {
+      exporter.getMetricsRequestHandler({} as unknown as IncomingMessage, mockRes)
+    } catch (error) {
+      clearTimeout(timeout)
+      reject(error)
+    }
+  }).catch((error) => {
+    throw new Error(`Failed to collect metrics: ${error.message}`)
+  })
+
+  return new Response(metricsString, {
+    headers: { 'Content-Type': 'text/plain; charset=utf-8' },
+  })
+})
diff --git a/packages/chronicle/src/server/entry-server.tsx b/packages/chronicle/src/server/entry-server.tsx
@@ -10,6 +10,7 @@ import { loadApiSpecs } from '@/lib/openapi';
 import { PageProvider } from '@/lib/page-context';
 import { getPageTree, getPage, loadPageModule, extractFrontmatter, getRelativePath, getOriginalPath } from '@/lib/source';
 import { App } from './App';
+import { recordSSRRender } from './telemetry';
 
 import clientAssets from './entry-client?assets=client';
 import serverAssets from './entry-server?assets=ssr';
@@ -57,6 +58,7 @@ export default {
 
     const assets = clientAssets.merge(serverAssets);
 
+    const renderStart = performance.now();
     const stream = await renderToReadableStream(
       <html lang="en">
         <head>
@@ -91,9 +93,13 @@ export default {
       </html>,
     );
 
+    const renderDuration = performance.now() - renderStart;
+
     const isApiRoute = pathname.startsWith('/apis');
     const status = !page && !isApiRoute && slug.length > 0 ? 404 : 200;
 
+    recordSSRRender(pathname, status, renderDuration);
+
     return new Response(stream, {
       status,
       headers: { 'Content-Type': 'text/html;charset=utf-8' },

diff --git a/packages/chronicle/src/server/plugins/telemetry.ts b/packages/chronicle/src/server/plugins/telemetry.ts
@@ -0,0 +1,21 @@
+import { definePlugin } from 'nitro'
+import { loadConfig } from '@/lib/config'
+import { initTelemetry, recordRequest } from '../telemetry'
+
+export default definePlugin((nitroApp) => {
+  const config = loadConfig()
+  if (!config.telemetry?.enabled) return
+
+  initTelemetry(config)
+
+  nitroApp.hooks.hook('request', (event) => {
+    if (event.path === '/api/metrics') return
+    event.context._requestStart = performance.now()
+  })
+
+  nitroApp.hooks.hook('response', (res, event) => {
+    if (!event.context._requestStart) return
+    const duration = performance.now() - event.context._requestStart
+    recordRequest(event.method, event.path, res.status, duration)
+  })
+})
diff --git a/packages/chronicle/src/server/telemetry.ts b/packages/chronicle/src/server/telemetry.ts
@@ -0,0 +1,49 @@
+import type { Counter, Histogram } from '@opentelemetry/api'
+import sdkMetrics from '@opentelemetry/sdk-metrics'
+import prometheusExporter from '@opentelemetry/exporter-prometheus'
+import resources from '@opentelemetry/resources'
+import semconv from '@opentelemetry/semantic-conventions'
+import type { ChronicleConfig } from '@/types/config'
+
+const { MeterProvider } = sdkMetrics
+const { PrometheusExporter } = prometheusExporter
+const { resourceFromAttributes } = resources
+const { ATTR_SERVICE_NAME } = semconv
+
+let exporter: PrometheusExporter
+let requestCounter: Counter
+let requestDuration: Histogram
+let ssrRenderDuration: Histogram
+
+export function initTelemetry(config: ChronicleConfig) {
+  const resource = resourceFromAttributes({
+    [ATTR_SERVICE_NAME]: config.telemetry?.serviceName ?? 'chronicle',
+  })
+
+  exporter = new PrometheusExporter({ preventServerStart: true })
+  const provider = new MeterProvider({ resource, readers: [exporter] })
+  const meter = provider.getMeter('chronicle')
+
+  requestCounter = meter.createCounter('http_server_request_total', {
+    description: 'Total HTTP requests',
+  })
+  requestDuration = meter.createHistogram('http_server_request_duration_ms', {
+    description: 'HTTP request duration in ms',
+  })
+  ssrRenderDuration = meter.createHistogram('http_server_ssr_render_duration_ms', {
+    description: 'SSR render duration in ms',
+  })
+}
+
+export function getExporter() {
+  return exporter
+}
+
+export function recordRequest(method: string, route: string, status: number, durationMs: number) {
+  requestCounter?.add(1, { method, route, status })
+  requestDuration?.record(durationMs, { method, route, status })
+}
+
+export function recordSSRRender(route: string, status: number, durationMs: number) {
+  ssrRenderDuration?.record(durationMs, { route, status })
+}
diff --git a/packages/chronicle/src/types/config.ts b/packages/chronicle/src/types/config.ts
@@ -67,6 +67,11 @@ const analyticsSchema = z.object({
   googleAnalytics: googleAnalyticsSchema.optional(),
 })
 
+const telemetrySchema = z.object({
+  enabled: z.boolean().optional(),
+  serviceName: z.string().optional(),
+})
+
 export const chronicleConfigSchema = z.object({
   title: z.string(),
   description: z.string().optional(),
@@ -81,6 +86,7 @@ export const chronicleConfigSchema = z.object({
   api: z.array(apiSchema).optional(),
   llms: llmsSchema.optional(),
   analytics: analyticsSchema.optional(),
+  telemetry: telemetrySchema.optional(),
 })
 
 export type ChronicleConfig = z.infer<typeof chronicleConfigSchema>
@@ -97,3 +103,4 @@ export type FooterConfig = z.infer<typeof footerSchema>
 export type LlmsConfig = z.infer<typeof llmsSchema>
 export type AnalyticsConfig = z.infer<typeof analyticsSchema>
 export type GoogleAnalyticsConfig = z.infer<typeof googleAnalyticsSchema>
+export type TelemetryConfig = z.infer<typeof telemetrySchema>