chore: Implement custom logger logic for errors (#632)

Logger.error will now send the error message to sentry

Author: sashko9807

apps/api/src/app/app.module.ts

@@ -60,6 +60,8 @@ import { MarketingNotificationsModule } from '../notifications/notifications.mod
 import { StatisticsModule } from '../statistics/statistics.module'
 import { AffiliateModule } from '../affiliate/affiliate.module'
 
+import { LoggerModule } from '../logger/logger.module'
+
 @Module({
   imports: [
     ConfigModule.forRoot({ validationSchema, isGlobal: true, load: [configuration] }),
@@ -123,6 +125,7 @@ import { AffiliateModule } from '../affiliate/affiliate.module'
     CampaignNewsModule,
     CampaignNewsFileModule,
     MarketingNotificationsModule,
+    LoggerModule,
   ],
   controllers: [AppController],
   providers: [

apps/api/src/logger/logger.module.ts

@@ -0,0 +1,8 @@
+import { Module } from '@nestjs/common'
+import { MyLogger } from './logger'
+
+@Module({
+  providers: [MyLogger],
+  exports: [MyLogger],
+})
+export class LoggerModule {}

apps/api/src/logger/logger.ts

@@ -0,0 +1,16 @@
+import { ConsoleLogger, Injectable } from '@nestjs/common'
+import { InjectSentry, SentryService } from '@ntegral/nestjs-sentry'
+
+@Injectable()
+export class MyLogger extends ConsoleLogger {
+  constructor(@InjectSentry() private readonly client: SentryService) {
+    super()
+  }
+
+  error(message: any, stack?: string, context?: string) {
+    // add your tailored logic here
+
+    this.client.instance().captureMessage(message, 'error')
+    super.error(message, stack, context)
+  }
+}

apps/api/src/main.ts

@@ -8,6 +8,8 @@ import { setupSwagger } from './config/swagger.config'
 import { setupExceptions } from './config/exceptions.config'
 import { setupValidation } from './config/validation.config'
 import { setupShutdownHooks } from './config/shutdown.config'
+import { MyLogger } from './logger/logger'
+import { LoggerModule } from './logger/logger.module'
 
 const globalPrefix = process.env.GLOBAL_PREFIX ?? 'api/v1'
 const logLevels: LogLevel[] = ['error', 'warn']
@@ -26,6 +28,7 @@ async function bootstrap() {
 
   app.setGlobalPrefix(globalPrefix)
   app.enableVersioning({ type: VersioningType.URI })
+  app.useLogger(app.get(MyLogger))
 
   const appVersion = process.env.APP_VERSION || 'unknown'
   setupHelmet(app)

apps/api/src/tasks/bank-import/import-transactions.task.ts

@@ -199,8 +199,7 @@ export class IrisTasks {
       // No transactions for the day yet
       if (!transactions.length) return
     } catch (e) {
-      Logger.error(e.message)
-      throw new BadRequestException('Failed to get transactions data from Iris' + e.message)
+      return Logger.error('Failed to get transactions data from Iris' + e.message)
     }
 
     // 3. Prepare the BankTransaction Records