refactor: extract some monitor logic into model

src/server/model/monitor/index.ts

@@ -1,3 +1,61 @@
+import { MonitorPublicInfoSchema } from '../../../types';
+import { prisma } from '../_client';
 import { MonitorManager } from './manager';
 
 export const monitorManager = new MonitorManager();
+
+export async function getMonitorPublicInfos(monitorIds: string[]) {
+  const res = await prisma.monitor.findMany({
+    where: {
+      id: {
+        in: monitorIds,
+      },
+    },
+  });
+
+  return res.map((item) => MonitorPublicInfoSchema.parse(item));
+}
+
+export function getMonitorData(
+  workspaceId: string,
+  monitorId: string,
+  startDate: Date,
+  endDate: Date
+) {
+  return prisma.monitorData.findMany({
+    where: {
+      monitor: {
+        id: monitorId,
+        workspaceId,
+      },
+      createdAt: {
+        gte: startDate,
+        lte: endDate,
+      },
+    },
+    select: {
+      value: true,
+      createdAt: true,
+    },
+  });
+}
+
+export function getMonitorRecentData(
+  workspaceId: string,
+  monitorId: string,
+  take: number
+) {
+  return prisma.monitorData.findMany({
+    where: {
+      monitor: {
+        id: monitorId,
+        workspaceId,
+      },
+    },
+    take: -take,
+    select: {
+      value: true,
+      createdAt: true,
+    },
+  });
+}

src/server/trpc/routers/monitor.ts

@@ -7,7 +7,12 @@ import {
 } from '../trpc';
 import { prisma } from '../../model/_client';
 import { z } from 'zod';
-import { monitorManager } from '../../model/monitor';
+import {
+  getMonitorData,
+  getMonitorPublicInfos,
+  getMonitorRecentData,
+  monitorManager,
+} from '../../model/monitor';
 import {
   MonitorInfoWithNotificationIds,
   MonitorPublicInfoSchema,
@@ -101,15 +106,8 @@ export const monitorRouter = router({
     .output(z.array(MonitorPublicInfoSchema))
     .query(async ({ input }) => {
       const { monitorIds } = input;
-      const res = await prisma.monitor.findMany({
-        where: {
-          id: {
-            in: monitorIds,
-          },
-        },
-      });
 
-      return res.map((item) => MonitorPublicInfoSchema.parse(item));
+      return getMonitorPublicInfos(monitorIds);
     }),
   upsert: workspaceOwnerProcedure
     .meta(
@@ -220,22 +218,12 @@ export const monitorRouter = router({
     .query(async ({ input }) => {
       const { monitorId, workspaceId, startAt, endAt } = input;
 
-      return prisma.monitorData.findMany({
+      return getMonitorData(
-        where: {
+        workspaceId,
-          monitor: {
+        monitorId,
-            id: monitorId,
+        new Date(startAt),
-            workspaceId,
+        new Date(endAt)
-          },
+      );
-          createdAt: {
-            gte: new Date(startAt),
-            lte: new Date(endAt),
-          },
-        },
-        select: {
-          value: true,
-          createdAt: true,
-        },
-      });
     }),
   changeActive: workspaceOwnerProcedure
     .meta(
@@ -312,18 +300,9 @@ export const monitorRouter = router({
       )
     )
     .query(async ({ input }) => {
-      const { monitorId, take } = input;
+      const { workspaceId, monitorId, take } = input;
 
-      return prisma.monitorData.findMany({
+      return getMonitorRecentData(workspaceId, monitorId, take);
-        where: {
-          monitorId,
-        },
-        take: -take,
-        select: {
-          value: true,
-          createdAt: true,
-        },
-      });
     }),
   dataMetrics: workspaceProcedure
     .meta(