moved heartbeat from controller to queue consumer

bcgov · Dec 4, 2024 · bf40da2 · bf40da2
1 parent 93a2bdb
commit bf40da2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 11 deletions.
diff --git a/src/api/notifications/notifications.controller.ts b/src/api/notifications/notifications.controller.ts
@@ -458,16 +458,6 @@ export class NotificationsController {
           },
           this.req,
         );
-        const hbTimeout = setInterval(() => {
-          this.notificationsService.updateById(
-            data.id,
-            {
-              updated: new Date(),
-            },
-            this.req,
-          );
-        }, 60000);
-
         const count = subCandidates.length;
         const chunks = Math.ceil(count / this.broadcastSubscriberChunkSize);
         let i = 0;
@@ -489,7 +479,6 @@ export class NotificationsController {
           data: { id: data.id },
           children,
         });
-        clearTimeout(hbTimeout);
         break;
       }
     }

diff --git a/src/queue/notification-queue-consumer.ts b/src/queue/notification-queue-consumer.ts
@@ -314,6 +314,9 @@ export class NotificationQueueConsumer
       case 'p':
         return this.postBroadcastProcessing(notification);
       case 'c':
+        await this.notificationsService.updateById(notification.id, {
+          updated: new Date(),
+        });
         return this.broadcastToSubscriberChunk(notification, job);
     }
   }