Add route handlers for cancel and terminate

src/app/api/domains/[domain]/[cluster]/workflows/[workflowId]/[runId]/(actions)/cancel/route.ts

@@ -0,0 +1,18 @@
+import { type NextRequest } from 'next/server';
+
+import { cancelWorkflow } from '@/route-handlers/cancel-workflow/cancel-workflow';
+import { type RouteParams } from '@/route-handlers/cancel-workflow/cancel-workflow.types';
+import { routeHandlerWithMiddlewares } from '@/utils/route-handlers-middleware';
+import routeHandlersDefaultMiddlewares from '@/utils/route-handlers-middleware/config/route-handlers-default-middlewares.config';
+
+export async function POST(
+  request: NextRequest,
+  options: { params: RouteParams }
+) {
+  return routeHandlerWithMiddlewares(
+    cancelWorkflow,
+    request,
+    options,
+    routeHandlersDefaultMiddlewares
+  );
+}

src/app/api/domains/[domain]/[cluster]/workflows/[workflowId]/[runId]/(actions)/terminate/route.ts

@@ -0,0 +1,18 @@
+import { type NextRequest } from 'next/server';
+
+import { terminateWorkflow } from '@/route-handlers/terminate-workflow/terminate-workflow';
+import { type RouteParams } from '@/route-handlers/terminate-workflow/terminate-workflow.types';
+import { routeHandlerWithMiddlewares } from '@/utils/route-handlers-middleware';
+import routeHandlersDefaultMiddlewares from '@/utils/route-handlers-middleware/config/route-handlers-default-middlewares.config';
+
+export async function POST(
+  request: NextRequest,
+  options: { params: RouteParams }
+) {
+  return routeHandlerWithMiddlewares(
+    terminateWorkflow,
+    request,
+    options,
+    routeHandlersDefaultMiddlewares
+  );
+}

src/route-handlers/cancel-workflow/cancel-workflow.ts

@@ -0,0 +1,61 @@
+import { type NextRequest, NextResponse } from 'next/server';
+
+import decodeUrlParams from '@/utils/decode-url-params';
+import { getHTTPStatusCode, GRPCError } from '@/utils/grpc/grpc-error';
+import logger, { type RouteHandlerErrorPayload } from '@/utils/logger';
+
+import {
+  type CancelWorkflowResponse,
+  type Context,
+  type RequestParams,
+} from './cancel-workflow.types';
+import cancelWorkflowRequestBodySchema from './schemas/cancel-workflow-request-body-schema';
+
+export async function cancelWorkflow(
+  request: NextRequest,
+  requestParams: RequestParams,
+  ctx: Context
+) {
+  const requestBody = await request.json();
+  const { data, error } =
+    cancelWorkflowRequestBodySchema.safeParse(requestBody);
+
+  if (error) {
+    return NextResponse.json(
+      {
+        message: 'Invalid values provided for workflow cancellation',
+        validationErrors: error.errors,
+      },
+      { status: 400 }
+    );
+  }
+
+  const decodedParams = decodeUrlParams(requestParams.params);
+
+  try {
+    await ctx.grpcClusterMethods.requestCancelWorkflow({
+      domain: decodedParams.domain,
+      workflowExecution: {
+        workflowId: decodedParams.workflowId,
+        runId: decodedParams.runId,
+      },
+      cause: data.cause,
+    });
+
+    return NextResponse.json({} satisfies CancelWorkflowResponse);
+  } catch (e) {
+    logger.error<RouteHandlerErrorPayload>(
+      { requestParams: decodedParams, cause: e },
+      'Error cancelling workflow'
+    );
+
+    return NextResponse.json(
+      {
+        message:
+          e instanceof GRPCError ? e.message : 'Error cancelling workflow',
+        cause: e,
+      },
+      { status: getHTTPStatusCode(e) }
+    );
+  }
+}

src/route-handlers/cancel-workflow/cancel-workflow.types.ts

@@ -0,0 +1,17 @@
+import { type RequestCancelWorkflowExecutionResponse } from '@/__generated__/proto-ts/uber/cadence/api/v1/RequestCancelWorkflowExecutionResponse';
+import { type DefaultMiddlewaresContext } from '@/utils/route-handlers-middleware';
+
+export type RouteParams = {
+  domain: string;
+  cluster: string;
+  workflowId: string;
+  runId: string;
+};
+
+export type RequestParams = {
+  params: RouteParams;
+};
+
+export type CancelWorkflowResponse = RequestCancelWorkflowExecutionResponse;
+
+export type Context = DefaultMiddlewaresContext;

src/route-handlers/cancel-workflow/schemas/cancel-workflow-request-body-schema.ts

@@ -0,0 +1,10 @@
+import { z } from 'zod';
+
+const cancelWorkflowRequestBodySchema = z.object({
+  cause: z
+    .string()
+    .optional()
+    .default('Requesting workflow cancellation from cadence-web UI'),
+});
+
+export default cancelWorkflowRequestBodySchema;

src/route-handlers/terminate-workflow/schemas/terminate-workflow-request-body-schema.ts

@@ -0,0 +1,10 @@
+import { z } from 'zod';
+
+const terminateWorkflowRequestBodySchema = z.object({
+  reason: z
+    .string()
+    .optional()
+    .default('Terminating workflow from cadence-web UI'),
+});
+
+export default terminateWorkflowRequestBodySchema;

src/route-handlers/terminate-workflow/terminate-workflow.ts

@@ -0,0 +1,61 @@
+import { type NextRequest, NextResponse } from 'next/server';
+
+import decodeUrlParams from '@/utils/decode-url-params';
+import { getHTTPStatusCode, GRPCError } from '@/utils/grpc/grpc-error';
+import logger, { type RouteHandlerErrorPayload } from '@/utils/logger';
+
+import terminateWorkflowRequestBodySchema from './schemas/terminate-workflow-request-body-schema';
+import {
+  type TerminateWorkflowResponse,
+  type Context,
+  type RequestParams,
+} from './terminate-workflow.types';
+
+export async function terminateWorkflow(
+  request: NextRequest,
+  requestParams: RequestParams,
+  ctx: Context
+) {
+  const requestBody = await request.json();
+  const { data, error } =
+    terminateWorkflowRequestBodySchema.safeParse(requestBody);
+
+  if (error) {
+    return NextResponse.json(
+      {
+        message: 'Invalid values provided for workflow termination',
+        validationErrors: error.errors,
+      },
+      { status: 400 }
+    );
+  }
+
+  const decodedParams = decodeUrlParams(requestParams.params);
+
+  try {
+    await ctx.grpcClusterMethods.terminateWorkflow({
+      domain: decodedParams.domain,
+      workflowExecution: {
+        workflowId: decodedParams.workflowId,
+        runId: decodedParams.runId,
+      },
+      reason: data.reason,
+    });
+
+    return NextResponse.json({} satisfies TerminateWorkflowResponse);
+  } catch (e) {
+    logger.error<RouteHandlerErrorPayload>(
+      { requestParams: decodedParams, cause: e },
+      'Error terminating workflow'
+    );
+
+    return NextResponse.json(
+      {
+        message:
+          e instanceof GRPCError ? e.message : 'Error terminating workflow',
+        cause: e,
+      },
+      { status: getHTTPStatusCode(e) }
+    );
+  }
+}

src/route-handlers/terminate-workflow/terminate-workflow.types.ts

@@ -0,0 +1,17 @@
+import { type TerminateWorkflowExecutionResponse } from '@/__generated__/proto-ts/uber/cadence/api/v1/TerminateWorkflowExecutionResponse';
+import { type DefaultMiddlewaresContext } from '@/utils/route-handlers-middleware';
+
+export type RouteParams = {
+  domain: string;
+  cluster: string;
+  workflowId: string;
+  runId: string;
+};
+
+export type RequestParams = {
+  params: RouteParams;
+};
+
+export type TerminateWorkflowResponse = TerminateWorkflowExecutionResponse;
+
+export type Context = DefaultMiddlewaresContext;