feature: Introduce a mechanism to cleanup dangling assets

1 files changed, 9 insertions, 3 deletions

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();