feat: Add bookmark functionality with toggle action and repository integration

Author: kingRayhan

src/backend/models/domain-models.ts

@@ -113,3 +113,10 @@ export interface ArticleTag {
   article?: Article;
   tag?: Tag;
 }
+
+export interface Bookmark {
+  id: string;
+  resource_id: string;
+  resource_type: "ARTICLE" | "COMMENT";
+  user_id: string;
+}

src/backend/persistence/persistence-contracts.ts

@@ -5,6 +5,7 @@ export enum DatabaseTableName {
   user_sessions = "user_sessions",
   series = "series",
   series_items = "series_items",
+  bookmarks = "bookmarks",
   tags = "tags",
   article_tag = "article_tag",
 }

src/backend/persistence/persistence-repositories.ts

@@ -2,6 +2,7 @@ import { Repository } from "sqlkit";
 import {
   Article,
   ArticleTag,
+  Bookmark,
   Series,
   SeriesItem,
   Tag,
@@ -59,11 +60,18 @@ const seriesItemsRepository = new Repository<SeriesItem>(
   repositoryConfig
 );
 
+const bookmarkRepository = new Repository<Bookmark>(
+  DatabaseTableName.bookmarks,
+  pgClient,
+  repositoryConfig
+);
+
 export const persistenceRepository = {
   user: userRepository,
   userSocial: userSocialRepository,
   userSession: userSessionRepository,
   article: articleRepository,
+  bookmark: bookmarkRepository,
   articleTagPivot: articleTagRepository,
   tags: tagRepository,
   series: seriesRepository,

src/backend/services/bookmark.action.ts

@@ -0,0 +1,53 @@
+import z from "zod";
+import { BookmarkActionInput } from "./inputs/bookmark.input";
+import { authID } from "./session.actions";
+import { ActionException, handleActionException } from "./RepositoryException";
+import { persistenceRepository } from "../persistence/persistence-repositories";
+import { and, eq } from "sqlkit";
+
+export async function toggleResourceBookmark(
+  _input: z.infer<typeof BookmarkActionInput.toggleBookmarkInput>
+) {
+  try {
+    const sessionUserId = await authID();
+    if (!sessionUserId) {
+      throw new ActionException("Unauthorized");
+    }
+    const input =
+      await BookmarkActionInput.toggleBookmarkInput.parseAsync(_input);
+
+    // -----------
+    const [existingBookmark] = await persistenceRepository.bookmark.find({
+      limit: 1,
+      where: and(
+        eq("resource_id", input.resource_id),
+        eq("resource_type", input.resource_type),
+        eq("user_id", sessionUserId)
+      ),
+    });
+
+    if (existingBookmark) {
+      // If bookmark exists, delete it
+      await persistenceRepository.bookmark.delete({
+        where: and(
+          eq("resource_id", input.resource_id),
+          eq("resource_type", input.resource_type),
+          eq("user_id", sessionUserId)
+        ),
+      });
+      return { bookmarked: false };
+    }
+
+    // If bookmark does not exist, create it
+    await persistenceRepository.bookmark.insert([
+      {
+        resource_id: input.resource_id,
+        resource_type: input.resource_type,
+        user_id: sessionUserId,
+      },
+    ]);
+    return { bookmarked: true };
+  } catch (error) {
+    handleActionException(error);
+  }
+}