feat: add structured OTel request logs with source IP

packages/chronicle/package.json

@@ -43,8 +43,10 @@
     "@codemirror/view": "^6.39.14",
     "@heroicons/react": "^2.2.0",
     "@opentelemetry/api": "^1.9.1",
+    "@opentelemetry/api-logs": "^0.218.0",
     "@opentelemetry/exporter-prometheus": "^0.214.0",
     "@opentelemetry/resources": "^2.6.1",
+    "@opentelemetry/sdk-logs": "^0.218.0",
     "@opentelemetry/sdk-metrics": "^2.6.1",
     "@opentelemetry/semantic-conventions": "^1.40.0",
     "@radix-ui/react-icons": "^1.3.2",

packages/chronicle/src/server/plugins/telemetry.ts

@@ -1,6 +1,12 @@
 import type { Counter, Histogram } from '@opentelemetry/api'
 import { MeterProvider } from '@opentelemetry/sdk-metrics'
 import { PrometheusExporter } from '@opentelemetry/exporter-prometheus'
+import {
+  LoggerProvider,
+  SimpleLogRecordProcessor,
+  ConsoleLogRecordExporter,
+} from '@opentelemetry/sdk-logs'
+import { SeverityNumber } from '@opentelemetry/api-logs'
 import { resourceFromAttributes } from '@opentelemetry/resources'
 import { ATTR_SERVICE_NAME } from '@opentelemetry/semantic-conventions'
 import type { H3Event } from 'h3'
@@ -53,6 +59,12 @@ export default definePlugin((nitroApp) => {
   const provider = new MeterProvider({ resource, readers: [exporter] })
   const meter = provider.getMeter('chronicle')
 
+  const loggerProvider = new LoggerProvider({
+    resource,
+    processors: [new SimpleLogRecordProcessor(new ConsoleLogRecordExporter())],
+  })
+  const logger = loggerProvider.getLogger('chronicle')
+
   const requestCounter: Counter = meter.createCounter('http_server_request_total', {
     description: 'Total HTTP requests',
   })
@@ -64,6 +76,7 @@ export default definePlugin((nitroApp) => {
   })
 
   nitroApp.hooks.hook('close', async () => {
+    await loggerProvider.shutdown()
     await provider.shutdown()
     await exporter.shutdown()
   })
@@ -81,8 +94,30 @@ export default definePlugin((nitroApp) => {
     if (start === undefined) return
     const duration = performance.now() - start
     const method = event.req.method
-    const endpoint = toEndpoint(new URL(event.req.url).pathname)
+    const route = new URL(event.req.url).pathname
+    const endpoint = toEndpoint(route)
+
+    const clientIp =
+      event.req.headers['x-forwarded-for']?.toString().split(',')[0].trim() ??
+      event.req.headers['x-real-ip']?.toString() ??
+      event.req.socket?.remoteAddress ??
+      'unknown'
+
     requestCounter.add(1, { method, endpoint, status: res.status })
     requestDuration.record(duration, { method, endpoint, status: res.status })
+
+    logger.emit({
+      severityNumber: SeverityNumber.INFO,
+      severityText: 'INFO',
+      body: `${method} ${route} ${res.status} ${duration.toFixed(1)}ms`,
+      attributes: {
+        'client.address': clientIp,
+        'http.request.method': method,
+        'url.path': route,
+        'http.response.status_code': res.status,
+        'http.request.duration_ms': Math.round(duration),
+      },
+    })
+
   })
 })