sample() update examples with new API

Author: kamilmysliwiec

sample/01-cats-app/src/common/interceptors/exception.interceptor.ts

@@ -1,23 +1,23 @@
 import {
-  Injectable,
-  NestInterceptor,
+  CallHandler,
   ExecutionContext,
+  HttpException,
   HttpStatus,
+  Injectable,
+  NestInterceptor,
 } from '@nestjs/common';
-import { HttpException } from '@nestjs/common';
 import { Observable, throwError } from 'rxjs';
 import { catchError } from 'rxjs/operators';
 
 @Injectable()
 export class ErrorsInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
-    return call$.pipe(
-      catchError(err =>
-        throwError(new HttpException('Message', HttpStatus.BAD_GATEWAY)),
-      ),
-    );
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    return next
+      .handle()
+      .pipe(
+        catchError(err =>
+          throwError(new HttpException('New message', HttpStatus.BAD_GATEWAY)),
+        ),
+      );
   }
 }

sample/01-cats-app/src/common/interceptors/logging.interceptor.ts

@@ -1,16 +1,20 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { tap } from 'rxjs/operators';
 
 @Injectable()
 export class LoggingInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
     console.log('Before...');
 
     const now = Date.now();
-    return call$.pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
+    return next
+      .handle()
+      .pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
   }
 }

sample/01-cats-app/src/common/interceptors/timeout.interceptor.ts

@@ -1,13 +1,15 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { timeout } from 'rxjs/operators';
 
 @Injectable()
 export class TimeoutInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
-    return call$.pipe(timeout(5000));
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    return next.handle().pipe(timeout(5000));
   }
 }

sample/01-cats-app/src/common/interceptors/transform.interceptor.ts

@@ -1,4 +1,9 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { map } from 'rxjs/operators';
 
@@ -11,8 +16,8 @@ export class TransformInterceptor<T>
   implements NestInterceptor<T, Response<T>> {
   intercept(
     context: ExecutionContext,
-    call$: Observable<T>,
+    next: CallHandler<T>,
   ): Observable<Response<T>> {
-    return call$.pipe(map(data => ({ data })));
+    return next.handle().pipe(map(data => ({ data })));
   }
 }

sample/03-microservices/src/common/interceptors/logging.interceptor.ts

@@ -1,16 +1,20 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { tap } from 'rxjs/operators';
 
 @Injectable()
 export class LoggingInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
     console.log('Before...');
 
     const now = Date.now();
-    return call$.pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
+    return next
+      .handle()
+      .pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
   }
 }

sample/10-fastify/src/common/interceptors/exception.interceptor.ts

@@ -1,28 +1,28 @@
 import {
-  Injectable,
-  NestInterceptor,
+  CallHandler,
   ExecutionContext,
+  HttpException,
   HttpStatus,
+  Injectable,
+  NestInterceptor,
 } from '@nestjs/common';
-import { HttpException } from '@nestjs/common';
 import { Observable, throwError } from 'rxjs';
 import { catchError } from 'rxjs/operators';
 
 @Injectable()
 export class ExceptionInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
-    return call$.pipe(
-      catchError(err =>
-        throwError(
-          new HttpException(
-            'Exception interceptor message',
-            HttpStatus.BAD_GATEWAY,
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    return next
+      .handle()
+      .pipe(
+        catchError(err =>
+          throwError(
+            new HttpException(
+              'Exception interceptor message',
+              HttpStatus.BAD_GATEWAY,
+            ),
           ),
         ),
-      ),
-    );
+      );
   }
 }

sample/10-fastify/src/common/interceptors/logging.interceptor.ts

@@ -1,16 +1,20 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { tap } from 'rxjs/operators';
 
 @Injectable()
 export class LoggingInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
     console.log('Before...');
 
     const now = Date.now();
-    return call$.pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
+    return next
+      .handle()
+      .pipe(tap(() => console.log(`After... ${Date.now() - now}ms`)));
   }
 }

sample/10-fastify/src/common/interceptors/transform.interceptor.ts

@@ -1,13 +1,15 @@
-import { Injectable, NestInterceptor, ExecutionContext } from '@nestjs/common';
+import {
+  CallHandler,
+  ExecutionContext,
+  Injectable,
+  NestInterceptor,
+} from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { map } from 'rxjs/operators';
 
 @Injectable()
 export class TransformInterceptor implements NestInterceptor {
-  intercept(
-    context: ExecutionContext,
-    call$: Observable<any>,
-  ): Observable<any> {
-    return call$.pipe(map(data => ({ data })));
+  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
+    return next.handle().pipe(map(data => ({ data })));
   }
 }