add sessionuser id"

Author: icecrasher321

apps/sim/app/api/workflows/[id]/execute/route.ts

@@ -505,6 +505,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
           workflowId,
           workspaceId: workflow.workspaceId ?? undefined,
           userId: actorUserId,
+          sessionUserId: isClientSession ? userId : undefined,
           triggerType,
           useDraftState: shouldUseDraftState,
           startTime: new Date().toISOString(),
@@ -772,6 +773,7 @@ export async function POST(req: NextRequest, { params }: { params: Promise<{ id:
             workflowId,
             workspaceId: workflow.workspaceId ?? undefined,
             userId: actorUserId,
+            sessionUserId: isClientSession ? userId : undefined,
             triggerType,
             useDraftState: shouldUseDraftState,
             startTime: new Date().toISOString(),

apps/sim/executor/execution/snapshot-serializer.ts

@@ -101,6 +101,7 @@ export function serializePauseSnapshot(
     workflowId: context.workflowId,
     workspaceId: context.workspaceId,
     userId: metadataFromContext?.userId ?? '',
+    sessionUserId: metadataFromContext?.sessionUserId,
     triggerType: metadataFromContext?.triggerType ?? 'manual',
     triggerBlockId: triggerBlockIds[0],
     useDraftState,

apps/sim/executor/execution/snapshot.ts

@@ -7,6 +7,7 @@ export interface ExecutionMetadata {
   workflowId: string
   workspaceId?: string
   userId: string
+  sessionUserId?: string
   triggerType: string
   triggerBlockId?: string
   useDraftState: boolean

apps/sim/lib/workflows/executor/execution-core.ts

@@ -152,7 +152,10 @@ export async function executeWorkflowCore(
     // Merge block states
     const mergedStates = mergeSubblockState(blocks)
 
-    const personalEnvUserId = metadata.isClientSession ? userId : workflow.userId || userId
+    const personalEnvUserId =
+      metadata.isClientSession && metadata.sessionUserId
+        ? metadata.sessionUserId
+        : workflow.userId || userId
 
     const { personalEncrypted, workspaceEncrypted, personalDecrypted, workspaceDecrypted } =
       await getPersonalAndWorkspaceEnv(personalEnvUserId, providedWorkspaceId)

apps/sim/lib/workflows/executor/human-in-the-loop-manager.ts

@@ -639,6 +639,7 @@ export class PauseResumeManager {
       requestId: baseSnapshot.metadata.requestId,
       startTime: new Date().toISOString(),
       userId,
+      sessionUserId: baseSnapshot.metadata.sessionUserId,
       useDraftState: baseSnapshot.metadata.useDraftState,
       isClientSession: baseSnapshot.metadata.isClientSession,
       resumeFromSnapshot: true,