Added the interceptors [netology-code#10]

010-nestjs-validation/src/books/books.controller.ts

@@ -14,6 +14,7 @@ import { CreateBookDto } from './dto/create-book.dto';
 import { UpdateBookDto } from './dto/update-book.dto';
 import { BooksService } from './books.service';
 import { Book } from './schemas/book.schema';
+import { throwError } from 'rxjs';
 
 @Controller('books')
 export class BooksController {
@@ -29,6 +30,7 @@ export class BooksController {
 
   @Get(':id')
   getById(@Param('id') id: string): Promise<Book> {
+    // return Promise.reject();
     return this.BooksService.getById(id)
   }
 

010-nestjs-validation/src/interceptors/index.ts

@@ -0,0 +1,2 @@
+export { LoggingInterceptor } from './logging.interceptor';
+export { ResponseInterceptor } from './response.interceptor';

010-nestjs-validation/src/interceptors/logging.interceptor.ts

@@ -0,0 +1,19 @@
+import { Injectable, NestInterceptor, ExecutionContext, CallHandler, HttpException, HttpStatus } from '@nestjs/common';
+import { HttpArgumentsHost } from '@nestjs/common/interfaces';
+import { Observable, throwError } from 'rxjs';
+import { tap, catchError } from 'rxjs/operators';
+
+@Injectable()
+export class LoggingInterceptor implements NestInterceptor {
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    console.log('Before...');
+    const httpCtx: HttpArgumentsHost = context.switchToHttp();
+    const req = httpCtx.getRequest();
+    console.log('%clogging.interceptor.ts line:13 req', 'color: #007acc;', req.params);
+    const now: number = Date.now();
+
+    return next
+      .handle()
+      .pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
+  }
+}

010-nestjs-validation/src/interceptors/response.interceptor.ts

@@ -0,0 +1,14 @@
+import { Injectable, NestInterceptor, ExecutionContext, CallHandler, BadGatewayException } from '@nestjs/common';
+import { Observable, throwError } from 'rxjs';
+import { map, catchError } from 'rxjs/operators';
+
+@Injectable()
+export class ResponseInterceptor implements NestInterceptor {
+  intercept(context: ExecutionContext, next: CallHandler):  Observable<any> {
+    return next.handle().pipe(
+    map(data => ({ status: "success", data })), 
+    catchError((err: any) => {
+        return throwError(new BadGatewayException({data: err || 'error', status: "fail"}));
+    }));
+  }
+}

010-nestjs-validation/src/main.ts

@@ -1,8 +1,11 @@
 import { NestFactory } from '@nestjs/core';
 import { AppModule } from './app.module';
+import { LoggingInterceptor } from './interceptors/logging.interceptor';
+import { ResponseInterceptor } from './interceptors/response.interceptor';
 
 async function bootstrap() {
-  const app = await NestFactory.create(AppModule);
-  await app.listen(3000);
+    const app = await NestFactory.create(AppModule);
+    app.useGlobalInterceptors(new LoggingInterceptor(), new ResponseInterceptor())
+    await app.listen(3000);
 }
 bootstrap();