Error handling - exception filters

packages/apps/human-app/server/src/common/filter/global-exceptions.filter.ts

@@ -0,0 +1,28 @@
+import {
+  ArgumentsHost,
+  Catch,
+  ExceptionFilter,
+  HttpException,
+  HttpStatus,
+} from '@nestjs/common';
+
+@Catch()
+export class GlobalExceptionsFilter implements ExceptionFilter {
+  catch(exception: any, host: ArgumentsHost) {
+    const ctx = host.switchToHttp();
+    const response = ctx.getResponse();
+
+    let status = HttpStatus.INTERNAL_SERVER_ERROR;
+    let message: any = 'Internal Server Error';
+
+    if (exception instanceof HttpException) {
+      status = exception.getStatus();
+      message = exception.getResponse();
+    } else if (exception.response) {
+      status = exception.response.data.statusCode;
+      message = exception.response.data.message;
+    }
+
+    response.status(status).json(message);
+  }
+}

packages/apps/human-app/server/src/integrations/reputation-oracle/reputation-oracle.gateway.ts

@@ -1,4 +1,4 @@
-import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
+import { Injectable } from '@nestjs/common';
 import { HttpService } from '@nestjs/axios';
 import { lastValueFrom } from 'rxjs';
 import { InjectMapper } from '@automapper/nestjs';
@@ -16,12 +16,11 @@ import { GatewayConfig } from '../../common/interfaces/endpoint.interface';
 import { ExternalApiName } from '../../common/enums/external-api-name';
 import { EndpointName } from '../../common/enums/endpoint-name';
 import { AxiosRequestConfig } from 'axios';
-import {
-  RequestDataType
-} from './reputation-oracle.interface';
+import { RequestDataType } from './reputation-oracle.interface';
 import {
   SigninWorkerCommand,
-  SigninWorkerData, SigninWorkerResponse,
+  SigninWorkerData,
+  SigninWorkerResponse,
 } from '../../modules/user-worker/interfaces/worker-signin.interface';
 
 @Injectable()
@@ -57,14 +56,7 @@ export class ReputationOracleGateway {
       const response = await lastValueFrom(this.httpService.request(options));
       return response.data;
     } catch (error) {
-      if (error.response) {
-        throw new HttpException(error.response.data, error.response.status);
-      } else {
-        throw new HttpException(
-          'Error occurred while redirecting request.',
-          HttpStatus.INTERNAL_SERVER_ERROR,
-        );
-      }
+      throw error;
     }
   }
   async sendWorkerSignup(command: SignupWorkerCommand): Promise<void> {

packages/apps/human-app/server/src/main.ts

@@ -4,6 +4,7 @@ import { DocumentBuilder, SwaggerModule } from '@nestjs/swagger';
 import { ConfigService } from '@nestjs/config';
 import { Logger } from '@nestjs/common';
 import { EnvironmentConfigService } from './common/config/environment-config.service';
+import { GlobalExceptionsFilter } from './common/filter/global-exceptions.filter';
 
 async function bootstrap() {
   const logger = new Logger('bootstrap');
@@ -24,6 +25,8 @@ async function bootstrap() {
   const host = envConfigService.host;
   const port = envConfigService.port;
 
+  app.useGlobalFilters(new GlobalExceptionsFilter());
+
   await app.listen(port, host, async () => {
     logger.log(`Human APP server is running on http://${host}:${port}`);
   });