Update index.ts

This commit is contained in:
Nicolas 2024-07-12 10:22:06 -04:00
parent 961b27811d
commit c3eecf7b9f
1 changed files with 6 additions and 0 deletions

View File

@ -117,6 +117,8 @@ if (cluster.isMaster) {
});
app.post(`/admin/${process.env.BULL_AUTH_KEY}/shutdown`, async (req, res) => {
return res.status(200).json({ ok: true });
try {
const wsq = getWebScraperQueue();
@ -155,6 +157,8 @@ if (cluster.isMaster) {
});
app.post(`/admin/${process.env.BULL_AUTH_KEY}/unpause`, async (req, res) => {
return res.status(200).json({ ok: true });
await getWebScraperQueue().resume(false);
res.json({ ok: true });
});
@ -278,5 +282,7 @@ if (cluster.isMaster) {
res.send({ isProduction: global.isProduction });
});
console.log(`Worker ${process.pid} started`);
}