Add pagination to getAllWallets (#336)

* Add pagination to getAllWallets

* Update

Author: adam-maj

src/db/wallets/getAllWallets.ts

@@ -3,12 +3,20 @@ import { getPrismaWithPostgresTx } from "../client";
 
 interface GetAllWalletsParams {
   pgtx?: PrismaTransaction;
+  page: number;
+  limit: number;
 }
 
 // TODO: Add error logging handler from req.log to all queries
-export const getAllWallets = async ({ pgtx }: GetAllWalletsParams = {}) => {
+export const getAllWallets = async ({
+  pgtx,
+  page,
+  limit,
+}: GetAllWalletsParams) => {
   const prisma = getPrismaWithPostgresTx(pgtx);
 
-  const wallets = await prisma.walletDetails.findMany();
-  return wallets;
+  return prisma.walletDetails.findMany({
+    skip: (page - 1) * limit,
+    take: limit,
+  });
 };

src/server/routes/backend-wallet/getAll.ts

@@ -7,7 +7,19 @@ import {
   walletDetailsSchema,
 } from "../../schemas/sharedApiSchemas";
 
-// OUTPUT
+const QuerySchema = Type.Object({
+  page: Type.Number({
+    description: "The page of wallets to get.",
+    examples: ["1"],
+    default: "1",
+  }),
+  limit: Type.Number({
+    description: "The number of wallets to get per page.",
+    examples: ["10"],
+    default: "10",
+  }),
+});
+
 const responseSchema = Type.Object({
   result: Type.Array(walletDetailsSchema),
 });
@@ -30,6 +42,7 @@ responseSchema.example = {
 };
 export async function getAll(fastify: FastifyInstance) {
   fastify.route<{
+    Querystring: Static<typeof QuerySchema>;
     Reply: Static<typeof responseSchema>;
   }>({
     method: "GET",
@@ -39,15 +52,19 @@ export async function getAll(fastify: FastifyInstance) {
       description: "Get all backend wallets.",
       tags: ["Backend Wallet"],
       operationId: "getAll",
+      querystring: QuerySchema,
       response: {
         ...standardResponseSchema,
         [StatusCodes.OK]: responseSchema,
       },
     },
-    handler: async (request, reply) => {
-      const wallets = await getAllWallets();
+    handler: async (req, res) => {
+      const wallets = await getAllWallets({
+        page: req.query.page,
+        limit: req.query.limit,
+      });
 
-      reply.status(StatusCodes.OK).send({
+      res.status(StatusCodes.OK).send({
         result: wallets,
       });
     },