1 files changed, 40 insertions, 0 deletions
diff --git a/web/lib/services/links.ts b/web/lib/services/links.ts
new file mode 100644
index 00000000..f3ff1757
--- /dev/null
+++ b/web/lib/services/links.ts
@@ -0,0 +1,40 @@
+import { LinkCrawlerQueue } from "@remember/shared/queues";
+import prisma from "@remember/db";
+
+export async function bookmarkLink(url: string, userId: string) {
+  const link = await prisma.bookmarkedLink.create({
+    data: {
+      url,
+      userId,
+    },
+  });
+
+  // Enqueue crawling request
+  await LinkCrawlerQueue.add("crawl", {
+    linkId: link.id,
+    url: link.url,
+  });
+
+  return link;
+}
+
+export async function getLinks(userId: string) {
+  return await prisma.bookmarkedLink.findMany({
+    where: {
+      userId,
+    },
+    select: {
+      id: true,
+      url: true,
+      createdAt: true,
+      details: {
+        select: {
+          title: true,
+          description: true,
+          imageUrl: true,
+          favicon: true,
+        },
+      },
+    },
+  });
+}