Get workflow rest api

src/route-handlers/get-workflow-history/get-workflow-history.ts

@@ -9,15 +9,15 @@ import {
   type RouteParams,
   type RequestParams,
 } from './get-workflow-history.types';
-import getWorkflowHistoryQueryParamSchema from './schemas/get-workflow-history-query-params-schema';
+import getWorkflowHistoryQueryParamsSchema from './schemas/get-workflow-history-query-params-schema';
 
 export default async function getWorkflowHistory(
   request: NextRequest,
   requestParams: RequestParams
 ) {
   const decodedParams = decodeUrlParams<RouteParams>(requestParams.params);
   const { data: queryParams, error } =
-    getWorkflowHistoryQueryParamSchema.safeParse(
+    getWorkflowHistoryQueryParamsSchema.safeParse(
       Object.fromEntries(request.nextUrl.searchParams)
     );
 
@@ -49,6 +49,20 @@ export default async function getWorkflowHistory(
 
     return Response.json(res);
   } catch (e) {
+    if (
+      e instanceof GRPCError &&
+      e.message ===
+        'Requested workflow history not found, may have passed retention period.'
+    ) {
+      return NextResponse.json(
+        {
+          message: 'Workflow not found',
+          cause: e,
+        },
+        { status: 404 }
+      );
+    }
+
     logger.error<RouteHandlerErrorPayload>(
       { requestParams: decodedParams, cause: e },
       'Error fetching workflow history'

src/route-handlers/get-workflow-history/schemas/get-workflow-history-query-params-schema.ts

@@ -1,6 +1,6 @@
 import { z } from 'zod';
 
-const getWorkflowHistoryQueryParamSchema = z.object({
+const getWorkflowHistoryQueryParamsSchema = z.object({
   pageSize: z
     .string()
     .transform((val) => parseInt(val, 10))
@@ -16,4 +16,4 @@ const getWorkflowHistoryQueryParamSchema = z.object({
     .optional(),
 });
 
-export default getWorkflowHistoryQueryParamSchema;
+export default getWorkflowHistoryQueryParamsSchema;