aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers/crawlerWorker.ts
diff options
context:
space:
mode:
authorMohamedBassem <me@mbassem.com>2024-04-02 12:58:33 +0100
committerMohamedBassem <me@mbassem.com>2024-04-02 12:59:31 +0100
commit79321f83293bc37d37af4b0a0b2bd324f5bafe1a (patch)
treee56e819240eebc0d65e5a85a996d4751e458c4b1 /apps/workers/crawlerWorker.ts
parentc73dde43cc816b8bf8eee74051d4fdac402cc710 (diff)
downloadkarakeep-79321f83293bc37d37af4b0a0b2bd324f5bafe1a.tar.zst
fix(workers): Add a timeout to the crawling job to prevent it from getting stuck. Fixes #63
Diffstat (limited to 'apps/workers/crawlerWorker.ts')
-rw-r--r--apps/workers/crawlerWorker.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts
index 87b785ad..a969ab86 100644
--- a/apps/workers/crawlerWorker.ts
+++ b/apps/workers/crawlerWorker.ts
@@ -20,6 +20,7 @@ import metascraperUrl from "metascraper-url";
import puppeteer from "puppeteer-extra";
import AdblockerPlugin from "puppeteer-extra-plugin-adblocker";
import StealthPlugin from "puppeteer-extra-plugin-stealth";
+import { withTimeout } from "utils";
import type { ZCrawlLinkRequest } from "@hoarder/shared/queues";
import { db } from "@hoarder/db";
@@ -110,7 +111,7 @@ export class CrawlerWorker {
logger.info("Starting crawler worker ...");
const worker = new Worker<ZCrawlLinkRequest, void>(
LinkCrawlerQueue.name,
- runCrawler,
+ withTimeout(runCrawler, /* timeoutSec */ 30),
{
connection: queueConnectionDetails,
autorun: false,