File

src/core/interceptors/logger.interceptor.ts

Description

Logs the requests

Index

Properties
Methods

Methods

intercept
intercept(context: ExecutionContext, next: CallHandler)

intercept handler

Parameters :
Name Type Optional Description
context ExecutionContext No

context

next CallHandler No

next call

Returns : Observable<any>

handler

Private logHttpRequest
logHttpRequest(context: ExecutionContext, startTime: number)

logs the HTTP requests

Parameters :
Name Type Optional Description
context ExecutionContext No

context

startTime number No

start time

Returns : void

nothing

Properties

Private Readonly logger
Type : LoggerService
Default value : new LoggerService(LoggerInterceptor.name)

logs requests for the service

import { CallHandler, ExecutionContext, Injectable, NestInterceptor } from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap } from 'rxjs/operators';
import { Request, Response } from 'express';
import { LoggerService } from '../services/common'
////////////////////////////////////////////////////////////////////////
/**
 * Logs the requests
 */
@Injectable()
export class LoggerInterceptor implements NestInterceptor {
  //==================================================================================================
  /**
   * logs requests for the service
   */
  private readonly logger: LoggerService = new LoggerService(LoggerInterceptor.name);

  //==================================================================================================
  /**
   * intercept handler
   * @param context context
   * @param next next call
   * @returns handler
   */
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const startTime = Date.now();
    const contextType = context.getType();

    return next.handle().pipe(
      tap(
        () => {
          if (contextType === 'http') {
            this.logHttpRequest(context, startTime);
          }
        },
        (error: Error) => {
          if (contextType === 'http') {
            this.logHttpRequest(context, startTime);
          } else {
            const reqTime = Date.now() - startTime;
            this.logger.log(`[${error.name}] ${error.message} ${reqTime}ms`);
          }
        }
      )
    );
  }

  //==================================================================================================
  /**
   * logs the HTTP requests
   * @param context context
   * @param startTime start time
   * @returns nothing
   */
  private logHttpRequest(context: ExecutionContext, startTime: number) {
    if (context.getType() !== 'http') return;
    const reqTime = Date.now() - startTime;
    const controllerName = context.getClass().name;
    const handlerName = context.getHandler().name;
    const request = context.switchToHttp().getRequest<Request>();
    const response = context.switchToHttp().getResponse<Response>();
    const { url, method } = request;
    const { statusCode } = response;
    this.logger.log(
      `[HTTP] ${method.toUpperCase()} ${url} ${statusCode} [${controllerName}:${handlerName}] ${reqTime}ms`
    );
  }
}

results matching ""

    No results matching ""