OmniRoute/src/sse/utils/logger.ts

/**
 * SSE Logger — Thin wrapper around the shared Pino logger
 * for backward compatibility with existing SSE code.
 *
 * Migrated from direct console logging to structured Pino logging.
 */
import { createLogger } from "@/shared/utils/logger";

const log = createLogger("sse");

export function debug(tag: string, message: string, data?: unknown) {
  log.debug({ tag, ...spreadData(data) }, message);
}

export function info(tag: string, message: string, data?: unknown) {
  log.info({ tag, ...spreadData(data) }, message);
}

export function warn(tag: string, message: string, data?: unknown) {
  log.warn({ tag, ...spreadData(data) }, message);
}

export function error(tag: string, message: string, data?: unknown) {
  log.error({ tag, ...spreadData(data) }, message);
}

export function request(method: string, path: string, extra?: unknown) {
  log.info({ tag: "HTTP", method, path, ...spreadData(extra) }, `📥 ${method} ${path}`);
}

// Helper to spread data into structured fields
function spreadData(data: unknown): Record<string, unknown> {
  if (!data) return {};
  if (typeof data === "string") return { detail: data };
  if (typeof data === "object") return data as Record<string, unknown>;
  return { detail: String(data) };
}