Add GRPC_CODE_FROM_HTTP map

Author: youngkiu

lib/utils/grpc-codes-map.ts

@@ -0,0 +1,20 @@
+import { status as Status } from "@grpc/grpc-js";
+import { HttpStatus } from "@nestjs/common";
+
+// https://github.com/nestjs/nest/blob/master/packages/common/enums/http-status.enum.ts
+export const GRPC_CODE_FROM_HTTP: Record<number, number> = {
+  [HttpStatus.OK]: Status.OK,
+  [HttpStatus.BAD_GATEWAY]: Status.UNKNOWN,
+  [HttpStatus.UNPROCESSABLE_ENTITY]: Status.INVALID_ARGUMENT,
+  [HttpStatus.REQUEST_TIMEOUT]: Status.DEADLINE_EXCEEDED,
+  [HttpStatus.NOT_FOUND]: Status.NOT_FOUND,
+  [HttpStatus.CONFLICT]: Status.ALREADY_EXISTS,
+  [HttpStatus.FORBIDDEN]: Status.PERMISSION_DENIED,
+  [HttpStatus.TOO_MANY_REQUESTS]: Status.RESOURCE_EXHAUSTED,
+  [HttpStatus.PRECONDITION_REQUIRED]: Status.FAILED_PRECONDITION,
+  [HttpStatus.METHOD_NOT_ALLOWED]: Status.ABORTED,
+  [HttpStatus.PAYLOAD_TOO_LARGE]: Status.OUT_OF_RANGE,
+  [HttpStatus.NOT_IMPLEMENTED]: Status.UNIMPLEMENTED,
+  [HttpStatus.INTERNAL_SERVER_ERROR]: Status.INTERNAL,
+  [HttpStatus.UNAUTHORIZED]: Status.UNAUTHENTICATED,
+};

lib/utils/index.ts

@@ -1,3 +1,4 @@
 export * from "./error-object";
 export * from "./http-codes-map";
 export * from "./grpc-exceptions-map";
+export * from "./grpc-codes-map";

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

@@ -3,6 +3,7 @@ import { Observable, throwError } from "rxjs";
 import { HttpToGrpcInterceptor } from "../../lib";
 import { RpcException } from "@nestjs/microservices";
 import { status as GrpcStatusCode } from "@grpc/grpc-js";
+import { GRPC_CODE_FROM_HTTP } from "../../lib/utils";
 
 const throwMockException = (
   Exception: new (...args: any[]) => any,
@@ -12,7 +13,7 @@ const throwMockException = (
     () =>
       new RpcException({
         message: exception.message,
-        code: GrpcStatusCode.NOT_FOUND,
+        code: GRPC_CODE_FROM_HTTP[exception.status],
       }),
   );
 };