measure how many active jobs we have for disabled accounts

BoKKeR · Jul 12, 2023 · 26b93c5 · 26b93c5
1 parent ac5a8e1
commit 26b93c5
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/rss/rss.service.ts b/src/rss/rss.service.ts
@@ -109,6 +109,18 @@ export class RssService implements OnModuleInit {
       where: { chat_id: dto.chatId },
       data: { disabled: dto.disable }
     });
+    const activeJobs = await this.messagesQueue.getJobs(["waiting", "delayed"]);
+
+    let countOfActiveJobs = 0;
+
+    for (let i = 0; i < activeJobs.length; i++) {
+      const job = activeJobs[i];
+      if (job.data.chatId === dto.chatId) {
+        countOfActiveJobs++;
+      }
+    }
+
+    console.log("DISABLED USER ACTIVE JOBS: " + countOfActiveJobs);
   }
 
   async disableFeed(dto: { name: string; disable: boolean }) {