From c16173ea0fdbf6cc47b13756c0a77e8399669055 Mon Sep 17 00:00:00 2001
From: MohamedBassem <me@mbassem.com>
Date: Sat, 12 Oct 2024 16:47:22 +0000
Subject: feature: Introduce a mechanism to cleanup dangling assets

---
 apps/workers/index.ts | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

(limited to 'apps/workers/index.ts')

diff --git a/apps/workers/index.ts b/apps/workers/index.ts
index e576776a..f9a05e59 100644
--- a/apps/workers/index.ts
+++ b/apps/workers/index.ts
@@ -1,5 +1,7 @@
 import "dotenv/config";
 
+import { TidyAssetsWorker } from "tidyAssetsWorker";
+
 import serverConfig from "@hoarder/shared/config";
 import logger from "@hoarder/shared/logger";
 import { runQueueDBMigrations } from "@hoarder/shared/queues";
@@ -13,21 +15,25 @@ async function main() {
   logger.info(`Workers version: ${serverConfig.serverVersion ?? "not set"}`);
   runQueueDBMigrations();
 
-  const [crawler, openai, search] = [
+  const [crawler, openai, search, tidyAssets] = [
     await CrawlerWorker.build(),
     OpenAiWorker.build(),
     SearchIndexingWorker.build(),
+    TidyAssetsWorker.build(),
   ];
 
   await Promise.any([
-    Promise.all([crawler.run(), openai.run(), search.run()]),
+    Promise.all([crawler.run(), openai.run(), search.run(), tidyAssets.run()]),
     shutdownPromise,
   ]);
-  logger.info("Shutting down crawler, openai and search workers ...");
+  logger.info(
+    "Shutting down crawler, openai, tidyAssets and search workers ...",
+  );
 
   crawler.stop();
   openai.stop();
   search.stop();
+  tidyAssets.stop();
 }
 
 main();
-- 
cgit v1.2.3-70-g09d2