aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers/index.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2024-11-03 17:09:47 +0000
committerMohamed Bassem <me@mbassem.com>2024-11-03 17:09:47 +0000
commitcf1a25131fd45ab7c9a72b837be525c24457cd8b (patch)
treecb8b3d4a57a4ce06e500e4c7ceea43924d64a5d4 /apps/workers/index.ts
parent2efc7c8c01866fafad5322fb8783d94821e32ff1 (diff)
downloadkarakeep-cf1a25131fd45ab7c9a72b837be525c24457cd8b.tar.zst
feature: Add support for subscribing to RSS feeds. Fixes #202
Diffstat (limited to 'apps/workers/index.ts')
-rw-r--r--apps/workers/index.ts8
1 files changed, 6 insertions, 2 deletions
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();