Create grpc-to-http-interceptor.spec.ts test file

Author: youngkiu

test/interceptors/grpc-to-http-interceptor.spec.ts

@@ -1,4 +1,4 @@
-import { HttpException } from "@nestjs/common";
+import { HttpException, HttpStatus } from "@nestjs/common";
 import { Observable, throwError } from "rxjs";
 import { GrpcNotFoundException, GrpcToHttpInterceptor } from "../../lib";
 
@@ -48,7 +48,7 @@ describe("GrpcToHttpInterceptor", () => {
     intercept$.subscribe({
       error: (err) => {
         expect(err).toBeInstanceOf(HttpException);
-        expect(err.status).toEqual(404);
+        expect(err.status).toEqual(HttpStatus.NOT_FOUND);
         done();
       },
       complete: () => done(),

test/interceptors/http-to-grpc-interceptor.spec.ts

@@ -0,0 +1,74 @@
+import { NotFoundException } from "@nestjs/common";
+import { Observable, throwError } from "rxjs";
+import { HttpToGrpcInterceptor } from "../../lib";
+import { RpcException } from "@nestjs/microservices";
+import { status as GrpcStatusCode } from "@grpc/grpc-js";
+
+const throwMockException = (
+  Exception: new (...args: any[]) => any,
+): Observable<any> => {
+  const exception = new Exception(Exception.name);
+  return throwError(
+    () =>
+      new RpcException({
+        message: exception.message,
+        code: GrpcStatusCode.NOT_FOUND,
+      }),
+  );
+};
+
+describe("HttpToGrpcInterceptor", () => {
+  let interceptor: HttpToGrpcInterceptor;
+
+  beforeAll(() => {
+    interceptor = new HttpToGrpcInterceptor();
+  });
+
+  it("Should be defined", () => {
+    expect(interceptor).toBeDefined();
+  });
+
+  it("Should convert HTTP exceptions to gRPC exceptions", (done) => {
+    const intercept$ = interceptor.intercept({} as any, {
+      handle: () => throwMockException(NotFoundException),
+    }) as Observable<any>;
+
+    intercept$.subscribe({
+      error: (err) => {
+        expect(err).toBeInstanceOf(RpcException);
+        done();
+      },
+      complete: () => done(),
+    });
+  });
+
+  it("Should convert HTTP exceptions to gRPC exceptions", (done) => {
+    const intercept$ = interceptor.intercept({} as any, {
+      handle: () => throwMockException(NotFoundException),
+    }) as Observable<any>;
+
+    intercept$.subscribe({
+      error: (err) => {
+        expect(err).toBeInstanceOf(RpcException);
+        expect(err.error.code).toEqual(GrpcStatusCode.NOT_FOUND);
+        done();
+      },
+      complete: () => done(),
+    });
+  });
+
+  it("Should contain the HTTP exception error message", (done) => {
+    const intercept$ = interceptor.intercept({} as any, {
+      handle: () => throwMockException(NotFoundException),
+    }) as Observable<any>;
+
+    intercept$.subscribe({
+      error: (err) => {
+        expect(err).toBeInstanceOf(RpcException);
+        expect(err.message).toEqual(NotFoundException.name);
+        done();
+      },
+      complete: () => done(),
+    });
+  });
+});