removes integrated setup in favor of more modular independent blocks

Author: gm50x

src/index.ts

@@ -1,4 +1,7 @@
 export * from './logger/anonymizer';
+export * from './logger/http-inspector-inbound.middleware';
+export * from './logger/http-inspector-outbound.interceptor';
+export * from './logger/log-exception.filter';
 export * from './logger/logger.config';
 
 export * from './utils/compression.config';

src/logger/http-inspector-inbound.middleware.ts

@@ -4,6 +4,7 @@ import {
   Logger,
   NestMiddleware,
 } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
 import { NextFunction, Request, Response } from 'express';
 
 @Injectable()
@@ -68,9 +69,16 @@ class HttpInspectorInboundMiddleware implements NestMiddleware {
   }
 }
 
-export const configureHttpInspectorInbound = (app: INestApplication) => {
+export const configureHttpInspectorInbound = () => (app: INestApplication) => {
+  const configService = app.get(ConfigService);
+  const httpInspection = configService.get('INSPECT_HTTP_TRAFFIC', 'all');
+  if (!['all', 'inbound'].includes(httpInspection)) {
+    return;
+  }
+
   const inspector = new HttpInspectorInboundMiddleware();
   const middleware = inspector.use.bind(inspector);
+
   Object.defineProperty(middleware, 'name', {
     value: HttpInspectorInboundMiddleware.name,
   });

src/logger/http-inspector-outbound.interceptor.ts

@@ -1,4 +1,5 @@
 import { INestApplication, Logger } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
 import * as http from 'http';
 import * as https from 'https';
 import { logRequestError, logResponse } from './http-inspector.utils';
@@ -72,7 +73,13 @@ function mountInterceptor(logger: Logger, module: typeof http | typeof https) {
   }
 }
 
-export const configureHttpInspectorOutbound = (app: INestApplication) => {
+export const configureHttpInspectorOutbound = () => (app: INestApplication) => {
+  const configService = app.get(ConfigService);
+  const httpInspection = configService.get('INSPECT_HTTP_TRAFFIC', 'all');
+  if (!['all', 'outbound'].includes(httpInspection)) {
+    return;
+  }
+
   const logger = new Logger('OutboundHTTPInspection');
   for (const module of [http, https]) {
     mountInterceptor(logger, module);

src/logger/log-exception.filter.ts

@@ -52,8 +52,9 @@ class LogExceptionFilter
   }
 }
 
-export const configureExceptionLogger = (app: INestApplication) => {
+export const configureExceptionLogger = () => (app: INestApplication) => {
   const httpAdapter = app.get(HttpAdapterHost);
   app.useGlobalFilters(new LogExceptionFilter(httpAdapter));
+  Logger.log('Log exceptions handler initialized', '@gedai/common/config');
   return app;
 };

src/logger/logger.config.ts

@@ -8,9 +8,6 @@ import {
 } from 'nest-winston';
 import { config, format, transports } from 'winston';
 import { Anonymizer, RegExpAnonymizer } from './anonymizer';
-import { configureHttpInspectorInbound } from './http-inspector-inbound.middleware';
-import { configureHttpInspectorOutbound } from './http-inspector-outbound.interceptor';
-import { configureExceptionLogger } from './log-exception.filter';
 
 let contextService: ContextService;
 let anonymizer: Anonymizer;
@@ -118,7 +115,6 @@ export const configureLogger =
     const _env = configService.get('NODE_ENV', 'production');
     const appName = configService.get('SERVICE_NAME', 'nest-app');
     const logLevel = configService.get('LOG_LEVEL', 'info');
-    const httpInspection = configService.get('INSPECT_HTTP_TRAFFIC', 'all');
     const logFormat = configService.get('LOG_FORMAT', 'json');
     const usePrettyFormat = logFormat === 'pretty';
 
@@ -133,13 +129,6 @@ export const configureLogger =
     };
     const logger = WinstonModule.createLogger(loggerConfig);
     app.useLogger(logger);
-    configureExceptionLogger(app);
-    if (['all', 'inbound'].includes(httpInspection)) {
-      configureHttpInspectorInbound(app);
-    }
-    if (['all', 'outbound'].includes(httpInspection)) {
-      configureHttpInspectorOutbound(app);
-    }
-    Logger.log('Logger initialized', '@gedai/common');
+    Logger.log('Logger initialized', '@gedai/common/config');
     return app;
   };