1 files changed, 66 insertions, 0 deletions
diff --git a/src/queries/prisma/link.ts b/src/queries/prisma/link.ts
new file mode 100644
index 0000000..9b971de
--- /dev/null
+++ b/src/queries/prisma/link.ts
@@ -0,0 +1,66 @@
+import type { Prisma } from '@/generated/prisma/client';
+import prisma from '@/lib/prisma';
+import type { QueryFilters } from '@/lib/types';
+
+export async function findLink(criteria: Prisma.LinkFindUniqueArgs) {
+  return prisma.client.link.findUnique(criteria);
+}
+
+export async function getLink(linkId: string) {
+  return findLink({
+    where: {
+      id: linkId,
+    },
+  });
+}
+
+export async function getLinks(criteria: Prisma.LinkFindManyArgs, filters: QueryFilters = {}) {
+  const { search } = filters;
+  const { getSearchParameters, pagedQuery } = prisma;
+
+  const where: Prisma.LinkWhereInput = {
+    ...criteria.where,
+    ...getSearchParameters(search, [
+      { name: 'contains' },
+      { url: 'contains' },
+      { slug: 'contains' },
+    ]),
+  };
+
+  return pagedQuery('link', { ...criteria, where }, filters);
+}
+
+export async function getUserLinks(userId: string, filters?: QueryFilters) {
+  return getLinks(
+    {
+      where: {
+        userId,
+        deletedAt: null,
+      },
+    },
+    filters,
+  );
+}
+
+export async function getTeamLinks(teamId: string, filters?: QueryFilters) {
+  return getLinks(
+    {
+      where: {
+        teamId,
+      },
+    },
+    filters,
+  );
+}
+
+export async function createLink(data: Prisma.LinkUncheckedCreateInput) {
+  return prisma.client.link.create({ data });
+}
+
+export async function updateLink(linkId: string, data: any) {
+  return prisma.client.link.update({ where: { id: linkId }, data });
+}
+
+export async function deleteLink(linkId: string) {
+  return prisma.client.link.delete({ where: { id: linkId } });
+}