26 lines
483 B
TypeScript
26 lines
483 B
TypeScript
import { Job, Worker } from "bullmq";
|
|
import { insertVideosWorker } from "lib/mq/executors.ts";
|
|
import { redis } from "lib/db/redis.ts";
|
|
|
|
const worker = new Worker(
|
|
"cvsa",
|
|
async (job: Job) => {
|
|
switch (job.name) {
|
|
case "getLatestVideos":
|
|
await insertVideosWorker(job);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
},
|
|
{ connection: redis },
|
|
);
|
|
|
|
worker.on("active", () => {
|
|
console.log("[bullmq] Worker activated.");
|
|
});
|
|
|
|
worker.on("error", (err) => {
|
|
console.error(err);
|
|
});
|