feature: Add support for subscribing to RSS feeds. Fixes #202

1 files changed, 46 insertions, 0 deletions

diff --git a/packages/db/schema.ts b/packages/db/schema.ts
index 10c69d9d..12255cfb 100644
--- a/packages/db/schema.ts
+++ b/packages/db/schema.ts
@@ -334,6 +334,52 @@ export const customPrompts = sqliteTable(
   }),
 );
 
+export const rssFeedsTable = sqliteTable(
+  "rssFeeds",
+  {
+    id: text("id")
+      .notNull()
+      .primaryKey()
+      .$defaultFn(() => createId()),
+    name: text("name").notNull(),
+    url: text("url").notNull(),
+    createdAt: createdAtField(),
+    lastFetchedAt: integer("lastFetchedAt", { mode: "timestamp" }),
+    lastFetchedStatus: text("lastFetchedStatus", {
+      enum: ["pending", "failure", "success"],
+    }).default("pending"),
+    userId: text("userId")
+      .notNull()
+      .references(() => users.id, { onDelete: "cascade" }),
+  },
+  (bl) => ({
+    userIdIdx: index("rssFeeds_userId_idx").on(bl.userId),
+  }),
+);
+
+export const rssFeedImportsTable = sqliteTable(
+  "rssFeedImports",
+  {
+    id: text("id")
+      .notNull()
+      .primaryKey()
+      .$defaultFn(() => createId()),
+    createdAt: createdAtField(),
+    entryId: text("entryId").notNull(),
+    rssFeedId: text("rssFeedId")
+      .notNull()
+      .references(() => rssFeedsTable.id, { onDelete: "cascade" }),
+    bookmarkId: text("bookmarkId").references(() => bookmarks.id, {
+      onDelete: "set null",
+    }),
+  },
+  (bl) => ({
+    feedIdIdx: index("rssFeedImports_feedIdIdx_idx").on(bl.rssFeedId),
+    entryIdIdx: index("rssFeedImports_entryIdIdx_idx").on(bl.entryId),
+    feedIdEntryIdUnique: unique().on(bl.rssFeedId, bl.entryId),
+  }),
+);
+
 export const config = sqliteTable("config", {
   key: text("key").notNull().primaryKey(),
   value: text("value").notNull(),