[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","2f607f7b74b4e52529fb75176d403d8b5b284eb1","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_150":151,"_170":171,"_172":-5},"handle","AIWB","name","agentRegistry","path","workflowEngine.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_149":20},"id","53ac3ce0-6130-11f0-812d-0224a6c84d84","createdAt",["D",1752552063821],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","910c5de7-d7ef-46a2-9233-a36b504c0356","pinnedFileId","pinPreview","screenshotVersion","likeCount","3d0667b8-98c5-4e4b-9dab-f0c5e3bd2418","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycU91M051U0JoMFZtclVEaFY2MDNCUmlFbTYifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":139,"_140":141,"_142":108,"_143":144,"_145":146,"_147":96,"_148":94},"version",12,"53af644c-6130-11f0-812d-0224a6c84d84","projectId","forkedBranchId","5dfe05ac-2c6a-11f0-8699-569c3dd06744","forkedBranchVersion",96,"forkedProjectPrivacy","forkedProjectId","5dfdba8e-2c6a-11f0-8699-569c3dd06744","forkedProjectOrgId","45a0d482-0d4d-4887-9bc4-d08243be47a9","projectName","userHandle","isOwned","file",{"_101":152,"_95":98,"_153":154,"_155":-5,"_156":136,"_157":158,"_159":160,"_103":161,"_134":162,"_163":164,"_165":166,"_167":20,"_168":-5,"_97":169},"47ef52c4-6131-11f0-9ac4-0224a6c84d84","fileId","a6049c73-4d23-42bd-93ad-31a894608130","parentId","branchId","branchVersion",10,"latest",true,["D",1752552473652],3,"fileType","script","content","// workflowEngine.ts\nimport { AgentRegistry } from \"https://esm.town/v/AIWB/agentRegistry/agentRegistry.ts\";\nimport {\n AgentContext,\n AgentInput,\n AgentOutput,\n InputMapping, // Keep this type for explicit mappings\n WorkflowDefinition,\n WorkflowResult,\n WorkflowStep,\n} from \"https://esm.town/v/AIWB/agentRegistry/interfaces.ts\";\nimport { MemoryLogger } from \"https://esm.town/v/AIWB/agentRegistry/logger.ts\";\n\nexport class WorkflowEngine {\n constructor(private registry: AgentRegistry, private logger: MemoryLogger) {}\n\n private resolveNestedValue(obj: any, fieldPath: string): any {\n if (obj === undefined || obj === null || !fieldPath) return undefined; // Guard against null/undefined obj\n return fieldPath.split(\".\").reduce(\n (acc, part) => (acc && typeof acc === \"object\" && acc[part] !== undefined) ? acc[part] : undefined,\n obj,\n );\n }\n\n // New recursive function to resolve any kind of input structure\n private resolveInputStructure(\n structure: any,\n initialPayload: any,\n stepResults: Map>,\n contextStepId?: string, // Optional: for more detailed logging\n contextInputKey?: string, // Optional: for more detailed logging\n ): any {\n const log = this.logger.createLogFunction(\n contextStepId ? `M-UnknownStep-${contextStepId}` : `M-UnknownWorkflow`, // Placeholder mandateId for this internal log\n \"WorkflowEngine:InputResolver\",\n );\n\n // Case 1: It's an InputMapping object { source: \"...\", field: \"...\" }\n if (\n typeof structure === \"object\"\n && structure !== null\n && typeof structure.source === \"string\"\n && typeof structure.field === \"string\"\n && Object.keys(structure).length >= 2 && Object.keys(structure).length <= 3 // Allow for 'optional'\n ) {\n const sourceData = structure.source === \"initial\"\n ? initialPayload\n : stepResults.get(structure.source)?.payload;\n\n if (sourceData === undefined && structure.source !== \"initial\" && !stepResults.has(structure.source)) {\n // This can happen if a source step was skipped and the input wasn't marked optional in the workflow definition\n // or if this input mapping is for an output that an agent didn't produce.\n if (contextStepId && contextInputKey) {\n log(\n \"WARN\",\n `Step:${contextStepId}`,\n `Source step \"${structure.source}\" for input \"${contextInputKey}\" did not produce output or was not found.`,\n );\n }\n return undefined; // Or handle based on structure.optional if you implement that\n }\n const value = this.resolveNestedValue(sourceData, structure.field);\n if (value === undefined && contextStepId && contextInputKey) {\n // Log if a specific mapping resolves to undefined, helps debug missing fields\n log(\n \"WARN\",\n `Step:${contextStepId}`,\n `Input mapping for \"${contextInputKey}\" resolved to undefined from ${structure.source}.${structure.field}`,\n );\n }\n return value;\n }\n // Case 2: It's an array\n else if (Array.isArray(structure)) {\n return structure.map(item =>\n this.resolveInputStructure(item, initialPayload, stepResults, contextStepId, contextInputKey)\n );\n }\n // Case 3: It's a non-InputMapping, non-array object\n else if (typeof structure === \"object\" && structure !== null) {\n const resolvedObject: Record = {};\n for (const [key, value] of Object.entries(structure)) {\n resolvedObject[key] = this.resolveInputStructure(\n value,\n initialPayload,\n stepResults,\n contextStepId,\n contextInputKey ? `${contextInputKey}.${key}` : key,\n );\n }\n return resolvedObject;\n }\n // Case 4: It's a literal (string, number, boolean, null)\n return structure;\n }\n\n // The original resolveInputValue can be kept specifically for OutputMapping\n // as output mappings are expected to be simple {source, field}\n private resolveOutputValue(\n mapping: InputMapping, // OutputMappingValue is essentially an InputMapping\n initialPayload: any,\n stepResults: Map>,\n ): any {\n if (!mapping || typeof mapping.source !== \"string\" || typeof mapping.field !== \"string\") {\n this.logger.record({\n mandateId: \"WorkflowEngine\", // Generic mandateId for this type of error\n level: \"ERROR\",\n component: \"WorkflowEngine:OutputResolver\",\n message: \"Invalid output mapping structure\",\n details: { mapping },\n });\n return undefined;\n }\n const sourceData = mapping.source === \"initial\" ? initialPayload : stepResults.get(mapping.source)?.payload;\n // Check if the source step's payload exists, especially if the step might have been skipped or failed\n if (sourceData === undefined) {\n if (mapping.optional) { // Assuming OutputMappingValue might have an 'optional' field\n return undefined; // It's optional, so undefined is acceptable\n }\n this.logger.record({\n mandateId: \"WorkflowEngine\",\n level: \"WARN\",\n component: \"WorkflowEngine:OutputResolver\",\n message: `Source data for output mapping from step \"${mapping.source}\" is undefined.`,\n details: { mapping },\n });\n return undefined;\n }\n return this.resolveNestedValue(sourceData, mapping.field);\n }\n\n async execute(\n definition: WorkflowDefinition,\n initialPayload: InitialPayload,\n ): Promise> {\n const mandateId = `M-${Date.now()}-${definition.id}`;\n const log = this.logger.createLogFunction(mandateId, \"WorkflowEngine\");\n const stepResults = new Map>();\n const completedSteps = new Set();\n const runningSteps = new Set();\n\n log(\"INFO\", `Workflow:${definition.id}`, `Execution starting`, { initialPayload });\n\n // --- Initial Input Validation (simplified for brevity, your existing logic is fine) ---\n if (definition.initialInputSchema) {\n // ... (your validation logic - seems okay)\n if (false /* replace with actual validation failure */) {\n // ... return error ...\n }\n log(\"DEBUG\", `Workflow:${definition.id}`, `Initial input validation passed.`);\n }\n\n try {\n const stepLookup = new Map(definition.steps.map(step => [step.id, step]));\n\n while (completedSteps.size < definition.steps.length) {\n const readyToExecuteSteps: WorkflowStep[] = [];\n for (const step of definition.steps) {\n if (completedSteps.has(step.id) || runningSteps.has(step.id)) continue;\n\n const dependenciesMet = (step.dependencies ?? []).every(depId => completedSteps.has(depId));\n if (!dependenciesMet) continue;\n\n if (step.condition) {\n // Condition mapping should also use the new resolveInputStructure\n // Assuming step.condition is a standard InputMapping {source, field, operator}\n // For simplicity, if step.condition is just {source, field}, resolveInputValue is okay\n // but ideally, condition resolution might need to be more flexible too.\n // For now, let's assume current condition resolution is working based on logs.\n // Current logic for condition value:\n const conditionSourceValue = this.resolveInputStructure(\n step.condition,\n initialPayload,\n stepResults,\n step.id,\n \"conditionSource\",\n );\n\n let conditionResult = false;\n if (step.condition.operator === \"isNotEmpty\") {\n conditionResult = conditionSourceValue !== undefined && conditionSourceValue !== null\n && conditionSourceValue !== \"\";\n if (Array.isArray(conditionSourceValue)) conditionResult = conditionSourceValue.length > 0;\n } else if (step.condition.operator === \"isTrue\") {\n conditionResult = !!conditionSourceValue;\n } else { // Default: truthy\n conditionResult = !!conditionSourceValue;\n }\n\n if (!conditionResult) {\n log(\"INFO\", `Step:${step.id}`, `Skipped due to condition not met`, {\n conditionField: step.condition.field,\n value: conditionSourceValue,\n });\n completedSteps.add(step.id);\n continue;\n }\n log(\"DEBUG\", `Step:${step.id}`, `Condition met`, {\n conditionField: step.condition.field,\n value: conditionSourceValue,\n });\n }\n readyToExecuteSteps.push(step);\n }\n\n if (readyToExecuteSteps.length === 0 && completedSteps.size < definition.steps.length) {\n // ... (your deadlock detection - seems okay) ...\n throw new Error(`Workflow deadlock or circular dependency.`);\n }\n if (readyToExecuteSteps.length === 0 && completedSteps.size === definition.steps.length) break;\n\n const executionPromises = readyToExecuteSteps.map(async (step) => {\n runningSteps.add(step.id);\n const agent = this.registry.getAgent(step.agent);\n if (!agent) throw new Error(`Agent \"${step.agent}\" for step \"${step.id}\" not found.`);\n\n const agentInputPayload: Record = {};\n if (step.input) {\n for (const [key, inputStructureToResolve] of Object.entries(step.input)) {\n // Use the new recursive resolver\n agentInputPayload[key] = this.resolveInputStructure(\n inputStructureToResolve,\n initialPayload,\n stepResults,\n step.id, // Pass stepId for context\n key, // Pass inputKey for context\n );\n }\n }\n // ... (rest of agent execution logic: context, agent call, error handling, stepResults.set) ...\n const taskId = `T-${Date.now()}-${step.id}`;\n const agentContext: AgentContext = {\n /* ... your context setup ... */\n mandateId,\n taskId,\n log: this.logger.createLogFunction(mandateId, `Agent:${step.agent}`), // Simplified logger for agent\n config: step.config,\n };\n const agentInput: AgentInput = { mandateId, taskId, payload: agentInputPayload };\n\n log(\"DEBUG\", `Step:${step.id}`, `Executing agent \"${step.agent}\"`, { input: agentInputPayload }); // This log will now be more accurate\n try {\n const output = await agent(agentInput, agentContext);\n if (output.error) throw new Error(`Agent \"${step.agent}\" (Step \"${step.id}\") failed: ${output.error}`);\n // ... (correlationId check) ...\n log(\"DEBUG\", `Step:${step.id}`, `Agent \"${step.agent}\" completed`, { output: output.payload });\n stepResults.set(step.id, output); // Store the full AgentOutput\n return { stepId: step.id, success: true, error: null };\n } catch (e: any) {\n log(\"ERROR\", `Step:${step.id}`, `Agent \"${step.agent}\" execution error`, {\n message: e.message,\n stack: e.stack,\n });\n return { stepId: step.id, success: false, error: e };\n } finally {\n runningSteps.delete(step.id);\n }\n }); // End of map for executionPromises\n\n const results = await Promise.allSettled(executionPromises);\n // ... (your results processing and error handling - seems okay) ...\n let cycleError: Error | null = null;\n results.forEach(result => {\n if (result.status === \"fulfilled\" && result.value) {\n const { stepId, success, error } = result.value;\n if (success) {\n completedSteps.add(stepId);\n } else {\n if (!cycleError && error) cycleError = error;\n completedSteps.add(stepId); // Mark as completed even if failed to prevent re-execution\n }\n } else if (result.status === \"rejected\") {\n if (!cycleError) cycleError = result.reason;\n log(\"ERROR\", `Workflow:${definition.id}`, `Critical error in step execution promise.`, {\n reason: result.reason,\n });\n }\n });\n if (cycleError) throw cycleError;\n } // End while loop\n\n let finalPayload: any = {};\n if (definition.outputMapping) {\n for (const [key, mapping] of Object.entries(definition.outputMapping)) {\n // Use the specific resolveOutputValue for output mappings\n const value = this.resolveOutputValue(mapping as InputMapping, initialPayload, stepResults);\n // Only add to finalPayload if value is not undefined, or handle as per your needs\n // This will ensure keys with undefined values (due to failed resolution or optional not found) are omitted\n // which matches the previous logging behavior.\n if (value !== undefined) {\n finalPayload[key] = value;\n } else {\n log(\n \"WARN\",\n `Workflow:${definition.id}`,\n `Output mapping for key \"${key}\" resolved to undefined. Source: ${mapping.source}, Field: ${mapping.field}. It will be omitted from final payload.`,\n );\n }\n }\n } else if (definition.steps.length > 0) {\n // ... (your default output logic - seems okay, but ensure it handles undefined payloads gracefully) ...\n }\n\n log(\"SUCCESS\", `Workflow:${definition.id}`, `Execution finished successfully`, { finalPayload });\n return {\n mandateId,\n workflowId: definition.id,\n success: true,\n finalPayload: finalPayload as FinalPayload,\n debugLog: this.logger.getLogs(),\n };\n } catch (error: any) {\n log(\"ERROR\", `Workflow:${definition.id}`, `Execution failed`, { message: error.message, stack: error.stack });\n return {\n // ... (your error return structure - seems okay) ...\n mandateId,\n workflowId: definition.id,\n success: false,\n error: `Workflow \"${definition.id}\" failed.`,\n details: error?.message ?? String(error),\n debugLog: this.logger.getLogs(),\n };\n }\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/AIWB/agentRegistry/code/workflowEngine.ts","extension","actionData","errors"]