better logging

This commit is contained in:
Emily
2024-09-23 14:03:37 +02:00
parent cf1aa103e4
commit 3b6a202538
3 changed files with 21 additions and 7 deletions

View File

@@ -4,12 +4,13 @@ import winston from 'winston';
const { combine, timestamp, json, errors } = winston.format; const { combine, timestamp, json, errors } = winston.format;
const timestampFormat = () => { return new Date().toLocaleString('it-IT', { timeZone: 'Europe/Rome' }); }
export const logger = winston.createLogger({ export const logger = winston.createLogger({
format: combine( format: combine(
errors({ stack: true }), errors({ stack: true }),
timestamp({ timestamp({
format: 'DD-MM-YYYY hh:mm:ss' format: timestampFormat
}), }),
json() json()
), ),
@@ -27,7 +28,7 @@ export const logger = winston.createLogger({
format: combine( format: combine(
winston.format.colorize({ all: true }), winston.format.colorize({ all: true }),
errors({ stack: true }), errors({ stack: true }),
timestamp({ format: 'DD-MM-YYYY hh:mm:ss' }), timestamp({ format: timestampFormat }),
winston.format.printf((info) => { winston.format.printf((info) => {
if (info instanceof Error) { if (info instanceof Error) {
return `${info.timestamp} [${info.level}]: ${info.message}\n${info.stack}`; return `${info.timestamp} [${info.level}]: ${info.message}\n${info.stack}`;

View File

@@ -2,7 +2,6 @@ import mongoose from "mongoose";
import { Redis } from "~/server/services/CacheService"; import { Redis } from "~/server/services/CacheService";
import EmailService from '@services/EmailService'; import EmailService from '@services/EmailService';
import StripeService from '~/server/services/StripeService'; import StripeService from '~/server/services/StripeService';
import { anomalyLoop } from "./services/AnomalyService";
import { logger } from "./Logger"; import { logger } from "./Logger";

View File

@@ -6,7 +6,21 @@ export default defineEventHandler(async (event) => {
const ip = getRequestAddress(event); const ip = getRequestAddress(event);
const user = getRequestUser(event); const user = getRequestUser(event);
event.node.res.on('finish', () => { let payload: any | undefined;
const headers = getHeaders(event);
const xHeaders = Object.keys(headers)
.filter(e => e.startsWith('x-') && !e.startsWith("x-forwarded"))
.map(e => ({ [e]: headers[e] }));
if (event.method === 'POST' || event.method === 'DELETE') {
payload = await readBody(event)
}
event.node.res.on('finish', async () => {
if (!event.context['performance-start']) return; if (!event.context['performance-start']) return;
const start = parseInt(event.context['performance-start']); const start = parseInt(event.context['performance-start']);
if (isNaN(start)) return; if (isNaN(start)) return;
@@ -15,11 +29,11 @@ export default defineEventHandler(async (event) => {
const duration = (end - start); const duration = (end - start);
if (!user) { if (!user) {
logger.debug('Request without user', { path: event.path, method: event.method, ip, duration }); logger.debug('Request without user', { path: event.path, method: event.method, ip, duration, xHeaders, payload });
} else if (!user.logged) { } else if (!user.logged) {
logger.debug('Request as guest', { path: event.path, method: event.method, ip, duration }); logger.debug('Request as guest', { path: event.path, method: event.method, ip, duration, xHeaders, payload });
} else { } else {
logger.debug(`(${duration}ms) [${event.method}] ${event.path} { ${user.user.email} }`, { ip }); logger.debug(`(${duration}ms) [${event.method}] ${event.path} { ${user.user.email} }`, { ip, duration, xHeaders, payload });
} }
// event.node.res.setHeader('X-Total-Response-Time', `${duration.toFixed(2)} ms`); // event.node.res.setHeader('X-Total-Response-Time', `${duration.toFixed(2)} ms`);