refactor: change endpoint place

Author: moonrailgun

src/client/components/worker/useCronPreview.ts

@@ -2,6 +2,7 @@ import { useEffect, useState } from 'react';
 import dayjs from 'dayjs';
 import { trpc } from '@/api/trpc';
 import { useEvent } from '@/hooks/useEvent';
+import { useCurrentWorkspaceId } from '@/store/user';
 
 interface UseCronPreviewOptions {
   cronExpression?: string;
@@ -25,8 +26,9 @@ export function useCronPreview({
 }: UseCronPreviewOptions): UseCronPreviewResult {
   const [previewTimes, setPreviewTimes] = useState<string[]>([]);
   const [error, setError] = useState<string | null>(null);
+  const workspaceId = useCurrentWorkspaceId();
 
-  const cronPreviewMutation = trpc.global.previewCron.useMutation({
+  const cronPreviewMutation = trpc.workspace.previewCron.useMutation({
     onSuccess: (data) => {
       const runs = (data.nextRuns ?? []).map((run) =>
         dayjs(run).format('YYYY-MM-DD HH:mm:ss (z)')
@@ -70,6 +72,7 @@ export function useCronPreview({
     }
 
     await cronPreviewMutation.mutateAsync({
+      workspaceId,
       cronExpression: expression,
       count,
     });

src/server/trpc/routers/global.ts

@@ -3,7 +3,6 @@ import { publicProcedure, router } from '../trpc.js';
 import { OPENAPI_TAG } from '../../utils/const.js';
 import { env } from '../../utils/env.js';
 import dayjs from 'dayjs';
-import { Cron } from 'croner';
 
 export const globalRouter = router({
   config: publicProcedure
@@ -59,28 +58,4 @@ export const globalRouter = router({
         observability: env.observability,
       };
     }),
-  previewCron: publicProcedure
-    .input(
-      z.object({
-        cronExpression: z.string(),
-        count: z.number().default(5),
-      })
-    )
-    .output(
-      z.object({
-        nextRuns: z.string().array(),
-      })
-    )
-    .mutation(async ({ input, ctx }) => {
-      const { cronExpression, count } = input;
-
-      const cron = new Cron(cronExpression, {
-        timezone: ctx.timezone,
-        paused: true,
-      });
-
-      return {
-        nextRuns: cron.nextRuns(count).map((run) => run.toISOString()),
-      };
-    }),
 });

src/server/trpc/routers/workspace.ts

@@ -38,6 +38,7 @@ import {
   sendInvitationEmail,
 } from '../../model/invitation.js';
 import { workspaceConfigRouter } from './workspaceConfig.js';
+import Cron from 'croner';
 
 export const workspaceRouter = router({
   create: protectProedure
@@ -599,6 +600,40 @@ export const workspaceRouter = router({
         },
       });
     }),
+  previewCron: workspaceProcedure
+    .input(
+      z.object({
+        cronExpression: z.string(),
+        count: z.number().default(5),
+      })
+    )
+    .output(
+      z.object({
+        nextRuns: z.string().array(),
+      })
+    )
+    .mutation(async ({ input, ctx }) => {
+      const { workspaceId, cronExpression, count } = input;
+
+      const workspace = await prisma.workspace.findUniqueOrThrow({
+        where: {
+          id: workspaceId,
+        },
+      });
+
+      const timezone =
+        get(workspace, ['settings', 'timezone']) || ctx.timezone || 'utc';
+
+      const cron = new Cron(cronExpression, {
+        timezone,
+        paused: true,
+      });
+
+      return {
+        nextRuns: cron.nextRuns(count).map((run) => run.toISOString()),
+      };
+    }),
+
   config: workspaceConfigRouter,
 });