feat(user-tracking): Include userId in execution params

- Add userId to execution parameters for executeStep and retryStep
  functions to capture user-specific telemetry data
- Modify page functions to pass userId from the user context for
  more granular tracking and user-driven analytics
- Ensure all execution paths maintain consistent userId propagation
  for future scalability in user data insights

This enhancement improves the ability to trace executions back to
specific users, enabling better analytics and debugging capabilities
with no breaking changes introduced.

app/(playground)/p/[agentId]/page.tsx

@@ -126,6 +126,7 @@ export default async function Page({
 			stepId,
 			artifacts,
 			stream: true,
+			userId: user.id,
 		});
 	}
 	async function putExecutionAction(executionSnapshot: ExecutionSnapshot) {
@@ -169,19 +170,19 @@ export default async function Page({
 			stepId,
 			artifacts,
 			stream: true,
+			userId: user.id,
 		});
 	}
 
 	async function executeNodeAction(executionId: ExecutionId, nodeId: NodeId) {
 		"use server";
-		const response = await executeNode({
+		return await executeNode({
 			agentId,
 			executionId,
 			nodeId,
 			stream: true,
 			userId: user.id,
 		});
-		return response;
 	}
 
 	async function onFinishPerformExecutionAction(

packages/lib/execution.ts

@@ -411,6 +411,7 @@ interface ExecuteStepParams {
 	stepId: StepId;
 	artifacts: Artifact[];
 	stream?: boolean;
+	userId?: string;
 	overrideData?: OverrideData[];
 }
 export async function executeStep({
@@ -420,6 +421,7 @@ export async function executeStep({
 	stepId,
 	artifacts,
 	stream,
+	userId,
 	overrideData,
 }: ExecuteStepParams) {
 	const agent = await db.query.agents.findFirst({
@@ -490,6 +492,7 @@ export async function executeStep({
 		artifacts,
 		nodes: graph.nodes,
 		connections: graph.connections,
+		userId,
 		stream,
 	};
 
@@ -503,6 +506,7 @@ interface RetryStepParams {
 	stepId: StepId;
 	artifacts: Artifact[];
 	stream?: boolean;
+	userId?: string;
 }
 export async function retryStep({
 	agentId,
@@ -511,6 +515,7 @@ export async function retryStep({
 	stepId,
 	artifacts,
 	stream,
+	userId,
 }: RetryStepParams) {
 	const executionSnapshot = await fetch(retryExecutionSnapshotUrl).then(
 		(res) => res.json() as unknown as ExecutionSnapshot,
@@ -537,6 +542,7 @@ export async function retryStep({
 		nodes: executionSnapshot.nodes,
 		connections: executionSnapshot.connections,
 		stream,
+		userId,
 	};
 
 	return performFlowExecution(context);