feat: in case of any error, avoid crashing the worker

Author: nevo-david

apps/workers/src/app/app.module.ts

@@ -1,6 +1,5 @@
 import { Module } from '@nestjs/common';
 
-import { StarsController } from './stars.controller';
 import { DatabaseModule } from '@gitroom/nestjs-libraries/database/prisma/database.module';
 import { TrendingService } from '@gitroom/nestjs-libraries/services/trending.service';
 import { PostsController } from '@gitroom/workers/app/posts.controller';
@@ -10,7 +9,6 @@ import { PlugsController } from '@gitroom/workers/app/plugs.controller';
 @Module({
   imports: [DatabaseModule, BullMqModule],
   controllers: [
-    ...(!process.env.IS_GENERAL ? [StarsController] : []),
     PostsController,
     PlugsController,
   ],

apps/workers/src/app/plugs.controller.ts

@@ -14,7 +14,14 @@ export class PlugsController {
     totalRuns: number;
     currentRun: number;
   }) {
-    return this._integrationService.processPlugs(data);
+    try {
+      return await this._integrationService.processPlugs(data);
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the plugs worker",
+        err
+      );
+    }
   }
 
   @EventPattern('internal-plugs', Transport.REDIS)
@@ -27,6 +34,13 @@ export class PlugsController {
     delay: number;
     information: any;
   }) {
-    return this._integrationService.processInternalPlug(data);
+    try {
+      return await this._integrationService.processInternalPlug(data);
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the internal plugs worker",
+        err
+      );
+    }
   }
 }

apps/workers/src/app/posts.controller.ts

@@ -18,31 +18,59 @@ export class PostsController {
     try {
       return await this._postsService.post(data.id);
     } catch (err) {
-      console.log('Unhandled error, let\'s avoid crashing the worker', err);
+      console.log("Unhandled error, let's avoid crashing the post worker", err);
     }
   }
 
   @EventPattern('submit', Transport.REDIS)
   async payout(data: { id: string; releaseURL: string }) {
-    return this._postsService.payout(data.id, data.releaseURL);
+    try {
+      return await this._postsService.payout(data.id, data.releaseURL);
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the submit worker",
+        err
+      );
+    }
   }
 
   @EventPattern('sendDigestEmail', Transport.REDIS)
   async sendDigestEmail(data: { subject: string; org: string; since: string }) {
-    return this._postsService.sendDigestEmail(
-      data.subject,
-      data.org,
-      data.since
-    );
+    try {
+      return await this._postsService.sendDigestEmail(
+        data.subject,
+        data.org,
+        data.since
+      );
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the digest worker",
+        err
+      );
+    }
   }
 
   @EventPattern('webhooks', Transport.REDIS)
   async webhooks(data: { org: string; since: string }) {
-    return this._webhooksService.fireWebhooks(data.org, data.since);
+    try {
+      return await this._webhooksService.fireWebhooks(data.org, data.since);
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the webhooks worker",
+        err
+      );
+    }
   }
 
   @EventPattern('cron', Transport.REDIS)
   async cron(data: { id: string }) {
-    return this._autopostsService.startAutopost(data.id);
+    try {
+      return await this._autopostsService.startAutopost(data.id);
+    } catch (err) {
+      console.log(
+        "Unhandled error, let's avoid crashing the autopost worker",
+        err
+      );
+    }
   }
 }