From 758f729ae27ca379297ec5e87368ef92dd35e015 Mon Sep 17 00:00:00 2001 From: Nicolas Date: Sun, 1 Sep 2024 14:10:47 -0300 Subject: [PATCH] Update queue-worker.ts --- apps/api/src/services/queue-worker.ts | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index d3a34e96..477b3185 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -288,6 +288,11 @@ async function processJob(job: Job, token: string) { } if (await finishCrawl(job.data.crawl_id)) { + // v1 web hooks, call when done with no data, but with event completed + if (job.data.v1 && job.data.webhook) { + callWebhook(job.data.team_id, job.data.crawl_id, [], job.data.webhook, job.data.v1, "crawl.completed"); + } + const jobIDs = await getCrawlJobs(job.data.crawl_id); const jobs = (await Promise.all(jobIDs.map(async x => { @@ -351,10 +356,7 @@ async function processJob(job: Job, token: string) { if (!job.data.v1) { callWebhook(job.data.team_id, job.data.crawl_id, data, job.data.webhook, job.data.v1, "crawl.completed"); } - // v1 web hooks, call when done with no data, but with event completed - if (job.data.v1 && job.data.webhook) { - callWebhook(job.data.team_id, job.data.crawl_id, [], job.data.webhook, job.data.v1, "crawl.completed"); - } + } }