From cf1a25131fd45ab7c9a72b837be525c24457cd8b Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Sun, 3 Nov 2024 17:09:47 +0000
Subject: feature: Add support for subscribing to RSS feeds. Fixes #202

---
 apps/workers/index.ts | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

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

diff --git a/apps/workers/index.ts b/apps/workers/index.ts
index 3b5896e4..c8978adc 100644
--- a/apps/workers/index.ts
+++ b/apps/workers/index.ts
@@ -1,5 +1,6 @@
 import "dotenv/config";
 
+import { FeedWorker } from "feedWorker";
 import { TidyAssetsWorker } from "tidyAssetsWorker";
 
 import serverConfig from "@hoarder/shared/config";
@@ -16,12 +17,13 @@ async function main() {
   logger.info(`Workers version: ${serverConfig.serverVersion ?? "not set"}`);
   runQueueDBMigrations();
 
-  const [crawler, openai, search, tidyAssets, video] = [
+  const [crawler, openai, search, tidyAssets, video, feed] = [
     await CrawlerWorker.build(),
     OpenAiWorker.build(),
     SearchIndexingWorker.build(),
     TidyAssetsWorker.build(),
     VideoWorker.build(),
+    FeedWorker.build(),
   ];
 
   await Promise.any([
@@ -31,11 +33,12 @@ async function main() {
       search.run(),
       tidyAssets.run(),
       video.run(),
+      feed.run(),
     ]),
     shutdownPromise,
   ]);
   logger.info(
-    "Shutting down crawler, openai, tidyAssets, video and search workers ...",
+    "Shutting down crawler, openai, tidyAssets, video, feed and search workers ...",
   );
 
   crawler.stop();
@@ -43,6 +46,7 @@ async function main() {
   search.stop();
   tidyAssets.stop();
   video.stop();
+  feed.stop();
 }
 
 main();
-- 
cgit v1.2.3-70-g09d2