frishi/threetwo-core-service
1
0
Fork 0
Code Issues 2 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

🐂 Queue drain event

Browse Source
This commit is contained in:
Rishi Ghan
2023-08-22 05:20:24 -04:00
parent fe9fbe9c3a
commit 01975079e3
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
services/jobqueue.service.ts
View File

@@ -168,7 +168,17 @@ export default class JobQueueService extends Service {
async "enqueue.async.active"(ctx: Context<{ id: Number }>) { async "enqueue.async.active"(ctx: Context<{ id: Number }>) {
console.log(`Job ID ${ctx.params.id} is set to active.`); console.log(`Job ID ${ctx.params.id} is set to active.`);
}, },
async "drained"(ctx) {
console.log("Queue drained.");
this.broker.call("socket.broadcast", {
namespace: "/",
event: "action",
args: [{
type: "LS_IMPORT_QUEUE_DRAINED",
data: "cham"
}],
});
},
async "enqueue.async.completed"(ctx: Context<{ id: Number }>) { async "enqueue.async.completed"(ctx: Context<{ id: Number }>) {
// 1. Fetch the job result using the job Id // 1. Fetch the job result using the job Id
const job = await this.job(ctx.params.id); const job = await this.job(ctx.params.id);
@@ -197,10 +207,6 @@ export default class JobQueueService extends Service {
// 6. Purge it from Redis // 6. Purge it from Redis
await job.remove(); await job.remove();
// 7. Check
const jobCounts = this.getJobCounts("active", "completed", "failed");
console.log("ASDASD");
console.log(jobCounts);
console.log(`Job ID ${ctx.params.id} completed.`); console.log(`Job ID ${ctx.params.id} completed.`);
}, },