Merge pull request #432 from g-ongenae/fixture/handle-error-from-void…

…-promises [FIX] Handle error from void promises
algoan · Oct 28, 2024 · 3a0de2f · 3a0de2f
2 parents d4f2fcf + d4bd3aa
commit 3a0de2f
Showing 1 changed file with 28 additions and 4 deletions.
diff --git a/src/hooks/services/hooks.service.ts b/src/hooks/services/hooks.service.ts
@@ -87,7 +87,13 @@ export class HooksService {
       }
 
       // Handle the event asynchronously
-      void this.dispatchAndHandleWebhook(event, subscription, serviceAccount, aggregationStartDate);
+      void this.dispatchAndHandleWebhook(event, subscription, serviceAccount, aggregationStartDate)
+        .catch((err: Error) => {
+          this.logger.error({
+            message: `Error while processing the event ${event.id}`,
+            error: err?.stack ?? err,
+          });
+        });
 
       return;
     }
@@ -125,17 +131,35 @@ export class HooksService {
           break;
         // The default case should never be reached, as the eventName is already checked in the DTO
         default:
-          void se.update({ status: EventStatus.FAILED });
+          void se.update({ status: EventStatus.FAILED })
+            .catch((statusError: Error) => {
+              this.logger.error({
+                message: `Unable to update the event ${event.id}'s status to FAILED`,
+                error: statusError?.stack ?? statusError,
+              });
+            });
 
           return;
       }
     } catch (err) {
-      void se.update({ status: EventStatus.ERROR });
+      void se.update({ status: EventStatus.ERROR })
+        .catch((statusError: Error) => {
+          this.logger.error({
+            message: `Unable to update the event ${event.id}'s status to ERROR`,
+            error: statusError?.stack ?? statusError,
+          });
+        });
 
       throw err;
     }
 
-    void se.update({ status: EventStatus.PROCESSED });
+    void se.update({ status: EventStatus.PROCESSED })
+      .catch((statusError: Error) => {
+        this.logger.error({
+          message: `Unable to update the event ${event.id}'s status to PROCESSED`,
+          error: statusError?.stack ?? statusError,
+        });
+      });
   }
 
   /**