Merge pull request #216 from johanbook/unexpected-exception-logger

Add logger for unexpected exceptions in comands and events

services/api/package.json

@@ -26,7 +26,7 @@
     "@fastify/static": "^6.10.0",
     "@nestjs/common": "^9.0.0",
     "@nestjs/core": "^9.0.0",
-    "@nestjs/cqrs": "^9.0.3",
+    "@nestjs/cqrs": "^10.0.3",
     "@nestjs/platform-express": "^9.0.0",
     "@nestjs/platform-fastify": "^9.4.0",
     "@nestjs/platform-socket.io": "^9.4.0",

services/api/src/core/logging/logging.module.ts

@@ -3,11 +3,12 @@ import { CqrsModule } from "@nestjs/cqrs";
 
 import { CommandLogger } from "./command.logger";
 import { EventLogger } from "./event.logger";
+import { UnhandledExceptionLogger } from "./unhandled-exception.logger";
 
 @Module({
   exports: [],
   imports: [CqrsModule],
   controllers: [],
-  providers: [CommandLogger, EventLogger],
+  providers: [CommandLogger, EventLogger, UnhandledExceptionLogger],
 })
 export class LoggingModule {}

services/api/src/core/logging/unhandled-exception.logger.ts

@@ -0,0 +1,19 @@
+import { Injectable } from "@nestjs/common";
+import { UnhandledExceptionBus } from "@nestjs/cqrs";
+
+import { Logger } from "./domain/services/logger.service";
+
+@Injectable()
+export class UnhandledExceptionLogger {
+  private logger = new Logger(UnhandledExceptionLogger.name);
+
+  constructor(private readonly unhandledExceptionBus: UnhandledExceptionBus) {
+    this.unhandledExceptionBus.subscribe((exceptionInfo) => {
+      this.logger.error({
+        cause: exceptionInfo.cause,
+        error: exceptionInfo.exception,
+        msg: `Encountered unhandled exception ${exceptionInfo.exception.message}`,
+      });
+    });
+  }
+}