feat: crawl status websocket WIP

2024-08-17 01:04:14 +02:00
parent e2a6ef26d3
commit eb84673b06
7 changed files with 262 additions and 28 deletions
@@ -63,6 +63,10 @@ export async function isCrawlFinished(id: string) {
    return (await redisConnection.scard("crawl:" + id + ":jobs_done")) === (await redisConnection.scard("crawl:" + id + ":jobs"));
 }

+export async function isCrawlFinishedLocked(id: string) {
+    return (await redisConnection.exists("crawl:" + id + ":finish"));
+}
+
 export async function finishCrawl(id: string) {
    if (await isCrawlFinished(id)) {
        const set = await redisConnection.setnx("crawl:" + id + ":finish", "yes");