Add user info middleware (#1002)

* Add user info middleware

* Update src/utils/route-handlers-middleware/middlewares/user-info.ts

Co-authored-by: Adhitya Mamallan <adi1998is@gmail.com>

---------

Co-authored-by: Adhitya Mamallan <adi1998is@gmail.com>

Author: Assem-Uber

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

@@ -38,7 +38,6 @@ export async function resetWorkflow(
       decisionFinishEventId: data.decisionFinishEventId,
       requestId: data.requestId,
       skipSignalReapply: data.skipSignalReapply,
-      // TODO: add user identity
     });
 
     return NextResponse.json(response);

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

@@ -36,7 +36,7 @@ export async function restartWorkflow(
         runId: decodedParams.runId,
       },
       reason: data.reason,
-      // TODO: add user identity
+      identity: ctx.userInfo?.id,
     });
 
     return NextResponse.json(response);

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

@@ -39,7 +39,7 @@ export async function signalWorkflow(
       signalInput: data.signalInput
         ? { data: Buffer.from(data.signalInput) }
         : undefined,
-      // TODO: add user identity
+      identity: ctx.userInfo?.id,
     });
 
     return NextResponse.json(response);

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

@@ -1,6 +1,6 @@
 import { type z } from 'zod';
 
-import { type GRPCClusterMethods } from '@/utils/grpc/grpc-client';
+import { type DefaultMiddlewaresContext } from '@/utils/route-handlers-middleware';
 
 import type signalWorkflowRequestBodySchema from './schemas/signal-workflow-request-body-schema';
 
@@ -17,6 +17,4 @@ export type SignalWorkflowRequestBody = z.infer<
   typeof signalWorkflowRequestBodySchema
 >;
 
-export type Context = {
-  grpcClusterMethods: GRPCClusterMethods;
-};
+export type Context = DefaultMiddlewaresContext;

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

@@ -40,6 +40,7 @@ export async function terminateWorkflow(
         runId: decodedParams.runId,
       },
       reason: data.reason,
+      identity: ctx.userInfo?.id,
     });
 
     return NextResponse.json({} satisfies TerminateWorkflowResponse);

src/utils/route-handlers-middleware/config/route-handlers-default-middlewares.config.ts

@@ -1,10 +1,13 @@
 import { type GRPCClusterMethods } from '@/utils/grpc/grpc-client';
 
 import grpcClusterMethodsMiddleware from '../middlewares/grpc-cluster-methods';
+import userInfoMiddleware from '../middlewares/user-info';
+import { type UserInfoMiddlewareContext } from '../middlewares/user-info.types';
 import { type MiddlewareFunction } from '../route-handlers-middleware.types';
 
 const routeHandlersDefaultMiddlewares: [
   MiddlewareFunction<['grpcClusterMethods', GRPCClusterMethods]>,
-] = [grpcClusterMethodsMiddleware];
+  MiddlewareFunction<['userInfo', UserInfoMiddlewareContext]>,
+] = [grpcClusterMethodsMiddleware, userInfoMiddleware];
 
 export default routeHandlersDefaultMiddlewares;

src/utils/route-handlers-middleware/middlewares/user-info.ts

@@ -0,0 +1,12 @@
+import { type MiddlewareFunction } from '../route-handlers-middleware.types';
+
+import { type UserInfoMiddlewareContext } from './user-info.types';
+
+const userInfo: MiddlewareFunction<
+  ['userInfo', UserInfoMiddlewareContext]
+> = async () => {
+  // Placeholder for user info middleware, to be implemented after integrating auth
+  return ['userInfo', null];
+};
+
+export default userInfo;

src/utils/route-handlers-middleware/middlewares/user-info.types.ts

@@ -0,0 +1,3 @@
+export type UserInfoMiddlewareContext = {
+  id: string;
+} | null;