Análisis de eventos estructurados de Pino

import pino from "pino";

const logger = pino();

async function recordOutcome(data) {
  try {
    const receipt = await fetch("https://api.telemetry.sh/log", {
      method: "POST",
      headers: {
        Authorization: process.env.TELEMETRY_API_KEY,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ table: "api_request_completed", data }),
      signal: AbortSignal.timeout(2_000),
    });
    if (!receipt.ok) console.warn("Telemetry ingestion failed", receipt.status);
  } catch {
    console.warn("Telemetry ingestion unavailable");
  }
}
const startedAt = performance.now();

try {
  const result = await runCheckout();
  const outcome = {
    request_id: requestId,
    route_template: "/api/checkout",
    method: "POST",
    status_code: 200,
    status: "success",
    latency_ms: Math.round(performance.now() - startedAt),
    release: process.env.APP_RELEASE,
  };

  logger.info(outcome, "checkout completed");
  await recordOutcome(outcome);
  return result;
} catch (error) {
  const outcome = {
    request_id: requestId,
    route_template: "/api/checkout",
    method: "POST",
    status_code: 500,
    status: "failed",
    latency_ms: Math.round(performance.now() - startedAt),
    error_type: classifyError(error),
    release: process.env.APP_RELEASE,
  };

  logger.error({ ...outcome, err: error }, "checkout failed");
  await recordOutcome(outcome);
  throw error;
}