| import { logs, SeverityNumber } from "@opentelemetry/api-logs"; |
| import pino, { multistream } from "pino"; |
| import type { Writable } from "node:stream"; |
|
|
| const SERVICE_NAME = "@superlog/proxy"; |
|
|
| const PINO_LEVEL_TO_OTEL: Record<number, { num: SeverityNumber; text: string }> = { |
| 10: { num: SeverityNumber.TRACE, text: "TRACE" }, |
| 20: { num: SeverityNumber.DEBUG, text: "DEBUG" }, |
| 30: { num: SeverityNumber.INFO, text: "INFO" }, |
| 40: { num: SeverityNumber.WARN, text: "WARN" }, |
| 50: { num: SeverityNumber.ERROR, text: "ERROR" }, |
| 60: { num: SeverityNumber.FATAL, text: "FATAL" }, |
| }; |
|
|
| const DEFAULT_SEVERITY = { num: SeverityNumber.INFO, text: "INFO" } as const; |
|
|
| const otelStream: Writable = Object.assign(Object.create(null), { |
| write(chunk: string): boolean { |
| |
| let rec: any; |
| try { |
| rec = JSON.parse(chunk); |
| } catch { |
| return true; |
| } |
| const level = typeof rec.level === "number" ? rec.level : 30; |
| const sev = PINO_LEVEL_TO_OTEL[level] ?? DEFAULT_SEVERITY; |
| const { level: _l, time, msg, pid: _p, hostname: _h, name: _n, ...attributes } = rec; |
| logs.getLogger(SERVICE_NAME).emit({ |
| timestamp: typeof time === "number" ? time : Date.now(), |
| severityNumber: sev.num, |
| severityText: sev.text, |
| body: typeof msg === "string" ? msg : JSON.stringify(msg ?? ""), |
| attributes, |
| }); |
| return true; |
| }, |
| }) as unknown as Writable; |
|
|
| export const logger = pino( |
| { name: SERVICE_NAME }, |
| multistream([ |
| { stream: process.stdout }, |
| { stream: otelStream }, |
| ]), |
| ); |
|
|
