ingra-ai · chozzz · Aug 20, 2024 · Aug 19, 2024 · Aug 20, 2024 · Aug 20, 2024
@@ -12,7 +12,7 @@ import {
   unsubscribeToCollection as dataUnsubscribeToCollection,
   toggleCollectionSubscription as dataToggleCollectionSubscription,
 
-} from '@/data/collections';
+} from '@data/collections';
 
 export const createCollection = async (values: z.infer<typeof CollectionSchema>) => {
   const validatedValues = await validateAction(CollectionSchema, values);

@@ -12,7 +12,7 @@ import {
   cloneFunction as dataCloneFunction,
   toggleFunctionSubscription,
 } from '@data/functions';
-import { addFunctionToCollection, removeFunctionFromCollection } from '@/data/collections';
+import { addFunctionToCollection, removeFunctionFromCollection } from '@data/collections';
 
 export const upsertFunction = async (values: z.infer<typeof FunctionSchema>) => {
   const validatedValues = await validateAction(FunctionSchema, values);
@@ -59,7 +59,10 @@ export const cloneFunction = async (functionId: string) => {
     return {
       status: 'ok',
       message: `Function "${clonedFunction.slug}" has been cloned!`,
-      data: clonedFunction
+      data: {
+        ...clonedFunction,
+        href: `/repo/${authSession.user.profile?.userName}/functions/edit/${clonedFunction.id}`
+      }
     };
   });
 };

@@ -1,6 +1,6 @@
 'use client';
 import { NavItemChild } from '@components/navs/types';
-import { SquareDashedBottomCodeIcon, SquareLibraryIcon } from 'lucide-react';
+import { SquareFunctionIcon, SquareLibraryIcon } from 'lucide-react';
 
 export const MarketplaceNavRoutes: NavItemChild[] = [
   {
@@ -11,6 +11,6 @@ export const MarketplaceNavRoutes: NavItemChild[] = [
   {
     name: 'Functions',
     href: '/marketplace/functions',
-    icon: SquareDashedBottomCodeIcon
+    icon: SquareFunctionIcon
   }
 ];
@@ -0,0 +1,148 @@
+
+import type { FetchCommunityCollectionListPaginationType } from '@components/data/collections/types';
+import clamp from 'lodash/clamp';
+import db from '@lib/db';
+
+export const fetchPaginationData = async (searchParams: Record<string, string | string[] | undefined> = {}, userId: string) => {
+  // Parse the query parameteres
+  let { page = '1' } = searchParams;
+  page = Array.isArray(page) ? page[0] : page;
+
+  // Validate and sanitize page and pageSize
+  const pageInt = Number.isInteger(Number(page)) && Number(page) > 0 ? parseInt(page, 10) : 1;
+  const pageSizeInt = 20;
+
+  // Calculate skip value based on page and pageSize
+  const skip = clamp(pageInt - 1, 0, 1e3) * pageSizeInt;
+
+  const [totalCount, allCollections] = await Promise.all([
+    // Fetch the total count of collections
+    db.collection.count({
+      where: {
+        NOT: {
+          userId,
+        },
+        functions: {
+          some: {
+            isPublished: true,
+            isPrivate: false,
+          },
+        },
+      },
+    }),
+
+    // Fetch paginated collections
+    db.collection.findMany({
+      where: {
+        NOT: {
+          userId,
+        },
+        functions: {
+          some: {
+            isPublished: true,
+            isPrivate: false,
+          },
+        },
+      },
+      orderBy: {
+        updatedAt: 'desc',
+      },
+      select: {
+        id: true,
+        name: true,
+        slug: true,
+        description: true,
+        owner: {
+          select: {
+            profile: {
+              select: {
+                userName: true,
+              }
+            }
+          }
+        },
+        functions: {
+          select: {
+            id: true,
+            slug: true,
+            code: false,
+            description: true,
+            httpVerb: true,
+            isPrivate: true,
+            isPublished: true,
+            ownerUserId: true,
+            createdAt: false,
+            updatedAt: true,
+            tags: {
+              select: {
+                id: true,
+                name: true,
+                functionId: false,
+                function: false,
+              }
+            },
+            arguments: {
+              select: {
+                id: true,
+                name: true,
+                description: false,
+                type: true,
+                defaultValue: false,
+                isRequired: false,
+              }
+            },
+            owner: {
+              select: {
+                id: true,
+             
B93C
   profile: {
+                  select: {
+                    userName: true,
+                  }
+                }
+              }
+            }
+          },
+        },
+        _count: {
+          select: {
+            subscribers: true,
+          }
+        },
+        subscribers: {
+          where: {
+            userId,
+          },
+          select: {
+            id: true,
+          },
+        },
+      },
+      skip,
+      take: pageSizeInt,
+    })
+  ]);
+
+  // Transform the `subscribers` field into a boolean `isSubscribed`
+  const collectionsWithSubscriptionStatus = allCollections.map(collection => ({
+    ...collection,
+    isSubscribed: Array.isArray( collection?.subscribers ) && collection.subscribers.length > 0
+  }));
+
+  // Calculate pagination details
+  const totalRecords = totalCount;
+  const nbPages = Math.ceil(totalRecords / pageSizeInt);
+  const hasNext = (skip + pageSizeInt) < totalRecords;
+  const hasPrevious = pageInt > 1;
+
+  const result: FetchCommunityCollectionListPaginationType = {
+    records: collectionsWithSubscriptionStatus,
+    page: pageInt,
+    pageSize: pageSizeInt,
+    totalRecords,
+    nbPages,
+    hasNext,
+    hasPrevious,
+  };
+
+  return result;
+};
@@ -13,11 +13,9 @@ async function Layout ({
   children: ReactNode
 }) {
   return (
-    <div className='relative' data-testid="marketplace-collections-layout">
-      <Suspense fallback={<LoadingSkeleton />}>
-        { children }
-      </Suspense>
-    </div>
+    <Suspense fallback={<LoadingSkeleton />}>
+      { children }
+    </Suspense>
   );
 }