AI/firecrawl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/mendableai/firecrawl synced 2025-08-15 01:26:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Nick: fixed n-1 w/ Rafa

Browse Source
This commit is contained in:
Nicolas 2024-12-03 17:53:17 -03:00
parent 52806807a1
commit 43530b3b4d
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/api/src/services/queue-worker.ts
View File

@ -20,6 +20,7 @@ import {
addCrawlJobDone,
crawlToCrawler,
finishCrawl,
generateURLPermutations,
getCrawl,
getCrawlJobs,
lockURL,
@ -422,7 +423,16 @@ async function processJob(job: Job & { id: string }, token: string) {
const sc = (await getCrawl(job.data.crawl_id)) as StoredCrawl;
if (doc.metadata.url !== undefined && doc.metadata.sourceURL !== undefined && normalizeURL(doc.metadata.url, sc) !== normalizeURL(doc.metadata.sourceURL, sc)) {
logger.debug("Was redirected, locking new URL...");
logger.debug("Was redirected, removing old URL and locking new URL...");
// Remove the old URL from visited sets
await redisConnection.srem("crawl:" + job.data.crawl_id + ":visited", normalizeURL(doc.metadata.sourceURL, sc));
if (sc.crawlerOptions?.deduplicateSimilarURLs) {
const permutations = generateURLPermutations(doc.metadata.sourceURL).map(x => x.href);
await redisConnection.srem("crawl:" + job.data.crawl_id + ":visited", ...permutations);
}
await redisConnection.srem("crawl:" + job.data.crawl_id + ":visited_unique", normalizeURL(doc.metadata.sourceURL, sc));
// Lock the new URL
await lockURL(job.data.crawl_id, sc, doc.metadata.url);
}