feat(tRPC): add paged smart trades

packages/trpc/src/routers/private/smart-trade/get-infinite-smart-trades/handler.ts

@@ -0,0 +1,41 @@
+import { xprisma, toSmartTradeEntity } from "@opentrader/db";
+import type { TGetInfiniteSmartTradesSchema } from "./schema.js";
+import type { Context } from "../../../../utils/context.js";
+
+type Options = {
+  ctx: {
+    user: NonNullable<Context["user"]>;
+  };
+  input: TGetInfiniteSmartTradesSchema;
+};
+
+export async function getInfiniteSmartTrades({ ctx, input }: Options) {
+  const { cursor } = input;
+  const limit = input.limit ?? 50;
+  const items = await xprisma.smartTrade.findMany({
+    take: limit + 1, // get an extra item at the end which we'll use as next cursor
+    cursor: cursor ? { id: cursor } : undefined,
+    orderBy: {
+      updatedAt: "desc",
+    },
+    where: {
+      owner: { id: ctx.user.id },
+      bot: { id: input.botId },
+    },
+    include: {
+      orders: true,
+      exchangeAccount: true,
+    },
+  });
+
+  let nextCursor: typeof cursor | undefined = undefined;
+  if (items.length > limit) {
+    const nextItem = items.pop();
+    nextCursor = nextItem!.id;
+  }
+
+  return {
+    items: items.map((smartTrade) => toSmartTradeEntity(smartTrade)),
+    nextCursor,
+  };
+}

packages/trpc/src/routers/private/smart-trade/get-infinite-smart-trades/schema.ts

@@ -0,0 +1,9 @@
+import { z } from "zod";
+
+export const ZGetInfiniteSmartTradesSchema = z.object({
+  botId: z.number().optional(),
+  limit: z.number().min(1).max(100).nullish(),
+  cursor: z.number().nullish(), // <-- "cursor" needs to exist, but can be any type
+});
+
+export type TGetInfiniteSmartTradesSchema = z.infer<typeof ZGetInfiniteSmartTradesSchema>;

packages/trpc/src/routers/private/smart-trade/router.ts

@@ -2,12 +2,13 @@ import { router } from "../../../trpc.js";
 import { authorizedProcedure } from "../../../procedures.js";
 import { getSmartTrades } from "./get-smart-trades/handler.js";
 import { ZGetSmartTradesSchema } from "./get-smart-trades/schema.js";
+import { getInfiniteSmartTrades } from "./get-infinite-smart-trades/handler.js";
+import { ZGetInfiniteSmartTradesSchema } from "./get-infinite-smart-trades/schema.js";
 import { getSmartTrade } from "./get-smart-trade/handler.js";
 import { ZGetSmartTradeInputSchema } from "./get-smart-trade/schema.js";
 
 export const smartTradeRouter = router({
   list: authorizedProcedure.input(ZGetSmartTradesSchema).query(getSmartTrades),
-  getOne: authorizedProcedure
-    .input(ZGetSmartTradeInputSchema)
-    .query(getSmartTrade),
+  infiniteList: authorizedProcedure.input(ZGetInfiniteSmartTradesSchema).query(getInfiniteSmartTrades),
+  getOne: authorizedProcedure.input(ZGetSmartTradeInputSchema).query(getSmartTrade),
 });