logs.ts

import type { FastifyInstance, FastifyRequest } from "fastify";
import { stringify } from "thirdweb/utils";
import { logger } from "../../shared/utils/logger";
import { ADMIN_QUEUES_BASEPATH } from "./admin-routes";
import { OPENAPI_ROUTES } from "./open-api";

const IGNORE_LOG_PATHS = new Set([
  "/",
  "/favicon.ico",
  "/system/health",
  "/static",
  ...OPENAPI_ROUTES,
]);

const SENSITIVE_LOG_PATHS = new Set([
  "/backend-wallet/import",
  "/configuration/wallets",
  "/backend-wallet/lite/:teamId",
]);

function shouldLog(request: FastifyRequest) {
  if (!request.routeOptions.url) {
    return false;
  }
  if (request.method === "OPTIONS") {
    return false;
  }
  if (
    request.method === "POST" &&
    SENSITIVE_LOG_PATHS.has(request.routeOptions.url)
  ) {
    return false;
  }
  if (IGNORE_LOG_PATHS.has(request.routeOptions.url)) {
    return false;
  }
  if (request.routeOptions.url.startsWith(ADMIN_QUEUES_BASEPATH)) {
    return false;
  }
  return true;
}

export function withRequestLogs(server: FastifyInstance) {
  server.addHook("onSend", async (request, reply, payload) => {
    if (shouldLog(request)) {
      const { method, routeOptions, headers, params, query, body } = request;
      const { statusCode, elapsedTime } = reply;
      const isError = statusCode >= 400;

      const extractedHeaders = {
        "x-backend-wallet-address": headers["x-backend-wallet-address"],
        "x-idempotency-key": headers["x-idempotency-key"],
        "x-account-address": headers["x-account-address"],
        "x-account-factory-address": headers["x-account-factory-address"],
        "x-account-salt": headers["x-account-salt"],
      };

      const paramsStr =
        params && Object.keys(params).length
          ? `params=${stringify(params)}`
          : undefined;
      const queryStr =
        query && Object.keys(query).length
          ? `querystring=${stringify(query)}`
          : undefined;
      const bodyStr =
        body && Object.keys(body).length
          ? `body=${stringify(body)}`
          : undefined;
      const payloadStr = isError ? `payload=${payload}` : undefined;

      logger({
        service: "server",
        level: isError ? "error" : "info",
        message: [
          `[Request complete - ${statusCode}]`,
          `method=${method}`,
          `path=${routeOptions.url}`,
          `headers=${stringify(extractedHeaders)}`,
          paramsStr,
          queryStr,
          bodyStr,
          `duration=${elapsedTime.toFixed(1)}ms`,
          payloadStr,
        ].join(" "),
      });
    }

    return payload;
  });
}