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

---
 packages/shared/queues.ts | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

(limited to 'packages/shared/queues.ts')

diff --git a/packages/shared/queues.ts b/packages/shared/queues.ts
index 6189a633..7baae535 100644
--- a/packages/shared/queues.ts
+++ b/packages/shared/queues.ts
@@ -116,3 +116,20 @@ export async function triggerVideoWorker(bookmarkId: string, url: string) {
     url,
   });
 }
+
+// Feed Worker
+export const zFeedRequestSchema = z.object({
+  feedId: z.string(),
+});
+export type ZFeedRequestSchema = z.infer<typeof zFeedRequestSchema>;
+
+export const FeedQueue = new SqliteQueue<ZFeedRequestSchema>(
+  "feed_queue",
+  queueDB,
+  {
+    defaultJobArgs: {
+      // One retry is enough for the feed queue given that it's periodic
+      numRetries: 1,
+    },
+  },
+);
-- 
cgit v1.2.3-70-g09d2