add abstract

Author: liujia02

package.json

@@ -12,29 +12,30 @@
     "url": "git+https://github.com/marsprince/nest-log4js"
   },
   "dependencies": {
+    "circular-json-es6": "^2.0.2",
     "log4js": "^3.0.5"
   },
   "devDependencies": {
-    "reflect-metadata": "^0.1.12",
-    "rxjs": "^6.0.0",
-    "typescript": "^2.6.2",
     "@nestjs/common": "^5.0.0",
     "@nestjs/core": "^5.0.0",
-    "fastify-formbody": "^2.0.0",
     "@nestjs/testing": "^5.0.0",
     "@types/express": "^4.0.39",
     "@types/jest": "^21.1.8",
     "@types/node": "^9.3.0",
     "@types/supertest": "^2.0.4",
+    "fastify-formbody": "^2.0.0",
     "jest": "^21.2.1",
     "nodemon": "^1.14.1",
     "prettier": "^1.11.1",
+    "reflect-metadata": "^0.1.12",
+    "rxjs": "^6.0.0",
     "supertest": "^3.0.0",
     "ts-jest": "^21.2.4",
     "ts-loader": "^4.1.0",
     "ts-node": "^4.1.0",
     "tsconfig-paths": "^3.1.1",
-    "tslint": "5.3.2"
+    "tslint": "5.3.2",
+    "typescript": "^2.6.2"
   },
   "jest": {
     "moduleFileExtensions": [

src/index.ts

@@ -1,5 +1,6 @@
 export * from './log4js.constant';
 export * from './log4js.filter';
+export * from './log4js.interceptor.abstract';
 export * from './log4js.interceptor';
 export * from './log4js.module';
 export * from './log4js.provider';

src/log4js.interceptor.abstract.ts

@@ -0,0 +1,29 @@
+import { NestInterceptor, ExecutionContext } from '@nestjs/common';
+import { Observable } from 'rxjs';
+import { tap } from 'rxjs/operators';
+import { Logger } from 'log4js';
+
+export abstract class Log4jsInterceptorAbstract implements NestInterceptor {
+  protected constructor(
+    protected requestLogger: Logger,
+    protected responseLogger: Logger,
+  ) {
+  }
+
+  intercept(
+    context: ExecutionContext,
+    call$: Observable<any>,
+  ): Observable<any> {
+    const httpRequest = context.switchToHttp().getRequest();
+    this.requestLogger.info(this.requestFormat(httpRequest));
+    return call$.pipe(
+      tap(httpResponse => {
+        this.responseLogger.info(this.responseFormat(httpResponse));
+      }),
+    );
+  }
+
+  abstract requestFormat<T>(httpRequest: T): string;
+
+  abstract responseFormat<T>(httpResponse: T): string;
+}

src/log4js.interceptor.ts

@@ -1,27 +1,40 @@
-import { Injectable, NestInterceptor, ExecutionContext, Inject } from '@nestjs/common';
+import { Injectable, ExecutionContext, Inject } from '@nestjs/common';
 import { Observable } from 'rxjs';
-import { tap, catchError } from 'rxjs/operators';
 import { LOG4JS_REQUEST_LOGGER, LOG4JS_RESPONSE_LOGGER } from './log4js.constant';
 import { Logger } from 'log4js';
+import { Log4jsInterceptorAbstract } from './log4js.interceptor.abstract';
+import { stringify } from 'circular-json-es6';
 
 @Injectable()
-export class Log4jsInterceptor implements NestInterceptor {
+export class Log4jsInterceptor extends Log4jsInterceptorAbstract {
   constructor(
-    @Inject(LOG4JS_REQUEST_LOGGER) private requestLogger: Logger,
-    @Inject(LOG4JS_RESPONSE_LOGGER) private responseLogger: Logger,
+    @Inject(LOG4JS_REQUEST_LOGGER) protected requestLogger: Logger,
+    @Inject(LOG4JS_RESPONSE_LOGGER) protected responseLogger: Logger,
   ) {
+    super(responseLogger, responseLogger);
   }
 
   intercept(
     context: ExecutionContext,
     call$: Observable<any>,
   ): Observable<any> {
-    const httpRequest = context.switchToHttp().getRequest();
-    this.requestLogger.info(httpRequest);
-    return call$.pipe(
-      tap(httpResponse => {
-        this.responseLogger.info(httpResponse);
-      }),
-    );
+    return super.intercept(context, call$);
+  }
+
+  requestFormat(httpRequest: any): string {
+    return stringify({
+      url: httpRequest.url,
+      method: httpRequest.method,
+      params: httpRequest.params,
+      query: httpRequest.query,
+      body: httpRequest.body,
+      httpVersion: httpRequest.httpVersion,
+      headers: httpRequest.headers,
+      route: httpRequest.route,
+    });
+  }
+
+  responseFormat(httpResponse: any): string {
+    return stringify(httpResponse);
   }
 }