(globalThis.TURBOPACK||(globalThis.TURBOPACK=[])).push(["object"==typeof document?document.currentScript:void 0,368148,e=>{"use strict";var t=e.i(805735),a=e.i(942347),o=e.i(841501),n=e.i(189299),i=e.i(390622),d=e.i(972282);e.s(["useAutoGenerateWebhookUrl",0,()=>{let e=(0,o.useStoreApi)();return(0,a.useCallback)(async a=>{let o=n.useStore.getState().appDetail?.id;if(!o)return;let{getNodes:r}=e.getState(),l=r().find(e=>e.id===a);if(l&&l.data.type===i.BlockEnum.TriggerWebhook&&(!l.data.webhook_url||!(l.data.webhook_url.length>0)))try{let n=await (0,d.fetchWebhookUrl)({appId:o,nodeId:a}),{getNodes:r,setNodes:l}=e.getState(),s=!1,u=(0,t.produce)(r(),e=>{let t=e.find(e=>e.id===a);t&&t.data.type===i.BlockEnum.TriggerWebhook&&(t.data={...t.data,webhook_url:n.webhook_url,webhook_debug_url:n.webhook_debug_url},s=!0)});s&&l(u)}catch(e){console.error("Failed to auto-generate webhook URL:",e)}},[e])}])},585736,e=>{"use strict";e.s(["createHooksStore",()=>d,"useHooksStore",()=>r]);var t=e.i(220365),a=e.i(942347),o=e.i(534011),n=e.i(613763),i=e.i(407396);let d=e=>{let{doSyncWorkflowDraft:a=async()=>(0,t.noop)(),syncWorkflowDraftWhenPageClose:o=t.noop,handleRefreshWorkflowDraft:i=t.noop,handleBackupDraft:d=t.noop,handleLoadBackupDraft:r=t.noop,handleRestoreFromPublishedWorkflow:l=t.noop,handleRun:s=t.noop,handleStopRun:u=t.noop,handleStartWorkflowRun:c=t.noop,handleWorkflowStartRunInWorkflow:p=t.noop,handleWorkflowStartRunInChatflow:g=t.noop,handleWorkflowTriggerScheduleRunInWorkflow:f=t.noop,handleWorkflowTriggerWebhookRunInWorkflow:h=t.noop,handleWorkflowTriggerPluginRunInWorkflow:y=t.noop,handleWorkflowRunAllTriggersInWorkflow:I=t.noop,availableNodesMetaData:S={nodes:[]},getWorkflowRunAndTraceUrl:k=()=>({runUrl:"",traceUrl:""}),exportCheck:E=async()=>(0,t.noop)(),handleExportDSL:m=async()=>(0,t.noop)(),fetchInspectVars:_=async()=>(0,t.noop)(),hasNodeInspectVars:w=()=>!1,hasSetInspectVar:T=()=>!1,fetchInspectVarValue:N=async()=>(0,t.noop)(),editInspectVarValue:C=async()=>(0,t.noop)(),renameInspectVarName:v=async()=>(0,t.noop)(),appendNodeInspectVars:D=()=>(0,t.noop)(),deleteInspectVar:b=async()=>(0,t.noop)(),deleteNodeInspectorVars:O=async()=>(0,t.noop)(),deleteAllInspectorVars:A=async()=>(0,t.noop)(),isInspectVarEdited:P=()=>!1,resetToLastRunVar:B=async()=>(0,t.noop)(),invalidateSysVarValues:M=t.noop,resetConversationVar:x=async()=>(0,t.noop)(),invalidateConversationVarValues:H=t.noop}=e;return(0,n.createStore)(e=>({refreshAll:t=>e(e=>({...e,...t})),doSyncWorkflowDraft:a,syncWorkflowDraftWhenPageClose:o,handleRefreshWorkflowDraft:i,handleBackupDraft:d,handleLoadBackupDraft:r,handleRestoreFromPublishedWorkflow:l,handleRun:s,handleStopRun:u,handleStartWorkflowRun:c,handleWorkflowStartRunInWorkflow:p,handleWorkflowStartRunInChatflow:g,handleWorkflowTriggerScheduleRunInWorkflow:f,handleWorkflowTriggerWebhookRunInWorkflow:h,handleWorkflowTriggerPluginRunInWorkflow:y,handleWorkflowRunAllTriggersInWorkflow:I,availableNodesMetaData:S,getWorkflowRunAndTraceUrl:k,exportCheck:E,handleExportDSL:m,fetchInspectVars:_,hasNodeInspectVars:w,hasSetInspectVar:T,fetchInspectVarValue:N,editInspectVarValue:C,renameInspectVarName:v,appendNodeInspectVars:D,deleteInspectVar:b,deleteNodeInspectorVars:O,deleteAllInspectorVars:A,isInspectVarEdited:P,resetToLastRunVar:B,invalidateSysVarValues:M,resetConversationVar:x,invalidateConversationVarValues:H}))};function r(e){let t=(0,a.useContext)(i.HooksStoreContext);if(!t)throw Error("Missing HooksStoreContext.Provider in the tree");return(0,o.useStore)(t,e)}},407396,e=>{"use strict";e.s(["HooksStoreContext",()=>i,"HooksStoreContextProvider",()=>d]);var t=e.i(162115),a=e.i(942347),o=e.i(841501),n=e.i(585736);let i=(0,a.createContext)(null),d=e=>{let{children:d,...r}=e,l=(0,a.useRef)(void 0),s=(0,o.useStore)(e=>e.d3Selection),u=(0,o.useStore)(e=>e.d3Zoom);return(0,a.useEffect)(()=>{l.current&&s&&u&&l.current.getState().refreshAll(r)},[s,u]),l.current||(l.current=(0,n.createHooksStore)(r)),(0,t.jsx)(i.Provider,{value:l.current,children:d})}},491401,e=>{"use strict";e.i(407396),e.i(585736),e.s([])},275225,305230,705405,e=>{"use strict";e.s([],275225),e.i(845296),e.s(["createWorkflowStore",()=>s,"useStore",()=>u,"useWorkflowStore",()=>c],705405);var t=e.i(942347),a=e.i(534011),o=e.i(613763);e.s(["WorkflowContext",()=>i,"WorkflowContextProvider",()=>d],305230);var n=e.i(162115);let i=(0,t.createContext)(null),d=e=>{let{children:a,injectWorkflowStoreSliceFn:o}=e,d=(0,t.useRef)(void 0);return d.current||(d.current=s({injectWorkflowStoreSliceFn:o})),(0,n.jsx)(i.Provider,{value:d.current,children:a})};var r=e.i(805735),l=e.i(328817);let s=e=>{let{injectWorkflowStoreSliceFn:t}=e||{};return(0,o.createStore)(function(){for(var e=arguments.length,a=Array(e),o=0;o{let t={showDebugAndPreviewPanel:!1,showEnvPanel:!1,showChatVariablePanel:!1,showGlobalVariablePanel:!1};return{showChatVariablePanel:!1,setShowChatVariablePanel:a=>e(()=>a?{...t,showChatVariablePanel:!0}:{showChatVariablePanel:!1}),showGlobalVariablePanel:!1,setShowGlobalVariablePanel:a=>e(()=>a?{...t,showGlobalVariablePanel:!0}:{showGlobalVariablePanel:!1}),conversationVariables:[],setConversationVariables:t=>e(()=>({conversationVariables:t}))}})(...a),...(e=>{let t={showDebugAndPreviewPanel:!1,showEnvPanel:!1,showChatVariablePanel:!1,showGlobalVariablePanel:!1};return{showEnvPanel:!1,setShowEnvPanel:a=>e(()=>a?{...t,showEnvPanel:!0}:{showEnvPanel:!1}),environmentVariables:[],setEnvironmentVariables:t=>e(()=>({environmentVariables:t})),envSecrets:{},setEnvSecrets:t=>e(()=>({envSecrets:t}))}})(...a),...(e=>({inputs:{},setInputs:t=>e(()=>({inputs:t})),files:[],setFiles:t=>e(()=>({files:t}))}))(...a),...(e=>({helpLineHorizontal:void 0,setHelpLineHorizontal:t=>e(()=>({helpLineHorizontal:t})),helpLineVertical:void 0,setHelpLineVertical:t=>e(()=>({helpLineVertical:t}))}))(...a),...(e=>({historyWorkflowData:void 0,setHistoryWorkflowData:t=>e(()=>({historyWorkflowData:t})),showRunHistory:!1,setShowRunHistory:t=>e(()=>({showRunHistory:t})),versionHistory:[],setVersionHistory:t=>e(()=>({versionHistory:t}))}))(...a),...(e=>({showSingleRunPanel:!1,setShowSingleRunPanel:t=>e(()=>({showSingleRunPanel:t})),nodeAnimation:!1,setNodeAnimation:t=>e(()=>({nodeAnimation:t})),candidateNode:void 0,setCandidateNode:t=>e(()=>({candidateNode:t})),nodeMenu:void 0,setNodeMenu:t=>e(()=>({nodeMenu:t})),showAssignVariablePopup:void 0,setShowAssignVariablePopup:t=>e(()=>({showAssignVariablePopup:t})),hoveringAssignVariableGroupId:void 0,setHoveringAssignVariableGroupId:t=>e(()=>({hoveringAssignVariableGroupId:t})),connectingNodePayload:void 0,setConnectingNodePayload:t=>e(()=>({connectingNodePayload:t})),enteringNodePayload:void 0,setEnteringNodePayload:t=>e(()=>({enteringNodePayload:t})),iterTimes:1,setIterTimes:t=>e(()=>({iterTimes:t})),loopTimes:1,setLoopTimes:t=>e(()=>({loopTimes:t})),iterParallelLogMap:new Map,setIterParallelLogMap:t=>e(()=>({iterParallelLogMap:t})),pendingSingleRun:void 0,setPendingSingleRun:t=>e(()=>({pendingSingleRun:t}))}))(...a),...(e=>({panelWidth:localStorage.getItem("workflow-node-panel-width")?Number.parseFloat(localStorage.getItem("workflow-node-panel-width")):420,showFeaturesPanel:!1,setShowFeaturesPanel:t=>e(()=>({showFeaturesPanel:t})),showWorkflowVersionHistoryPanel:!1,setShowWorkflowVersionHistoryPanel:t=>e(()=>({showWorkflowVersionHistoryPanel:t})),showInputsPanel:!1,setShowInputsPanel:t=>e(()=>({showInputsPanel:t})),showDebugAndPreviewPanel:!1,setShowDebugAndPreviewPanel:t=>e(()=>({showDebugAndPreviewPanel:t})),panelMenu:void 0,setPanelMenu:t=>e(()=>({panelMenu:t})),selectionMenu:void 0,setSelectionMenu:t=>e(()=>({selectionMenu:t})),edgeMenu:void 0,setEdgeMenu:t=>e(()=>({edgeMenu:t})),showVariableInspectPanel:!1,setShowVariableInspectPanel:t=>e(()=>({showVariableInspectPanel:t})),initShowLastRunTab:!1,setInitShowLastRunTab:t=>e(()=>({initShowLastRunTab:t}))}))(...a),...(e=>({toolPublished:!1,setToolPublished:t=>e(()=>({toolPublished:t})),lastPublishedHasUserInput:!1,setLastPublishedHasUserInput:t=>e(()=>({lastPublishedHasUserInput:t})),buildInTools:void 0,customTools:void 0,workflowTools:void 0,mcpTools:void 0}))(...a),...(e=>({draftUpdatedAt:0,setDraftUpdatedAt:t=>e(()=>({draftUpdatedAt:t?1e3*t:0})),publishedAt:0,setPublishedAt:t=>e(()=>({publishedAt:t?1e3*t:0})),currentVersion:null,setCurrentVersion:t=>e(()=>({currentVersion:t})),isRestoring:!1,setIsRestoring:t=>e(()=>({isRestoring:t}))}))(...a),...(e=>{let t=(0,l.debounce)(e=>{e()},5e3);return{backupDraft:void 0,setBackupDraft:t=>e(()=>({backupDraft:t})),debouncedSyncWorkflowDraft:t,syncWorkflowDraftHash:"",setSyncWorkflowDraftHash:t=>e(()=>({syncWorkflowDraftHash:t})),isSyncingWorkflowDraft:!1,setIsSyncingWorkflowDraft:t=>e(()=>({isSyncingWorkflowDraft:t})),isWorkflowDataLoaded:!1,setIsWorkflowDataLoaded:t=>e(()=>({isWorkflowDataLoaded:t})),nodes:[],setNodes:t=>e(()=>({nodes:t})),flushPendingSync:()=>{t.flush&&t.flush()}}})(...a),...(e=>({workflowRunningData:void 0,setWorkflowRunningData:t=>e(()=>({workflowRunningData:t})),isListening:!1,setIsListening:t=>e(()=>({isListening:t})),listeningTriggerType:null,setListeningTriggerType:t=>e(()=>({listeningTriggerType:t})),listeningTriggerNodeId:null,setListeningTriggerNodeId:t=>e(()=>({listeningTriggerNodeId:t})),listeningTriggerNodeIds:[],setListeningTriggerNodeIds:t=>e(()=>({listeningTriggerNodeIds:t})),listeningTriggerIsAll:!1,setListeningTriggerIsAll:t=>e(()=>({listeningTriggerIsAll:t})),clipboardElements:[],setClipboardElements:t=>e(()=>({clipboardElements:t})),selection:null,setSelection:t=>e(()=>({selection:t})),bundleNodeSize:null,setBundleNodeSize:t=>e(()=>({bundleNodeSize:t})),controlMode:"pointer"===localStorage.getItem("workflow-operation-mode")?"pointer":"hand",setControlMode:t=>{e(()=>({controlMode:t})),localStorage.setItem("workflow-operation-mode",t)},mousePosition:{pageX:0,pageY:0,elementX:0,elementY:0},setMousePosition:t=>e(()=>({mousePosition:t})),showConfirm:void 0,setShowConfirm:t=>e(()=>({showConfirm:t})),controlPromptEditorRerenderKey:0,setControlPromptEditorRerenderKey:t=>e(()=>({controlPromptEditorRerenderKey:t})),showImportDSLModal:!1,setShowImportDSLModal:t=>e(()=>({showImportDSLModal:t})),fileUploadConfig:void 0,setFileUploadConfig:t=>e(()=>({fileUploadConfig:t}))}))(...a),...(e=>({currentFocusNodeId:null,nodesWithInspectVars:[],conversationVars:[],setCurrentFocusNodeId:t=>{e(()=>({currentFocusNodeId:t}))},setNodesWithInspectVars:t=>{e(()=>({nodesWithInspectVars:t}))},deleteAllInspectVars:()=>{e(()=>({nodesWithInspectVars:[]}))},setNodeInspectVars:(t,a)=>{e(e=>{let o=e.nodesWithInspectVars;return{nodesWithInspectVars:(0,r.produce)(o,e=>{let n=o.findIndex(e=>e.nodeId===t);-1!==n&&(e[n].vars=a,e[n].isValueFetched=!0)})}})},deleteNodeInspectVars:t=>{e(e=>({nodesWithInspectVars:e.nodesWithInspectVars.filter(e=>e.nodeId!==t)}))},setInspectVarValue:(t,a,o)=>{e(e=>({nodesWithInspectVars:(0,r.produce)(e.nodesWithInspectVars,e=>{let n=e.find(e=>e.nodeId===t);if(!n)return;let i=n.vars.find(e=>e.id===a);i&&(i.value=o,i.edited=!0)})}))},resetToLastRunVar:(t,a,o)=>{e(e=>({nodesWithInspectVars:(0,r.produce)(e.nodesWithInspectVars,e=>{let n=e.find(e=>e.nodeId===t);if(!n)return;let i=n.vars.find(e=>e.id===a);i&&(i.value=o,i.edited=!1)})}))},renameInspectVarName:(t,a,o)=>{e(e=>({nodesWithInspectVars:(0,r.produce)(e.nodesWithInspectVars,e=>{let n=e.find(e=>e.nodeId===t);if(!n)return;let i=n.vars.find(e=>e.id===a);i&&(i.name=o[1],i.selector=o)})}))},deleteInspectVar:(t,a)=>{e(e=>({nodesWithInspectVars:(0,r.produce)(e.nodesWithInspectVars,e=>{let o=e.find(e=>e.nodeId===t);if(!o)return;let n=o.vars.findIndex(e=>e.id===a);-1!==n&&o.vars.splice(n,1)})}))}}))(...a),...(e=>({workflowCanvasWidth:void 0,workflowCanvasHeight:void 0,setWorkflowCanvasWidth:t=>e(()=>({workflowCanvasWidth:t})),setWorkflowCanvasHeight:t=>e(()=>({workflowCanvasHeight:t})),rightPanelWidth:void 0,setRightPanelWidth:t=>e(()=>({rightPanelWidth:t})),nodePanelWidth:localStorage.getItem("workflow-node-panel-width")?Number.parseFloat(localStorage.getItem("workflow-node-panel-width")):400,setNodePanelWidth:t=>e(()=>({nodePanelWidth:t})),previewPanelWidth:localStorage.getItem("debug-and-preview-panel-width")?Number.parseFloat(localStorage.getItem("debug-and-preview-panel-width")):400,setPreviewPanelWidth:t=>e(()=>({previewPanelWidth:t})),otherPanelWidth:400,setOtherPanelWidth:t=>e(()=>({otherPanelWidth:t})),bottomPanelWidth:480,setBottomPanelWidth:t=>e(()=>({bottomPanelWidth:t})),bottomPanelHeight:324,setBottomPanelHeight:t=>e(()=>({bottomPanelHeight:t})),variableInspectPanelHeight:localStorage.getItem("workflow-variable-inpsect-panel-height")?Number.parseFloat(localStorage.getItem("workflow-variable-inpsect-panel-height")):320,setVariableInspectPanelHeight:t=>e(()=>({variableInspectPanelHeight:t})),maximizeCanvas:"true"===localStorage.getItem("workflow-canvas-maximize"),setMaximizeCanvas:t=>e(()=>({maximizeCanvas:t}))}))(...a),...t?.(...a)||{}}})};function u(e){let o=(0,t.useContext)(i);if(!o)throw Error("Missing WorkflowContext.Provider in the tree");return(0,a.useStore)(o,e)}let c=()=>(0,t.useContext)(i)},3340,148280,e=>{"use strict";var t=e.i(942347),a=e.i(390622),o=e.i(946700);e.i(491401);var n=e.i(585736);e.i(275225);var i=e.i(705405),d=e.i(683257),r=e.i(154033),l=e.i(842090);let s=()=>{let e=(0,n.useHooksStore)(e=>e.availableNodesMetaData);return(0,t.useMemo)(()=>({nodes:e?.nodes||[],nodesMap:e?.nodesMap||{}}),[e])};e.s(["useNodeMetaData",0,e=>{let n=(0,d.useGetLanguage)(),{data:u}=(0,r.useAllBuiltInTools)(),{data:c}=(0,r.useAllCustomTools)(),{data:p}=(0,r.useAllWorkflowTools)(),g=(0,i.useStore)(e=>e.dataSourceList),f=s(),{data:h}=e,y=f.nodesMap?.[h.type],I=(0,t.useMemo)(()=>h.type===a.BlockEnum.DataSource?g?.find(e=>e.plugin_id===h.plugin_id)?.author:h.type===a.BlockEnum.Tool?h.provider_type===o.CollectionType.builtIn?u?.find(e=>(0,l.canFindTool)(e.id,h.provider_id))?.author:h.provider_type===o.CollectionType.workflow?p?.find(e=>e.id===h.provider_id)?.author:c?.find(e=>e.id===h.provider_id)?.author:y?.metaData.author,[h,u,c,p,y,g]),S=(0,t.useMemo)(()=>h.type===a.BlockEnum.DataSource?g?.find(e=>e.plugin_id===h.plugin_id)?.description[n]:h.type===a.BlockEnum.Tool?h.provider_type===o.CollectionType.builtIn?u?.find(e=>(0,l.canFindTool)(e.id,h.provider_id))?.description[n]:h.provider_type===o.CollectionType.workflow?p?.find(e=>e.id===h.provider_id)?.description[n]:c?.find(e=>e.id===h.provider_id)?.description[n]:y?.metaData.description,[h,u,c,p,y,g,n]);return(0,t.useMemo)(()=>({...y?.metaData,author:I,description:S}),[I,y,S])},"useNodesMetaData",0,s],148280);let u=(e,t)=>(!t||e!==a.BlockEnum.Iteration&&e!==a.BlockEnum.Loop&&e!==a.BlockEnum.End&&e!==a.BlockEnum.DataSource&&e!==a.BlockEnum.KnowledgeBase&&e!==a.BlockEnum.HumanInput)&&(!!t||e!==a.BlockEnum.LoopEnd)&&!0;e.s(["useAvailableBlocks",0,(e,o)=>{let{nodes:n}=s(),i=(0,t.useMemo)(()=>n.map(e=>e.metaData.type),[n]),d=(0,t.useMemo)(()=>e&&e!==a.BlockEnum.Start&&e!==a.BlockEnum.DataSource&&e!==a.BlockEnum.TriggerPlugin&&e!==a.BlockEnum.TriggerWebhook&&e!==a.BlockEnum.TriggerSchedule?i:[],[i,e]),r=(0,t.useMemo)(()=>e&&e!==a.BlockEnum.End&&e!==a.BlockEnum.LoopEnd&&e!==a.BlockEnum.KnowledgeBase?i:[],[i,e]),l=(0,t.useCallback)((e,t)=>{let o=i;e&&e!==a.BlockEnum.Start&&e!==a.BlockEnum.DataSource||(o=[]);let n=i;return e&&e!==a.BlockEnum.End&&e!==a.BlockEnum.LoopEnd&&e!==a.BlockEnum.KnowledgeBase||(n=[]),{availablePrevBlocks:o.filter(e=>u(e,t)),availableNextBlocks:n.filter(e=>u(e,t))}},[i]);return(0,t.useMemo)(()=>({getAvailableBlocks:l,availablePrevBlocks:d.filter(e=>u(e,o)),availableNextBlocks:r.filter(e=>u(e,o))}),[l,d,r,o])}],3340)},616332,e=>{"use strict";e.i(275225);var t=e.i(705405);e.s(["default",0,()=>(0,t.useStore)(e=>e.nodes)])},18084,517317,95131,227785,e=>{"use strict";e.s(["createDatasetsDetailStore",()=>u,"useDatasetsDetailStore",()=>c],18084);var t=e.i(805735),a=e.i(942347),o=e.i(613763),n=e.i(534011);e.s(["DatasetsDetailContext",()=>l,"default",()=>s],517317);var i=e.i(162115),d=e.i(211857),r=e.i(390622);let l=(0,a.createContext)(void 0),s=e=>{let{nodes:t,children:o}=e,n=(0,a.useRef)(void 0);n.current||(n.current=u());let s=(0,a.useCallback)(async e=>{let{data:t}=await (0,d.fetchDatasets)({url:"/datasets",params:{page:1,ids:e}});t&&t.length>0&&n.current.getState().updateDatasetsDetail(t)},[]);return(0,a.useEffect)(()=>{if(!n.current)return;let e=t.filter(e=>e.data.type===r.BlockEnum.KnowledgeRetrieval).reduce((e,t)=>Array.from(new Set([...e,...t.data.dataset_ids])),[]);0!==e.length&&s(e)},[]),(0,i.jsx)(l.Provider,{value:n.current,children:o})},u=()=>(0,o.createStore)((e,a)=>({datasetsDetail:{},updateDatasetsDetail:o=>{let n=a().datasetsDetail,i=o.reduce((e,t)=>(e[t.id]=t,e),{});e({datasetsDetail:(0,t.produce)(n,e=>{Object.entries(i).forEach(t=>{let[a,o]=t;e[a]=o})})})}})),c=e=>{let t=(0,a.useContext)(l);if(!t)throw Error("Missing DatasetsDetailContext.Provider in the tree");return(0,n.useStore)(t,e)};var p=e.i(946700),g=e.i(922521),f=e.i(154033),h=e.i(819114),y=e.i(842090);e.i(275225);var I=e.i(705405);let S=e=>e.type===r.BlockEnum.TriggerPlugin,k=e=>e.type===r.BlockEnum.Tool,E=e=>e.type===r.BlockEnum.DataSource,m=(e,t,a)=>"dark"===e&&a?a:t,_=(e,t,a)=>{let o=t||[];for(let t of e){if(!t)continue;let e=o.find(e=>e.id===t||(0,y.canFindTool)(e.id,t));if(e)return m(a,e.icon,e.icon_dark)}};e.s(["useGetToolIcon",0,()=>{let{data:e}=(0,f.useAllBuiltInTools)(),{data:t}=(0,f.useAllCustomTools)(),{data:o}=(0,f.useAllWorkflowTools)(),{data:n}=(0,f.useAllMCPTools)(),{data:i}=(0,h.useAllTriggerPlugins)(),d=(0,I.useWorkflowStore)(),{theme:r}=(0,g.default)();return(0,a.useCallback)(a=>{let{buildInTools:l,customTools:s,workflowTools:u,mcpTools:c,dataSourceList:g}=d.getState();if(S(a))return _([a.plugin_id,a.provider_id,a.provider_name],i,r);if(k(a)){let i=[(()=>{switch(a.provider_type){case p.CollectionType.custom:return s??t;case p.CollectionType.mcp:return c??n;case p.CollectionType.workflow:return u??o;case p.CollectionType.builtIn:default:return l??e}})(),l??e,s??t,u??o,c??n],d=new Set;for(let e of i){if(!e||d.has(e))continue;d.add(e);let t=e.find(e=>!!(0,y.canFindTool)(e.id,a.provider_id)||!!a.plugin_id&&e.plugin_id===a.plugin_id||a.provider_name===e.name);if(t){let e=m(r,t.icon,t.icon_dark);if(e)return e}}let g=m(r,a.provider_icon,a.provider_icon_dark);return g||void 0}if(E(a))return g?.find(e=>e.plugin_id===a.plugin_id)?.icon},[d,i,e,t,o,n,r])},"useToolIcon",0,e=>{let{data:t}=(0,f.useAllBuiltInTools)(),{data:o}=(0,f.useAllCustomTools)(),{data:n}=(0,f.useAllWorkflowTools)(),{data:i}=(0,f.useAllMCPTools)(),d=(0,I.useStore)(e=>e.dataSourceList),{data:r}=(0,h.useAllTriggerPlugins)(),{theme:l}=(0,g.default)();return(0,a.useMemo)(()=>{if(!e)return"";if(S(e)){let t=_([e.plugin_id,e.provider_id,e.provider_name],r,l);if(t)return t}if(k(e)){let a;switch(e.provider_type){case p.CollectionType.custom:a=o;break;case p.CollectionType.mcp:a=i;break;case p.CollectionType.workflow:a=n;break;case p.CollectionType.builtIn:default:a=t}let d=[a,t,o,n,i],r=new Set;for(let t of d){if(!t||r.has(t))continue;r.add(t);let a=t.find(t=>!!(0,y.canFindTool)(t.id,e.provider_id)||!!e.plugin_id&&t.plugin_id===e.plugin_id||e.provider_name===t.name);if(a){let e=m(l,a.icon,a.icon_dark);if(e)return e}}let s=m(l,e.provider_icon,e.provider_icon_dark);return s||""}return E(e)&&d?.find(t=>t.plugin_id===e.plugin_id)?.icon||""},[e,d,t,o,n,i,r,l])}],95131),e.s(["getTriggerCheckParams",0,(e,t,a)=>{if(!t)return{triggerInputsSchema:[],isReadyForCheckValid:!1};let{provider_id:o,provider_name:n,event_name:i}=e,d=t.find(e=>e.name===n||e.id===o||o&&e.plugin_id===o),r=d?.events.find(e=>e.name===i);return{triggerInputsSchema:(r?.parameters||[]).map(e=>{let t=e.label?.[a]||e.label?.en_US||e.name;return{variable:e.name,label:t,required:e.required}}),isReadyForCheckValid:!0}}],227785)},720315,205707,e=>{"use strict";e.s(["useIsChatMode",()=>S,"useIsNodeInIteration",()=>_,"useIsNodeInLoop",()=>w,"useNodesReadOnly",()=>m,"useWorkflow",()=>k,"useWorkflowReadOnly",()=>E],720315);var t=e.i(964001),a=e.i(942347),o=e.i(841501),n=e.i(189299),i=e.i(786191),d=e.i(4520),r=e.i(648404);e.i(845780);var l=e.i(148280),s=e.i(959752),u=e.i(963855),c=e.i(534042);e.i(275225);var p=e.i(705405),g=e.i(390622);function f(e){let t=e.find(e=>(0,g.isTriggerNode)(e.data.type));return t||e.find(e=>e.data.type===g.BlockEnum.Start)}function h(e){return e===g.BlockEnum.Start||(0,g.isTriggerNode)(e)}function y(e){return e.some(e=>(0,g.isTriggerNode)(e.data.type))}e.s(["getWorkflowEntryNode",()=>f,"isTriggerWorkflow",()=>y,"isWorkflowEntryNode",()=>h],205707);var I=e.i(3340);let S=()=>{let e=(0,n.useStore)(e=>e.appDetail);return e?.mode===r.AppModeEnum.ADVANCED_CHAT},k=()=>{let e=(0,o.useStoreApi)(),{getAvailableBlocks:n}=(0,I.useAvailableBlocks)(),{nodesMap:r}=(0,l.useNodesMetaData)(),p=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState();return a().find(e=>e.id===t)},[e]),g=(0,a.useCallback)(a=>{let{getNodes:n,edges:l}=e.getState(),u=n(),c=u.find(e=>e.id===a),p=u.filter(e=>r?.[e.data.type]?.metaData.isStart)||[];if(c?.parentId){let e=u.find(e=>e.parentId===c.parentId&&(e.type===i.CUSTOM_ITERATION_START_NODE||e.type===d.CUSTOM_LOOP_START_NODE));e&&(p=[e])}if(!p.length)return[];let g=[],f=(e,t)=>{if(e.id===a)return;let n=(0,o.getOutgoers)(e,u,l);n.length?n.forEach(e=>{f(e,t)}):e.id!==a&&t(e)};p.forEach(e=>{f(e,e=>{g.push(e)})});let h=(0,o.getIncomers)({id:a},u,l);return g.push(...h),(0,t.uniqBy)(g,"id").filter(e=>s.SUPPORT_OUTPUT_VARS_NODE.includes(e.data.type))},[e,r]),y=(0,a.useCallback)((a,n,i)=>{let{getNodes:d,edges:r}=e.getState(),l=n||d(),u=l.find(e=>e.id===a),c=[];if(!u)return c;if(u.parentId){let e=l.find(e=>e.id===u.parentId);if(e){let t=y(e.id);c.push(...t)}}let p=(e,t)=>{if(e){let a=(0,o.getIncomers)(e,l,i||r);a.length&&a.forEach(e=>{c.find(t=>e.id===t.id)||(t(e),p(e,t))})}};return(p(u,e=>{c.push(e)}),c.length)?(0,t.uniqBy)(c,"id").reverse().filter(e=>s.SUPPORT_OUTPUT_VARS_NODE.includes(e.data.type)):[]},[e]),S=(0,a.useCallback)((t,a,o)=>{let n=y(t,a,o),{getNodes:i}=e.getState(),d=i(),r=d.find(e=>e.id===t),l=r?.parentId,s=d.find(e=>e.id===l);return s&&n.push(s),n},[y,e]),k=(0,a.useCallback)(a=>{let{getNodes:n,edges:i}=e.getState(),d=n(),r=d.find(e=>e.id===a);if(!r)return[];let l=[r],s=(e,t)=>{if(e){let a=(0,o.getOutgoers)(e,d,i);a.length&&a.forEach(e=>{t(e),s(e,t)})}};return s(r,e=>{l.push(e)}),(0,t.uniqBy)(l,"id")},[e]),E=(0,a.useCallback)(t=>{let{getNodes:a,edges:n}=e.getState(),i=a(),d=i.find(e=>e.id===t);return(0,o.getIncomers)(d,i,n)},[e]),m=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState();return a().filter(e=>e.parentId===t)},[e]),_=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState();return a().filter(e=>e.parentId===t)},[e]),w=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState(),o=a().find(e=>e.id===t);if(!o)return!1;if(h(o.data.type))return!0;let n=e=>{for(let t of E(e.id))if(h(t.data.type)||n(t))return!0;return!1};return n(o)},[e,E]),T=(0,a.useCallback)((t,a,o)=>{let{getNodes:n,setNodes:i}=e.getState(),d=n(),r=(0,u.findUsedVarNodes)(a,d);r.length>0&&i(d.map(e=>r.find(t=>t.id===e.id)?(0,u.updateNodeVars)(e,a,o):e))},[e]),N=(0,a.useCallback)(e=>{let t=k(e[0]);return(0,u.findUsedVarNodes)(e,t).length>0},[k]),C=(0,a.useCallback)(t=>{let a=t[0],{getNodes:o,setNodes:n}=e.getState(),i=k(a),d=(0,u.findUsedVarNodes)(t,i);d.length>0&&n(o().map(e=>d.find(t=>t.id===e.id)?(0,u.updateNodeVars)(e,t,[]):e))},[k,e]),v=(0,a.useCallback)((e,t)=>(0,u.getNodeOutputVars)(e,t).some(e=>N(e)),[N]),D=(0,a.useCallback)(a=>{let{getNodes:n,edges:i}=e.getState(),d=n(),r=d.find(e=>e.id===a),l=[];if(!r)return l;if(r.parentId){let e=d.find(e=>e.id===r.parentId);if(e){let t=D(e.id);l.push(...t)}}let s=(e,t)=>{if(e){let a=(0,o.getIncomers)(e,d,i);a.length?a.forEach(e=>{s(e,t)}):t(e)}};return(s(r,e=>{l.push(e)}),l.length)?(0,t.uniqBy)(l,"id"):[]},[e]),b=(0,a.useCallback)((e,t)=>{let{id:a,parentId:o}=t||{},n=[];if(o){let t=e.find(e=>e.id===o);if(!t)throw Error("Parent node not found");let a=e.find(e=>e.id===t.data.start_node_id);a&&(n=[a])}else n=e.filter(e=>r?.[e.data.type]?.metaData.isStart)||[];return n.length||(n=D(a||"")),n},[r,D]);return{getNodeById:p,getTreeLeafNodes:g,getBeforeNodesInSameBranch:y,getBeforeNodesInSameBranchIncludeParent:S,getAfterNodesInSameBranch:k,handleOutVarRenameChange:T,isVarUsedInNodes:N,removeUsedVarInNodes:C,isNodeVarsUsedInNodes:v,isValidConnection:(0,a.useCallback)(t=>{let{source:a,sourceHandle:i,target:d}=t,{edges:r,getNodes:l}=e.getState(),s=l(),u=s.find(e=>e.id===a),p=s.find(e=>e.id===d);if(u.type===c.CUSTOM_NOTE_NODE||p.type===c.CUSTOM_NOTE_NODE||u.parentId!==p.parentId)return!1;if(u&&p){let e=n(u.data.type,!!u.parentId).availableNextBlocks,t=n(p.data.type,!!p.parentId).availablePrevBlocks;if(!e.includes(p.data.type)||!t.includes(u.data.type))return!1}let g=function(e){let t=arguments.length>1&&void 0!==arguments[1]?arguments[1]:new Set;if(t.has(e.id))return!1;for(let n of(t.add(e.id),(0,o.getOutgoers)(e,s,r)))if(n.id===a||g(n,t))return!0};return!g(p)},[e,n]),getBeforeNodeById:E,getIterationNodeChildren:m,getLoopNodeChildren:_,getRootNodesById:D,getStartNodes:b,isFromStartNode:w,getNode:(0,a.useCallback)(t=>{let{getNodes:a}=e.getState(),o=a();return o.find(e=>e.id===t)||f(o)},[e])}},E=()=>{let e=(0,p.useWorkflowStore)(),t=(0,p.useStore)(e=>e.workflowRunningData),o=(0,a.useCallback)(()=>e.getState().workflowRunningData?.result.status===g.WorkflowRunningStatus.Running,[e]);return{workflowReadOnly:t?.result.status===g.WorkflowRunningStatus.Running,getWorkflowReadOnly:o}},m=()=>{let e=(0,p.useWorkflowStore)(),t=(0,p.useStore)(e=>e.workflowRunningData),o=(0,p.useStore)(e=>e.historyWorkflowData),n=(0,p.useStore)(e=>e.isRestoring),i=(0,a.useCallback)(()=>{let{workflowRunningData:t,historyWorkflowData:a,isRestoring:o}=e.getState();return!!(t?.result.status===g.WorkflowRunningStatus.Running||t?.result.status===g.WorkflowRunningStatus.Paused||a||o)},[e]);return{nodesReadOnly:!!(t?.result.status===g.WorkflowRunningStatus.Running||t?.result.status===g.WorkflowRunningStatus.Paused||o||n),getNodesReadOnly:i}},_=e=>{let t=(0,o.useStoreApi)();return{isNodeInIteration:(0,a.useCallback)(a=>{let{getNodes:o}=t.getState(),n=o().find(e=>e.id===a);return!!n&&n.parentId===e},[e,t])}},w=e=>{let t=(0,o.useStoreApi)();return{isNodeInLoop:(0,a.useCallback)(a=>{let{getNodes:o}=t.getState(),n=o().find(e=>e.id===a);return!!n&&n.parentId===e},[e,t])}}},944419,949250,804612,e=>{"use strict";e.s(["useChecklist",()=>x,"useChecklistBeforePublish",()=>H,"useWorkflowRunValidation",()=>R],944419);var t=e.i(942347);e.i(816688);var a=e.i(675066),o=e.i(841501),n=e.i(189299),i=e.i(734962),d=e.i(739255),r=e.i(225162),l=e.i(616332),s=e.i(925521),u=e.i(683257),c=e.i(211857),p=e.i(243922),g=e.i(154033),f=e.i(819114),h=e.i(648404),y=e.i(959752),I=e.i(18084);e.i(845780);var S=e.i(95131),k=e.i(148280),E=e.i(963855);e.i(275225);var m=e.i(705405),_=e.i(390622);e.i(905691);var w=e.i(451660),T=e.i(476285),N=e.i(911684),C=e.i(227785),v=e.i(720315);e.s(["useWorkflowVariableType",()=>O,"useWorkflowVariables",()=>b],949250);var D=e.i(840247);let b=()=>{let{t:e}=(0,a.useTranslation)(),o=(0,m.useWorkflowStore)(),{schemaTypeDefinitions:n}=(0,D.default)(),{data:i}=(0,g.useAllBuiltInTools)(),{data:d}=(0,g.useAllCustomTools)(),{data:r}=(0,g.useAllWorkflowTools)(),{data:l}=(0,g.useAllMCPTools)();return{getNodeAvailableVars:(0,t.useCallback)(t=>{let{parentNode:a,beforeNodes:s,isChatMode:u,filterVar:c,hideEnv:p,hideChatVar:g}=t,{conversationVariables:f,environmentVariables:h,ragPipelineVariables:y,dataSourceList:I}=o.getState();return(0,E.toNodeAvailableVars)({parentNode:a,t:e,beforeNodes:s,isChatMode:u,environmentVariables:p?[]:h,conversationVariables:u&&!g?f:[],ragVariables:y,filterVar:c,allPluginInfoList:{buildInTools:i||[],customTools:d||[],workflowTools:r||[],mcpTools:l||[],dataSourceList:I||[]},schemaTypeDefinitions:n})},[e,o,n,i,d,r,l]),getCurrentVariableType:(0,t.useCallback)(e=>{let{parentNode:t,valueSelector:a,isIterationItem:s,isLoopItem:u,availableNodes:c,isChatMode:p,isConstant:g,preferSchemaType:f}=e,{conversationVariables:h,environmentVariables:y,ragPipelineVariables:I,dataSourceList:S}=o.getState();return(0,E.getVarType)({parentNode:t,valueSelector:a,isIterationItem:s,isLoopItem:u,availableNodes:c,isChatMode:p,isConstant:g,environmentVariables:y,conversationVariables:h,ragVariables:I,allPluginInfoList:{buildInTools:i||[],customTools:d||[],workflowTools:r||[],mcpTools:l||[],dataSourceList:S??[]},schemaTypeDefinitions:n,preferSchemaType:f})},[o,n,i,d,r,l])}},O=()=>{let{getNodes:e}=(0,o.useStoreApi)().getState(),{getCurrentVariableType:t}=b(),a=(0,v.useIsChatMode)();return o=>{let{nodeId:n,valueSelector:i}=o,d=e().find(e=>e.id===n);return t({parentNode:d?.data.isInIteration?e().find(e=>e.id===d.parentId):null,valueSelector:i,availableNodes:[d],isChatMode:a,isConstant:!1})}},A=(e,t)=>{let a=t.find(t=>t.id===e),o=!!a?.data.isInIteration,n=!!a?.data.isInLoop,i=a?.parentId;return{node:a,isInIteration:o,isInLoop:n,parentNode:t.find(e=>e.id===i)}},P=function(e){let{onlyLeafNodeVar:t,filterVar:a,hideEnv:o=!1,hideChatVar:n=!1,passedInAvailableNodes:i}=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{onlyLeafNodeVar:!1,filterVar:()=>!0},{getTreeLeafNodes:d,getBeforeNodesInSameBranchIncludeParent:r}=(0,v.useWorkflow)(),{getNodeAvailableVars:l}=b(),s=(0,v.useIsChatMode)(),u={};return e.forEach(c=>{let p=c.id,g=i||(t?d(p):r(p));c.data.type===_.BlockEnum.Loop&&g.push(c);let{parentNode:f}=A(p,e),h=l({parentNode:f,beforeNodes:g,isChatMode:s,filterVar:a,hideEnv:o,hideChatVar:n});u[p]={node:c,availableVars:h,availableNodes:g}}),u},B=[_.BlockEnum.Start,_.BlockEnum.TriggerSchedule,_.BlockEnum.TriggerWebhook,_.BlockEnum.TriggerPlugin],M=[_.BlockEnum.Tool,_.BlockEnum.DataSource,_.BlockEnum.TriggerPlugin],x=(e,o)=>{let{t:i}=(0,a.useTranslation)(),l=(0,u.useGetLanguage)(),{nodesMap:s}=(0,k.useNodesMetaData)(),{data:c}=(0,g.useAllBuiltInTools)(),{data:v}=(0,g.useAllCustomTools)(),{data:D}=(0,g.useAllWorkflowTools)(),b=(0,m.useStore)(e=>e.dataSourceList),{data:O}=(0,p.useStrategyProviders)(),{data:A}=(0,f.useAllTriggerPlugins)(),x=(0,I.useDatasetsDetailStore)(e=>e.datasetsDetail),H=(0,S.useGetToolIcon)(),R=n.useStore.getState().appDetail?.mode,L=R===h.AppModeEnum.WORKFLOW||R===h.AppModeEnum.ADVANCED_CHAT,W=P(e),{data:V}=(0,r.useModelList)(d.ModelTypeEnum.textEmbedding),{data:U}=(0,r.useModelList)(d.ModelTypeEnum.rerank),$=(0,t.useCallback)(e=>{let t=e;if(e.type===_.BlockEnum.KnowledgeRetrieval){let a=e.dataset_ids.reduce((e,t)=>(x[t]&&e.push(x[t]),e),[]);t={...e,_datasets:a}}else e.type===_.BlockEnum.KnowledgeBase&&(t={...e,_embeddingModelList:V,_rerankModelList:U});return t},[x,V,U]);return(0,t.useMemo)(()=>{let t=[],a=e.filter(e=>e.type===y.CUSTOM_NODE),{validNodes:n}=(0,N.getValidTreeNodes)(a,o);for(let e=0;et.declaration.identity.name===e.agent_strategy_provider_name),n=a?.declaration.strategies?.find(t=>t.identity.name===e.agent_strategy_name);o={provider:a,strategy:n,language:l,isReadyForCheckValid:t}}else r=(0,E.getNodeUsedVars)(d).filter(e=>e.length>0);if(d.type===y.CUSTOM_NODE){let e,a=$(d.data),l=s?.[d.data.type]?.checkValid,c=M.includes(d.data.type)&&d.data._pluginInstallLocked;if(c?e=i("nodes.common.pluginNotInstalled",{ns:"workflow"}):l&&(e=l(a,i,o).errorMessage),!e){let t=W[d.id].availableVars;for(let a of r)if(!(0,E.isSpecialVar)(a[0])){let o=t.find(e=>e.nodeId===a?.[0]);o&&o.vars.find(e=>e.variable===a?.[1])||(e=i("errorMsg.invalidVariable",{ns:"workflow"}))}}let p=s?.[d.data.type]?.metaData.isStart??!1,g=!L||p,f=!n.find(e=>e.id===d.id);(e||f&&!g)&&t.push({id:d.id,type:d.data.type,title:d.data.title,toolIcon:u,unConnected:f&&!g,errorMessage:e,canNavigate:!c,disableGoTo:c})}}return L&&0===e.filter(e=>B.includes(e.data.type)).length&&t.push({id:"start-node-required",type:_.BlockEnum.Start,title:i("panel.startNode",{ns:"workflow"}),errorMessage:i("common.needStartNode",{ns:"workflow"}),canNavigate:!1}),Object.keys(s).filter(e=>s[e].metaData.isRequired).forEach(e=>{a.find(t=>t.data.type===e)||t.push({id:`${e}-need-added`,type:e,title:i(`blocks.${e}`,{ns:"workflow"}),errorMessage:i("common.needAdd",{ns:"workflow",node:i(`blocks.${e}`,{ns:"workflow"})}),canNavigate:!1})}),t},[e,o,L,s,c,v,D,l,b,A,H,O,$,i,W])},H=()=>{let{t:e}=(0,a.useTranslation)(),l=(0,u.useGetLanguage)(),{notify:f}=(0,i.useToastContext)(),S=(0,o.useStoreApi)(),{nodesMap:C}=(0,k.useNodesMetaData)(),{data:D}=(0,p.useStrategyProviders)(),O=(0,I.useDatasetsDetailStore)(e=>e.updateDatasetsDetail),P=(0,t.useRef)(0),M=(0,m.useWorkflowStore)(),{getNodesAvailableVarList:x}=(()=>{let{getTreeLeafNodes:e,getBeforeNodesInSameBranchIncludeParent:a}=(0,v.useWorkflow)(),{getNodeAvailableVars:o}=b(),n=(0,v.useIsChatMode)();return{getNodesAvailableVarList:(0,t.useCallback)(function(t){let{onlyLeafNodeVar:i,filterVar:d,hideEnv:r,hideChatVar:l,passedInAvailableNodes:s}=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{onlyLeafNodeVar:!1,filterVar:()=>!0},u={};return t.forEach(c=>{let p=c.id,g=s||(i?e(p):a(p));c.data.type===_.BlockEnum.Loop&&g.push(c);let{parentNode:f}=A(p,t),h=o({parentNode:f,beforeNodes:g,isChatMode:n,filterVar:d,hideEnv:r,hideChatVar:l});u[p]={node:c,availableVars:h,availableNodes:g}}),u},[e,a,o,n])}})(),{data:H}=(0,r.useModelList)(d.ModelTypeEnum.textEmbedding),{data:R}=(0,r.useModelList)(d.ModelTypeEnum.rerank),{data:L}=(0,g.useAllBuiltInTools)(),{data:W}=(0,g.useAllCustomTools)(),{data:V}=(0,g.useAllWorkflowTools)(),U=n.useStore.getState().appDetail?.mode,$=U===h.AppModeEnum.WORKFLOW||U===h.AppModeEnum.ADVANCED_CHAT,z=(0,t.useCallback)((e,t)=>{let a=e;if(e.type===_.BlockEnum.KnowledgeRetrieval){let o=e.dataset_ids,n=t.reduce((e,t)=>(e[t.id]=t,e),{}),i=o.reduce((e,t)=>(n[t]&&e.push(n[t]),e),[]);a={...e,_datasets:i}}else e.type===_.BlockEnum.KnowledgeBase&&(a={...e,_embeddingModelList:H,_rerankModelList:R});return a},[H,R]);return{handleCheckBeforePublish:(0,t.useCallback)(async()=>{let{getNodes:t,edges:a}=S.getState(),{dataSourceList:o}=M.getState(),n=t(),i=n.filter(e=>e.type===y.CUSTOM_NODE),{validNodes:d,maxDepth:r}=(0,N.getValidTreeNodes)(i,a);if(r>s.MAX_TREE_DEPTH)return f({type:"error",message:e("common.maxTreeDepth",{ns:"workflow",depth:s.MAX_TREE_DEPTH})}),!1;let u=i.filter(e=>e.data.type===_.BlockEnum.KnowledgeRetrieval).reduce((e,t)=>Array.from(new Set([...e,...t.data.dataset_ids])),[]),p=[];if(u.length>0){P.current=P.current+1;let e=P.current,{data:t}=await (0,c.fetchDatasets)({url:"/datasets",params:{page:1,ids:u}});if(t&&t.length>0){if(et.declaration.identity.name===e.agent_strategy_provider_name),i=o?.declaration.strategies?.find(t=>t.identity.name===e.agent_strategy_name);a={provider:o,strategy:i,language:l,isReadyForCheckValid:t}}else r=(0,E.getNodeUsedVars)(n).filter(e=>e.length>0);let s=z(n.data,p),{errorMessage:u}=C[n.data.type].checkValid(s,e,a);if(u)return f({type:"error",message:`[${n.data.title}] ${u}`}),!1;let c=g[n.id].availableVars;for(let t of r)if(!(0,E.isSpecialVar)(t[0])){let a=c.find(e=>e.nodeId===t?.[0]);if(!a||!a.vars.find(e=>e.variable===t?.[1]))return f({type:"error",message:`[${n.data.title}] ${e("errorMsg.invalidVariable",{ns:"workflow"})}`}),!1}let h=C?.[n.data.type]?.metaData.isStart??!1,y=!$||h;if(!d.find(e=>e.id===n.id)&&!y)return f({type:"error",message:`[${n.data.title}] ${e("common.needConnectTip",{ns:"workflow"})}`}),!1}if($&&0===n.filter(e=>B.includes(e.data.type)).length)return f({type:"error",message:e("common.needStartNode",{ns:"workflow"})}),!1;let h=Object.keys(C).filter(e=>C[e].metaData.isRequired);for(let t=0;te.data.type===a))return f({type:"error",message:e("common.needAdd",{ns:"workflow",node:e(`blocks.${a}`,{ns:"workflow"})})}),!1}return!0},[S,M,x,$,C,f,e,O,L,W,V,l,z,D])}},R=()=>{let{t:e}=(0,a.useTranslation)(),n=x((0,l.default)(),(0,o.useEdges)()),{notify:d}=(0,i.useToastContext)();return{validateBeforeRun:(0,t.useCallback)(()=>!(n.length>0)||(d({type:"error",message:e("panel.checklistTip",{ns:"workflow"})}),!1),[n,d,e]),hasValidationErrors:n.length>0,warningNodes:n}};e.i(491401);var L=e.i(585736);e.s(["useDSL",0,()=>({exportCheck:(0,L.useHooksStore)(e=>e.exportCheck),handleExportDSL:(0,L.useHooksStore)(e=>e.handleExportDSL)})],804612)},604208,e=>{"use strict";e.s(["useNodesSyncDraft",()=>i]);var t=e.i(942347);e.i(491401);var a=e.i(585736);e.i(275225);var o=e.i(705405),n=e.i(720315);let i=()=>{let{getNodesReadOnly:e}=(0,n.useNodesReadOnly)(),i=(0,o.useStore)(e=>e.debouncedSyncWorkflowDraft),d=(0,a.useHooksStore)(e=>e.doSyncWorkflowDraft),r=(0,a.useHooksStore)(e=>e.syncWorkflowDraftWhenPageClose),l=(0,t.useCallback)((t,a,o)=>{e()||(t?d(a,o):i(d))},[i,d,e]);return{doSyncWorkflowDraft:d,handleSyncWorkflowDraft:l,syncWorkflowDraftWhenPageClose:r}}},735738,276145,339512,959095,554499,91025,781988,265522,257988,568603,77352,e=>{"use strict";e.s(["useEdgesInteractions",()=>_],735738);var t=e.i(805735),a=e.i(942347),o=e.i(841501);e.i(275225);var n=e.i(705405);e.i(905691);var i=e.i(911684),d=e.i(604208),r=e.i(720315),l=e.i(328817);e.i(816688);var s=e.i(675066),u=e.i(162115),c=e.i(220365),p=e.i(65932),g=e.i(613763),f=(e,t,a)=>(o,n)=>({pastStates:a?.pastStates||[],futureStates:a?.futureStates||[],undo:function(){let i=arguments.length>0&&void 0!==arguments[0]?arguments[0]:1;if(n().pastStates.length){let d=a?.partialize?.(t())||t(),r=n().pastStates.splice(-i,i),l=r.shift();e(l),o({pastStates:n().pastStates,futureStates:n().futureStates.concat(a?.diff?.(d,l)||d,r.reverse())})}},redo:function(){let i=arguments.length>0&&void 0!==arguments[0]?arguments[0]:1;if(n().futureStates.length){let d=a?.partialize?.(t())||t(),r=n().futureStates.splice(-i,i),l=r.shift();e(l),o({pastStates:n().pastStates.concat(a?.diff?.(d,l)||d,r.reverse()),futureStates:n().futureStates})}},clear:()=>o({pastStates:[],futureStates:[]}),isTracking:!0,pause:()=>o({isTracking:!1}),resume:()=>o({isTracking:!0}),setOnSave:e=>o({_onSave:e}),_onSave:a?.onSave,_handleSet:(e,t,i,d)=>{a?.limit&&n().pastStates.length>=a?.limit&&n().pastStates.shift(),n()._onSave?.(e,i),o({pastStates:n().pastStates.concat(d||e),futureStates:[]})}}),h=e.i(534011);let y=(0,a.createContext)({store:null,shortcutsEnabled:!0,setShortcutsEnabled:c.noop}),I=y.Provider;function S(e){let{nodes:t,edges:o,children:n}=e,[i,d]=(0,a.useState)(!0),[r]=(0,a.useState)(()=>(function(e){var t,a;let{nodes:o,edges:n}=e;return(0,h.create)((t=(e,t)=>({workflowHistoryEvent:void 0,workflowHistoryEventMeta:void 0,nodes:o,edges:n,getNodes:()=>t().nodes,setNodes:t=>e({nodes:t}),setEdges:t=>e({edges:t})}),a={equality:(e,t)=>(0,p.default)(e,t)},(e,o,n)=>{n.temporal=(0,g.createStore)(a?.wrapTemporal?.(f(e,o,a))||f(e,o,a));let i=a?.handleSet?.(n.temporal.getState()._handleSet)||n.temporal.getState()._handleSet,d=e=>{if(!n.temporal.getState().isTracking)return;let t=a?.partialize?.(o())||o(),d=a?.diff?.(e,t);null===d||a?.equality?.(e,t)||i(e,void 0,t,d)},r=n.setState;return n.setState=function(){for(var e=arguments.length,t=Array(e),n=0;n({getState:e.getState,setState:t=>{e.setState({workflowHistoryEvent:t.workflowHistoryEvent,workflowHistoryEventMeta:t.workflowHistoryEventMeta,nodes:t.nodes.map(e=>({...e,data:{...e.data,selected:!1}})),edges:t.edges.map(e=>({...e,selected:!1}))})},subscribe:e.subscribe,temporal:e.temporal}),[e]),shortcutsEnabled:t,setShortcutsEnabled:o}}e.s(["WorkflowHistoryProvider",()=>S,"useWorkflowHistoryStore",()=>k],276145);let E={NodeTitleChange:"NodeTitleChange",NodeDescriptionChange:"NodeDescriptionChange",NodeDragStop:"NodeDragStop",NodeChange:"NodeChange",NodeConnect:"NodeConnect",NodePaste:"NodePaste",NodeDelete:"NodeDelete",EdgeDelete:"EdgeDelete",EdgeDeleteByDeleteBranch:"EdgeDeleteByDeleteBranch",EdgeSourceHandleChange:"EdgeSourceHandleChange",NodeAdd:"NodeAdd",NodeResize:"NodeResize",NoteAdd:"NoteAdd",NoteChange:"NoteChange",NoteDelete:"NoteDelete",LayoutOrganize:"LayoutOrganize"},m=()=>{let e=(0,o.useStoreApi)(),{store:t}=k(),{t:n}=(0,s.useTranslation)(),[i,d]=(0,a.useState)([]),[r,u]=(0,a.useState)([]),c=(0,a.useCallback)(e=>(d(t=>[...t,e]),()=>d(t=>t.filter(t=>t!==e))),[]),p=(0,a.useCallback)(e=>(u(t=>[...t,e]),()=>u(t=>t.filter(t=>t!==e))),[]),g=(0,a.useCallback)(()=>{t.temporal.getState().undo(),i.forEach(e=>e())},[i,t.temporal]),f=(0,a.useCallback)(()=>{t.temporal.getState().redo(),r.forEach(e=>e())},[r,t.temporal]),h=(0,a.useRef)((0,l.debounce)((a,o)=>{t.setState({workflowHistoryEvent:a,workflowHistoryEventMeta:o,nodes:e.getState().getNodes(),edges:e.getState().edges})},500));return{store:t,saveStateToHistory:(0,a.useCallback)((e,t)=>{switch(e){case E.NoteChange:case E.NodeTitleChange:case E.NodeDescriptionChange:case E.NodeDragStop:case E.NodeChange:case E.NodeConnect:case E.NodePaste:case E.NodeDelete:case E.EdgeDelete:case E.EdgeDeleteByDeleteBranch:case E.NodeAdd:case E.NodeResize:case E.NoteAdd:case E.LayoutOrganize:case E.NoteDelete:h.current(e,t)}},[]),getHistoryLabel:(0,a.useCallback)(e=>{switch(e){case E.NodeTitleChange:return n("changeHistory.nodeTitleChange",{ns:"workflow"});case E.NodeDescriptionChange:return n("changeHistory.nodeDescriptionChange",{ns:"workflow"});case E.LayoutOrganize:case E.NodeDragStop:return n("changeHistory.nodeDragStop",{ns:"workflow"});case E.NodeChange:return n("changeHistory.nodeChange",{ns:"workflow"});case E.NodeConnect:return n("changeHistory.nodeConnect",{ns:"workflow"});case E.NodePaste:return n("changeHistory.nodePaste",{ns:"workflow"});case E.NodeDelete:return n("changeHistory.nodeDelete",{ns:"workflow"});case E.NodeAdd:return n("changeHistory.nodeAdd",{ns:"workflow"});case E.EdgeDelete:case E.EdgeDeleteByDeleteBranch:return n("changeHistory.edgeDelete",{ns:"workflow"});case E.NodeResize:return n("changeHistory.nodeResize",{ns:"workflow"});case E.NoteAdd:return n("changeHistory.noteAdd",{ns:"workflow"});case E.NoteChange:return n("changeHistory.noteChange",{ns:"workflow"});case E.NoteDelete:return n("changeHistory.noteDelete",{ns:"workflow"});default:return"Unknown Event"}},[n]),undo:g,redo:f,onUndo:c,onRedo:p}};e.s(["WorkflowHistoryEvent",0,E,"useWorkflowHistory",0,m],339512);let _=()=>{let e=(0,o.useStoreApi)(),l=(0,n.useWorkflowStore)(),{handleSyncWorkflowDraft:s}=(0,d.useNodesSyncDraft)(),{getNodesReadOnly:u}=(0,r.useNodesReadOnly)(),{saveStateToHistory:c}=m(),p=(0,a.useCallback)(a=>{let{getNodes:o,setNodes:n,edges:d,setEdges:r}=e.getState(),u=d.findIndex(e=>e.id===a);if(u<0)return;let p=d[u],g=o(),f=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([{type:"remove",edge:p}],g);n((0,t.produce)(g,e=>{e.forEach(e=>{f[e.id]&&(e.data={...e.data,...f[e.id]})})})),r((0,t.produce)(d,e=>{e.splice(u,1)}));let h=l.getState().edgeMenu;h?.edgeId===p.id&&l.setState({edgeMenu:void 0}),s(),c(E.EdgeDelete)},[e,l,s,c]),g=(0,a.useCallback)((a,o)=>{if(u())return;let{edges:n,setEdges:i}=e.getState();i((0,t.produce)(n,e=>{e.find(e=>e.id===o.id).data._hovering=!0}))},[e,u]),f=(0,a.useCallback)((a,o)=>{if(u())return;let{edges:n,setEdges:i}=e.getState();i((0,t.produce)(n,e=>{e.find(e=>e.id===o.id).data._hovering=!1}))},[e,u]),h=(0,a.useCallback)((a,o)=>{if(u())return;let{getNodes:n,setNodes:d,edges:r,setEdges:p}=e.getState(),g=r.filter(e=>e.source===a&&e.sourceHandle===o);if(!g.length)return;let f=n(),h=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)(g.map(e=>({type:"remove",edge:e})),f);d((0,t.produce)(f,e=>{e.forEach(e=>{h[e.id]&&(e.data={...e.data,...h[e.id]})})})),p((0,t.produce)(r,e=>e.filter(e=>!g.find(t=>t.id===e.id))));let y=l.getState().edgeMenu;y&&g.some(e=>e.id===y.edgeId)&&l.setState({edgeMenu:void 0}),s(),c(E.EdgeDeleteByDeleteBranch)},[u,e,l,s,c]),y=(0,a.useCallback)(()=>{if(u())return;let{edges:t}=e.getState(),a=t.find(e=>e.selected);a&&p(a.id)},[p,u,e]),I=(0,a.useCallback)(e=>{u()||p(e)},[p,u]),S=(0,a.useCallback)(a=>{if(u())return;let{edges:o,setEdges:n}=e.getState();n((0,t.produce)(o,e=>{a.forEach(t=>{"select"===t.type&&(e.find(e=>e.id===t.id).selected=t.selected)})}))},[e,u]);return{handleEdgeEnter:g,handleEdgeLeave:f,handleEdgeDeleteByDeleteBranch:h,handleEdgeDelete:y,handleEdgeDeleteById:I,handleEdgesChange:S,handleEdgeSourceHandleChange:(0,a.useCallback)((a,o,n)=>{if(u())return;let{getNodes:d,setNodes:r,edges:p,setEdges:g}=e.getState(),f=d(),h=p.filter(e=>e.source===a&&e.sourceHandle===o);if(0===h.length)return;let y=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([...h.map(e=>({type:"remove",edge:e})),...h.map(e=>({type:"add",edge:{...e,sourceHandle:n}}))],f);r((0,t.produce)(f,e=>{e.forEach(e=>{y[e.id]&&(e.data={...e.data,...y[e.id]})})}));let I=(0,t.produce)(p,e=>{e.forEach(e=>{e.source===a&&e.sourceHandle===o&&(e.sourceHandle=n,e.id=`${e.source}-${n}-${e.target}-${e.targetHandle}`)})});g(I);let S=l.getState().edgeMenu;S&&!I.some(e=>e.id===S.edgeId)&&l.setState({edgeMenu:void 0}),s(),c(E.EdgeSourceHandleChange)},[u,e,l,s,c]),handleEdgeContextMenu:(0,a.useCallback)((a,o)=>{if(u())return;a.preventDefault();let{getNodes:n,setNodes:i,edges:d,setEdges:r}=e.getState();r((0,t.produce)(d,e=>{e.forEach(e=>{e.selected=e.id===o.id,e.data._isBundled&&(e.data._isBundled=!1)})}));let s=n();s.some(e=>e.data.selected||e.selected||e.data._isBundled)&&i((0,t.produce)(s,e=>{e.forEach(e=>{e.data.selected=!1,e.data._isBundled&&(e.data._isBundled=!1),e.selected=!1})})),l.setState({nodeMenu:void 0,panelMenu:void 0,selectionMenu:void 0,edgeMenu:{clientX:a.clientX,clientY:a.clientY,edgeId:o.id}})},[e,l,u])}};e.i(491401);var w=e.i(585736),T=e.i(387852),N=e.i(480600),C=e.i(390622);let v=["query","files"],D=()=>{let e=(0,n.useStore)(e=>e.nodesWithInspectVars),a=(0,w.useHooksStore)(e=>e.configsMap),o=a?.flowType===N.FlowType.ragPipeline,{data:i}=(0,T.useConversationVarValues)(a?.flowType,o?"":a?.flowId),{data:d}=(0,T.useSysVarValues)(a?.flowType,o?"":a?.flowId),{varsAppendStartNode:r,systemVars:l}=d?.length===0?{varsAppendStartNode:[],systemVars:[]}:{varsAppendStartNode:d?.filter(e=>{let{name:t}=e;return v.includes(t)})||[],systemVars:d?.filter(e=>{let{name:t}=e;return!v.includes(t)})||[]},s=e&&0!==e.length?(0,t.produce)(e,e=>{e.forEach(e=>{e.nodeType===C.BlockEnum.Start&&(e.vars=[...e.vars,...r])})}):[],u=(0,w.useHooksStore)(e=>e.hasNodeInspectVars),c=(0,w.useHooksStore)(e=>e.hasSetInspectVar),p=(0,w.useHooksStore)(e=>e.fetchInspectVarValue),g=(0,w.useHooksStore)(e=>e.editInspectVarValue),f=(0,w.useHooksStore)(e=>e.renameInspectVarName),h=(0,w.useHooksStore)(e=>e.appendNodeInspectVars),y=(0,w.useHooksStore)(e=>e.deleteInspectVar),I=(0,w.useHooksStore)(e=>e.deleteNodeInspectorVars),S=(0,w.useHooksStore)(e=>e.deleteAllInspectorVars),k=(0,w.useHooksStore)(e=>e.isInspectVarEdited),E=(0,w.useHooksStore)(e=>e.resetToLastRunVar),m=(0,w.useHooksStore)(e=>e.invalidateSysVarValues);return{conversationVars:i||[],systemVars:l||[],nodesWithInspectVars:s,hasNodeInspectVars:u,hasSetInspectVar:c,fetchInspectVarValue:p,editInspectVarValue:g,renameInspectVarName:f,appendNodeInspectVars:h,deleteInspectVar:y,deleteNodeInspectorVars:I,deleteAllInspectorVars:S,isInspectVarEdited:k,resetToLastRunVar:E,invalidateSysVarValues:m,resetConversationVar:(0,w.useHooksStore)(e=>e.resetConversationVar),invalidateConversationVarValues:(0,w.useHooksStore)(e=>e.invalidateConversationVarValues)}};e.s(["default",0,D],959095),e.s(["useNodeDataUpdate",()=>b],554499);let b=()=>{let e=(0,o.useStoreApi)(),{handleSyncWorkflowDraft:n}=(0,d.useNodesSyncDraft)(),{getNodesReadOnly:i}=(0,r.useNodesReadOnly)(),l=(0,a.useCallback)(a=>{let{id:o,data:n}=a,{getNodes:i,setNodes:d}=e.getState();d((0,t.produce)(i(),e=>{let t=e.find(e=>e.id===o);t&&(t.data={...t.data,...n})}))},[e]),s=(0,a.useCallback)((e,t)=>{i()||(l(e),n(t?.sync,t?.notRefreshWhenSyncError,t?.callback))},[n,l,i]);return{handleNodeDataUpdate:l,handleNodeDataUpdateWithSyncDraft:s}};e.s(["useNodesInteractions",()=>V],265522);var O=e.i(959752),A=e.i(963855),P=e.i(786191);e.s(["useNodeIterationInteractions",()=>x],91025),e.i(845780);var B=e.i(148280),M=e.i(52592);let x=()=>{let{t:e}=(0,s.useTranslation)(),n=(0,o.useStoreApi)(),{nodesMap:i}=(0,B.useNodesMetaData)(),d=(0,a.useCallback)(e=>{let a,o,{getNodes:i,setNodes:d}=n.getState(),r=i(),l=r.find(t=>t.id===e);r.filter(t=>t.parentId===e).forEach(e=>{a?e.position.x+e.width>a.position.x+a.width&&(a=e):a=e,o?e.position.y+e.height>o.position.y+o.height&&(o=e):o=e});let s=a&&l.width{t.forEach(t=>{t.id===e&&(s&&(t.data.width=a.position.x+a.width+O.ITERATION_PADDING.right,t.width=a.position.x+a.width+O.ITERATION_PADDING.right),u&&(t.data.height=o.position.y+o.height+O.ITERATION_PADDING.bottom,t.height=o.position.y+o.height+O.ITERATION_PADDING.bottom))})}))},[n]),r=(0,a.useCallback)(e=>{let{getNodes:t}=n.getState(),a=t(),o={x:void 0,y:void 0};if(e.data.isInIteration){let t=a.find(t=>t.id===e.parentId);t&&(e.position.yt.width-O.ITERATION_PADDING.right&&(o.x=t.width-O.ITERATION_PADDING.right-e.width),e.position.y+e.height>t.height-O.ITERATION_PADDING.bottom&&(o.y=t.height-O.ITERATION_PADDING.bottom-e.height))}return{restrictPosition:o}},[n]),l=(0,a.useCallback)(e=>{let{getNodes:t}=n.getState(),a=t().find(t=>t.id===e).parentId;a&&d(a)},[n,d]);return{handleNodeIterationRerender:d,handleNodeIterationChildDrag:r,handleNodeIterationChildSizeChange:l,handleNodeIterationChildrenCopy:(0,a.useCallback)((t,a,o)=>{let{getNodes:d}=n.getState(),r=d(),l=r.filter(e=>e.parentId===t&&e.type!==P.CUSTOM_ITERATION_START_NODE),s={...o},u={};return{copyChildren:l.map((t,o)=>{let n=t.data.type,d=r.filter(e=>e.data.type===n);u[n]?u[n]=u[n]+1:u[n]=d.length+1;let{newNode:l}=(0,M.generateNewNode)({type:(0,M.getNodeCustomTypeByNodeDataType)(n),data:{...i[n].defaultValue,...t.data,selected:!1,_isBundled:!1,_connectedSourceHandleIds:[],_connectedTargetHandleIds:[],title:d.length>0?`${e(`blocks.${n}`,{ns:"workflow"})} ${u[n]}`:e(`blocks.${n}`,{ns:"workflow"}),iteration_id:a,type:n},position:t.position,positionAbsolute:t.positionAbsolute,parentId:a,extent:t.extent,zIndex:t.zIndex});return l.id=`${a}${l.id+o}`,s[t.id]=l.id,l}),newIdMapping:s}},[n,e])}};var H=e.i(4520);e.s(["useNodeLoopInteractions",()=>R],781988);let R=()=>{let e=(0,o.useStoreApi)(),{nodesMap:n}=(0,B.useNodesMetaData)(),i=(0,a.useCallback)(a=>{let o,n,{getNodes:i,setNodes:d}=e.getState(),r=i(),l=r.find(e=>e.id===a);r.filter(e=>e.parentId===a).forEach(e=>{o?e.position.x+e.width>o.position.x+o.width&&(o=e):o=e,n?e.position.y+e.height>n.position.y+n.height&&(n=e):n=e});let s=o&&l.width{e.forEach(e=>{e.id===a&&(s&&(e.data.width=o.position.x+o.width+O.LOOP_PADDING.right,e.width=o.position.x+o.width+O.LOOP_PADDING.right),u&&(e.data.height=n.position.y+n.height+O.LOOP_PADDING.bottom,e.height=n.position.y+n.height+O.LOOP_PADDING.bottom))})}))},[e]),d=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState(),o=a(),n={x:void 0,y:void 0};if(t.data.isInLoop){let e=o.find(e=>e.id===t.parentId);e&&(t.position.ye.width-O.LOOP_PADDING.right&&(n.x=e.width-O.LOOP_PADDING.right-t.width),t.position.y+t.height>e.height-O.LOOP_PADDING.bottom&&(n.y=e.height-O.LOOP_PADDING.bottom-t.height))}return{restrictPosition:n}},[e]),r=(0,a.useCallback)(t=>{let{getNodes:a}=e.getState(),o=a().find(e=>e.id===t).parentId;o&&i(o)},[e,i]);return{handleNodeLoopRerender:i,handleNodeLoopChildDrag:d,handleNodeLoopChildSizeChange:r,handleNodeLoopChildrenCopy:(0,a.useCallback)((t,a,o)=>{let{getNodes:i}=e.getState(),d=i(),r=d.filter(e=>e.parentId===t&&e.type!==H.CUSTOM_LOOP_START_NODE),l={...o};return{copyChildren:r.map((e,t)=>{let o=e.data.type,{defaultValue:i}=n[o],r=d.filter(e=>e.data.type===o),{newNode:s}=(0,M.generateNewNode)({type:(0,M.getNodeCustomTypeByNodeDataType)(o),data:{...i,...e.data,selected:!1,_isBundled:!1,_connectedSourceHandleIds:[],_connectedTargetHandleIds:[],_dimmed:!1,title:r.length>0?`${i.title} ${r.length+1}`:i.title,isInLoop:!0,loop_id:a,type:o},position:e.position,positionAbsolute:e.positionAbsolute,parentId:a,extent:e.extent,zIndex:O.LOOP_CHILDREN_Z_INDEX});return s.id=`${a}${s.id+t}`,l[e.id]=s.id,s}),newIdMapping:l}},[e,n])}};var L=e.i(534042),W=e.i(368148);let V=()=>{let e,l,u,c,{t:p}=(0,s.useTranslation)(),g=(0,o.useStoreApi)(),f=(0,n.useWorkflowStore)(),h=(0,o.useReactFlow)(),{store:y}=k(),{handleSyncWorkflowDraft:I}=(0,d.useNodesSyncDraft)(),{getAfterNodesInSameBranch:S}=(0,r.useWorkflow)(),{getNodesReadOnly:_}=(0,r.useNodesReadOnly)(),{getWorkflowReadOnly:w}=(0,r.useWorkflowReadOnly)(),{handleSetHelpline:T}=(e=(0,o.useStoreApi)(),l=(0,n.useWorkflowStore)(),u=(0,a.useCallback)(e=>(0,C.isTriggerNode)(e.data.type)||e.data.type===C.BlockEnum.Start,[]),c=(0,a.useCallback)(e=>u(e)?{x:e.position.x+0,y:e.position.y+21}:{x:e.position.x,y:e.position.y},[u]),{handleSetHelpline:(0,a.useCallback)(t=>{let{getNodes:a}=e.getState(),o=a(),{setHelpLineHorizontal:n,setHelpLineVertical:i}=l.getState();if(t.data.isInIteration||t.data.isInLoop)return{showHorizontalHelpLineNodes:[],showVerticalHelpLineNodes:[]};let d=c(t),r=o.filter(e=>{if(e.id===t.id||e.data.isInIteration||e.data.isInLoop)return!1;let a=Math.ceil(c(e).y),o=Math.ceil(d.y);return!!(a-o<5)&&!!(a-o>-5)}).sort((e,t)=>{let a=c(e),o=c(t);return a.x-o.x}),s=r.length;if(s>0){let e=r[0],a=r[s-1],o=c(e),i=c(a),l=u(a)?a.width-0:a.width,p={top:o.y,left:o.x,width:i.x+l-o.x};if(d.xi.x){let e=u(t)?t.width-0:t.width;p.width=d.x+e-o.x}n(p)}else n();let p=o.filter(e=>{if(e.id===t.id||e.data.isInIteration||e.data.isInLoop)return!1;let a=Math.ceil(c(e).x),o=Math.ceil(d.x);return!!(a-o<5)&&!!(a-o>-5)}).sort((e,t)=>{let a=c(e),o=c(t);return a.x-o.x}),g=p.length;if(g>0){let e=p[0],a=p[g-1],o=c(e),n=c(a),r=u(a)?a.height-21:a.height,l={top:o.y,left:o.x,height:n.y+r-o.y};if(d.yn.y){let e=u(t)?t.height-21:t.height;l.height=d.y+e-o.y}i(l)}else i();return{showHorizontalHelpLineNodes:r,showVerticalHelpLineNodes:p}},[e,l,c])}),{handleNodeIterationChildDrag:N,handleNodeIterationChildrenCopy:v}=x(),{handleNodeLoopChildDrag:b,handleNodeLoopChildrenCopy:V}=R(),U=(0,a.useRef)({x:0,y:0}),{nodesMap:$}=(0,B.useNodesMetaData)(),{saveStateToHistory:z,undo:G,redo:K}=m(),F=(0,W.useAutoGenerateWebhookUrl)(),X=(0,a.useCallback)((e,t)=>{f.setState({nodeAnimation:!1}),_()||t.type===P.CUSTOM_ITERATION_START_NODE||t.type===L.CUSTOM_NOTE_NODE||t.type!==H.CUSTOM_LOOP_START_NODE&&t.type!==L.CUSTOM_NOTE_NODE&&(U.current={x:t.position.x,y:t.position.y})},[f,_]),Z=(0,a.useCallback)((e,a)=>{if(_()||a.type===P.CUSTOM_ITERATION_START_NODE||a.type===H.CUSTOM_LOOP_START_NODE)return;let{getNodes:o,setNodes:n}=g.getState();e.stopPropagation();let i=o(),{restrictPosition:d}=N(a),{restrictPosition:r}=b(a),{showHorizontalHelpLineNodes:l,showVerticalHelpLineNodes:s}=T(a),u=l.length,c=s.length;n((0,t.produce)(i,e=>{let t=e.find(e=>e.id===a.id),o=(0,C.isTriggerNode)(a.data.type)||a.data.type===C.BlockEnum.Start;if(c>0){let e=s[0],a=(0,C.isTriggerNode)(e.data.type)||e.data.type===C.BlockEnum.Start;t.position.x=e.position.x+0-0}else void 0!==d.x?t.position.x=d.x:void 0!==r.x?t.position.x=r.x:t.position.x=a.position.x;if(u>0){let e=l[0],a=(0,C.isTriggerNode)(e.data.type)||e.data.type===C.BlockEnum.Start;t.position.y=e.position.y+21*!!a-21*!!o}else void 0!==d.y?t.position.y=d.y:void 0!==r.y?t.position.y=r.y:t.position.y=a.position.y}))},[_,g,N,b,T]),Y=(0,a.useCallback)((e,t)=>{let{setHelpLineHorizontal:a,setHelpLineVertical:o}=f.getState();if(_())return;let{x:n,y:i}=U.current;(n!==t.position.x||i!==t.position.y)&&(a(),o(),I(),0!==n&&0!==i&&z(E.NodeDragStop,{nodeId:t.id}))},[f,_,z,I]),q=(0,a.useCallback)((e,a)=>{if(_()||a.type===L.CUSTOM_NOTE_NODE||a.type===P.CUSTOM_ITERATION_START_NODE||a.type===H.CUSTOM_LOOP_START_NODE||a.type===L.CUSTOM_NOTE_NODE)return;let{getNodes:n,setNodes:i,edges:d,setEdges:r}=g.getState(),l=n(),{connectingNodePayload:s,setEnteringNodePayload:u}=f.getState();if(s){if(s.nodeId===a.id)return;let e=l.find(e=>e.id===s.nodeId);if(e.parentId===a.parentId){u({nodeId:a.id,nodeData:a.data});let o=s.handleType;i((0,t.produce)(l,t=>{t.forEach(t=>{t.id!==a.id||"source"!==o||a.data.type!==C.BlockEnum.VariableAssigner&&a.data.type!==C.BlockEnum.VariableAggregator||a.data.advanced_settings?.group_enabled||(t.data._isEntering=!0),t.id===a.id&&"target"===o&&(e.data.type===C.BlockEnum.VariableAssigner||e.data.type===C.BlockEnum.VariableAggregator)&&a.data.type!==C.BlockEnum.IfElse&&a.data.type!==C.BlockEnum.QuestionClassifier&&a.data.type!==C.BlockEnum.HumanInput&&(t.data._isEntering=!0)})}))}}r((0,t.produce)(d,e=>{(0,o.getConnectedEdges)([a],d).forEach(t=>{let a=e.find(e=>e.id===t.id);a&&(a.data._connectedNodeIsHovering=!0)})}))},[g,f,_]),j=(0,a.useCallback)((e,a)=>{if(_()||a.type===L.CUSTOM_NOTE_NODE||a.type===P.CUSTOM_ITERATION_START_NODE||a.type===L.CUSTOM_NOTE_NODE||a.type===H.CUSTOM_LOOP_START_NODE)return;let{setEnteringNodePayload:o}=f.getState();o(void 0);let{getNodes:n,setNodes:i,edges:d,setEdges:r}=g.getState();i((0,t.produce)(n(),e=>{e.forEach(e=>{e.data._isEntering=!1})})),r((0,t.produce)(d,e=>{e.forEach(e=>{e.data._connectedNodeIsHovering=!1})}))},[g,f,_]),Q=(0,a.useCallback)((e,a,n)=>{n&&f.setState({initShowLastRunTab:!0});let{getNodes:i,setNodes:d,edges:r,setEdges:l}=g.getState(),s=i(),u=s.find(e=>e.data.selected);if(!a&&u?.id===e)return;d((0,t.produce)(s,t=>{t.forEach(t=>{t.id===e?t.data.selected=!a:t.data.selected=!1})}));let c=(0,o.getConnectedEdges)([{id:e}],r).map(e=>e.id);l((0,t.produce)(r,e=>{e.forEach(e=>{c.includes(e.id)?e.data={...e.data,_connectedNodeIsSelected:!a}:e.data={...e.data,_connectedNodeIsSelected:!1}})})),I()},[g,I]),J=(0,a.useCallback)((e,t)=>{t.type===P.CUSTOM_ITERATION_START_NODE||t.type===H.CUSTOM_LOOP_START_NODE||t.data.type===C.BlockEnum.DataSourceEmpty||t.data._pluginInstallLocked||Q(t.id)},[Q]),ee=(0,a.useCallback)(e=>{let{source:a,sourceHandle:o,target:n,targetHandle:d}=e;if(a===n||_())return;let{getNodes:r,setNodes:l,edges:s,setEdges:u}=g.getState(),c=r(),p=c.find(e=>e.id===n),f=c.find(e=>e.id===a);if(p?.parentId!==f?.parentId||f?.type===L.CUSTOM_NOTE_NODE||p?.type===L.CUSTOM_NOTE_NODE||s.find(e=>e.source===a&&e.sourceHandle===o&&e.target===n&&e.targetHandle===d))return;let h=c.find(e=>e.id===p?.parentId),y=h&&h.data.type===C.BlockEnum.Iteration,S=!!h&&h.data.type===C.BlockEnum.Loop,k={id:`${a}-${o}-${n}-${d}`,type:O.CUSTOM_EDGE,source:a,target:n,sourceHandle:o,targetHandle:d,data:{sourceType:c.find(e=>e.id===a).data.type,targetType:c.find(e=>e.id===n).data.type,isInIteration:y,iteration_id:y?p?.parentId:void 0,isInLoop:S,loop_id:S?p?.parentId:void 0},zIndex:p?.parentId?y?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0},m=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([{type:"add",edge:k}],c),w=(0,t.produce)(c,e=>{e.forEach(e=>{m[e.id]&&(e.data={...e.data,...m[e.id]})})}),T=(0,t.produce)(s,e=>{e.push(k)});l(w),u(T),I(),z(E.NodeConnect,{nodeId:p?.id})},[_,g,f,I,z]),et=(0,a.useCallback)((e,t)=>{let{nodeId:a,handleType:o,handleId:n}=t;if(!_()&&a&&o){let{setConnectingNodePayload:e}=f.getState(),{getNodes:t}=g.getState(),i=t().find(e=>e.id===a);if(i.type===L.CUSTOM_NOTE_NODE||(i.data.type===C.BlockEnum.VariableAggregator||i.data.type===C.BlockEnum.VariableAssigner)&&"target"===o)return;e({nodeId:a,nodeType:i.data.type,handleType:o,handleId:n})}},[g,f,_]),ea=(0,a.useCallback)(e=>{if(_())return;let{connectingNodePayload:a,setConnectingNodePayload:o,enteringNodePayload:n,setEnteringNodePayload:i}=f.getState();if(a&&n){let{setShowAssignVariablePopup:o,hoveringAssignVariableGroupId:i}=f.getState(),{screenToFlowPosition:d}=h,{getNodes:r,setNodes:l}=g.getState(),s=r(),u=a.handleType,c=a.handleId,p=s.find(e=>e.id===a.nodeId),y=s.find(e=>e.id===n.nodeId),I=s.find(e=>e.id===y.parentId);if(p.parentId!==y.parentId)return;let{x:S,y:k}=d({x:e.x,y:e.y});if("source"===u&&(y.data.type===C.BlockEnum.VariableAssigner||y.data.type===C.BlockEnum.VariableAggregator)){let e=y.data.advanced_settings?.group_enabled,a=y.data.advanced_settings?.groups[0].groupId,n="target";e&&(n=i||a),l((0,t.produce)(s,e=>{e.forEach(e=>{e.id===y.id&&(e.data._showAddVariablePopup=!0,e.data._holdAddVariablePopup=!0)})})),o({nodeId:p.id,nodeData:p.data,variableAssignerNodeId:y.id,variableAssignerNodeData:y.data,variableAssignerNodeHandleId:n,parentNode:I,x:S-y.positionAbsolute.x,y:k-y.positionAbsolute.y}),ee({source:p.id,sourceHandle:c,target:y.id,targetHandle:"target"})}}o(void 0),i(void 0)},[g,ee,_,f,h]),{deleteNodeInspectorVars:eo}=D(),en=(0,a.useCallback)(e=>{if(_())return;let{getNodes:a,setNodes:n,edges:d,setEdges:r}=g.getState(),l=a(),s=l.findIndex(t=>t.id===e),u=l[s];if(!u||$?.[u.data.type]?.metaData.isUndeletable)return;if(eo(e),u.data.type===C.BlockEnum.Iteration){let t=l.filter(e=>e.parentId===u.id);if(t.length)if(u.data._isBundled)return t.forEach(e=>{en(e.id)}),en(e);else{if(1===t.length){en(t[0].id),en(e);return}let{setShowConfirm:a,showConfirm:o}=f.getState();if(!o)return void a({title:p("nodes.iteration.deleteTitle",{ns:"workflow"}),desc:p("nodes.iteration.deleteDesc",{ns:"workflow"})||"",onConfirm:()=>{t.forEach(e=>{en(e.id)}),en(e),I(),a(void 0)}})}}if(u.data.type===C.BlockEnum.Loop){let t=l.filter(e=>e.parentId===u.id);if(t.length)if(u.data._isBundled)return t.forEach(e=>{en(e.id)}),en(e);else{if(1===t.length){en(t[0].id),en(e);return}let{setShowConfirm:a,showConfirm:o}=f.getState();if(!o)return void a({title:p("nodes.loop.deleteTitle",{ns:"workflow"}),desc:p("nodes.loop.deleteDesc",{ns:"workflow"})||"",onConfirm:()=>{t.forEach(e=>{en(e.id)}),en(e),I(),a(void 0)}})}}if(u.data.type===C.BlockEnum.DataSource){let{id:e}=u,{ragPipelineVariables:t,setRagPipelineVariables:a}=f.getState();if(t&&a){let o=[];t.forEach(t=>{t.belong_to_node_id!==e&&o.push(t)}),a(o)}}let c=(0,o.getConnectedEdges)([{id:e}],d),h=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)(c.map(e=>({type:"remove",edge:e})),l);n((0,t.produce)(l,t=>{t.forEach(t=>{h[t.id]&&(t.data={...t.data,...h[t.id]}),t.id===u.parentId&&(t.data._children=t.data._children?.filter(t=>t.nodeId!==e))}),t.splice(s,1)})),r((0,t.produce)(d,e=>e.filter(e=>!c.find(t=>t.id===e.id)))),I(),u.type===L.CUSTOM_NOTE_NODE?z(E.NoteDelete,{nodeId:u.id}):z(E.NodeDelete,{nodeId:u.id})},[_,g,I,z,f,p,$,eo]),ei=(0,a.useCallback)((e,a)=>{let{nodeType:n,sourceHandle:d="source",targetHandle:r="target",pluginDefaultValue:l}=e,{prevNodeId:s,prevNodeSourceHandle:u,nextNodeId:c,nextNodeTargetHandle:p}=a;if(_())return;let{getNodes:h,setNodes:y,edges:k,setEdges:m}=g.getState(),w=h(),T=w.filter(e=>e.data.type===n),{defaultValue:N}=$[n],{newNode:v,newIterationStartNode:D,newLoopStartNode:b}=(0,M.generateNewNode)({type:(0,M.getNodeCustomTypeByNodeDataType)(n),data:{...N,title:T.length>0?`${N.title} ${T.length+1}`:N.title,...l,selected:!0,_showAddVariablePopup:(n===C.BlockEnum.VariableAssigner||n===C.BlockEnum.VariableAggregator)&&!!s,_holdAddVariablePopup:!1},position:{x:0,y:0}});if(s&&!c){let e=w.findIndex(e=>e.id===s),a=w[e],d=(0,o.getOutgoers)(a,w,k).sort((e,t)=>e.position.y-t.position.y),l=d[d.length-1];v.data._connectedTargetHandleIds=n===C.BlockEnum.DataSource?[]:[r],v.data._connectedSourceHandleIds=[],v.position={x:l?l.position.x:a.position.x+a.width+O.X_OFFSET,y:l?l.position.y+l.height+O.Y_OFFSET:a.position.y},v.parentId=a.parentId,v.extent=a.extent;let c=w.find(e=>e.id===a.parentId)||null,p=!!c&&c.data.type===C.BlockEnum.Iteration,g=!!c&&c.data.type===C.BlockEnum.Loop;a.parentId&&(v.data.isInIteration=p,v.data.isInLoop=g,p&&(v.data.iteration_id=c.id,v.zIndex=O.ITERATION_CHILDREN_Z_INDEX),g&&(v.data.loop_id=c.id,v.zIndex=O.LOOP_CHILDREN_Z_INDEX),p&&(v.data.type===C.BlockEnum.Answer||v.data.type===C.BlockEnum.Tool||v.data.type===C.BlockEnum.Assigner)&&(c.data._isShowTips=!0),g&&(v.data.type===C.BlockEnum.Answer||v.data.type===C.BlockEnum.Tool||v.data.type===C.BlockEnum.Assigner)&&(c.data._isShowTips=!0));let h=null;n!==C.BlockEnum.DataSource&&(h={id:`${s}-${u}-${v.id}-${r}`,type:O.CUSTOM_EDGE,source:s,sourceHandle:u,target:v.id,targetHandle:r,data:{sourceType:a.data.type,targetType:v.data.type,isInIteration:p,isInLoop:g,iteration_id:p?a.parentId:void 0,loop_id:g?a.parentId:void 0,_connectedNodeIsSelected:!0},zIndex:a.parentId?p?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0});let I=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)(h?[{type:"add",edge:h}]:[],w),S=(0,t.produce)(w,e=>{e.forEach(e=>{e.data.selected=!1,I[e.id]&&(e.data={...e.data,...I[e.id]}),e.data.type===C.BlockEnum.Iteration&&a.parentId===e.id&&e.data._children?.push({nodeId:v.id,nodeType:v.data.type}),e.data.type===C.BlockEnum.Loop&&a.parentId===e.id&&e.data._children?.push({nodeId:v.id,nodeType:v.data.type})}),e.push(v),D&&e.push(D),b&&e.push(b)});if(v.data.type===C.BlockEnum.VariableAssigner||v.data.type===C.BlockEnum.VariableAggregator){let{setShowAssignVariablePopup:e}=f.getState();e({nodeId:a.id,nodeData:a.data,variableAssignerNodeId:v.id,variableAssignerNodeData:v.data,variableAssignerNodeHandleId:r,parentNode:w.find(e=>e.id===v.parentId),x:-25,y:44})}let E=(0,t.produce)(k,e=>{e.forEach(e=>{e.data={...e.data,_connectedNodeIsSelected:!1}}),h&&e.push(h)});y(S),m(E)}if(!s&&c){let e,a,o=w.findIndex(e=>e.id===c),r=w[o];n!==C.BlockEnum.IfElse&&n!==C.BlockEnum.QuestionClassifier&&n!==C.BlockEnum.HumanInput&&(v.data._connectedSourceHandleIds=[d]),v.data._connectedTargetHandleIds=[],v.position={x:r.position.x,y:r.position.y},v.parentId=r.parentId,v.extent=r.extent;let l=w.find(e=>e.id===r.parentId)||null,s=!!l&&l.data.type===C.BlockEnum.Iteration,u=!!l&&l.data.type===C.BlockEnum.Loop;l&&r.parentId&&(v.data.isInIteration=s,v.data.isInLoop=u,s&&(v.data.iteration_id=l.id,v.zIndex=O.ITERATION_CHILDREN_Z_INDEX),u&&(v.data.loop_id=l.id,v.zIndex=O.LOOP_CHILDREN_Z_INDEX)),n!==C.BlockEnum.IfElse&&n!==C.BlockEnum.QuestionClassifier&&n!==C.BlockEnum.HumanInput&&n!==C.BlockEnum.LoopEnd&&(e={id:`${v.id}-${d}-${c}-${p}`,type:O.CUSTOM_EDGE,source:v.id,sourceHandle:d,target:c,targetHandle:p,data:{sourceType:v.data.type,targetType:r.data.type,isInIteration:s,isInLoop:u,iteration_id:s?r.parentId:void 0,loop_id:u?r.parentId:void 0,_connectedNodeIsSelected:!0},zIndex:r.parentId?s?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0}),e&&(a=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([{type:"add",edge:e}],w));let g=S(c).map(e=>e.id),f=(0,t.produce)(w,e=>{e.forEach(e=>{e.data.selected=!1,g.includes(e.id)&&(e.position.x+=O.NODE_WIDTH_X_OFFSET),a?.[e.id]&&(e.data={...e.data,...a[e.id]}),e.data.type===C.BlockEnum.Iteration&&r.parentId===e.id&&e.data._children?.push({nodeId:v.id,nodeType:v.data.type}),e.data.type===C.BlockEnum.Iteration&&e.data.start_node_id===c&&(e.data.start_node_id=v.id,e.data.startNodeType=v.data.type),e.data.type===C.BlockEnum.Loop&&r.parentId===e.id&&e.data._children?.push({nodeId:v.id,nodeType:v.data.type}),e.data.type===C.BlockEnum.Loop&&e.data.start_node_id===c&&(e.data.start_node_id=v.id,e.data.startNodeType=v.data.type)}),e.push(v),D&&e.push(D),b&&e.push(b)});if(e){let a=(0,t.produce)(k,t=>{t.forEach(e=>{e.data={...e.data,_connectedNodeIsSelected:!1}}),t.push(e)});y(f),m(a)}else y(f)}if(s&&c){let e=w.find(e=>e.id===s),a=w.find(e=>e.id===c);v.data._connectedTargetHandleIds=n===C.BlockEnum.DataSource?[]:[r],v.data._connectedSourceHandleIds=[d],v.position={x:a.position.x,y:a.position.y},v.parentId=e.parentId,v.extent=e.extent;let o=w.find(t=>t.id===e.parentId)||null,l=!!o&&o.data.type===C.BlockEnum.Iteration,g=!!o&&o.data.type===C.BlockEnum.Loop;o&&e.parentId&&(v.data.isInIteration=l,v.data.isInLoop=g,l&&(v.data.iteration_id=o.id,v.zIndex=O.ITERATION_CHILDREN_Z_INDEX),g&&(v.data.loop_id=o.id,v.zIndex=O.LOOP_CHILDREN_Z_INDEX));let h=k.findIndex(e=>e.source===s&&e.target===c),I=null;n!==C.BlockEnum.DataSource&&(I={id:`${s}-${u}-${v.id}-${r}`,type:O.CUSTOM_EDGE,source:s,sourceHandle:u,target:v.id,targetHandle:r,data:{sourceType:e.data.type,targetType:v.data.type,isInIteration:l,isInLoop:g,iteration_id:l?e.parentId:void 0,loop_id:g?e.parentId:void 0,_connectedNodeIsSelected:!0},zIndex:e.parentId?l?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0});let E=null,_=w.find(e=>e.id===a.parentId)||null,T=!!_&&_.data.type===C.BlockEnum.Iteration,N=!!_&&_.data.type===C.BlockEnum.Loop;n!==C.BlockEnum.IfElse&&n!==C.BlockEnum.QuestionClassifier&&n!==C.BlockEnum.HumanInput&&n!==C.BlockEnum.LoopEnd&&(E={id:`${v.id}-${d}-${c}-${p}`,type:O.CUSTOM_EDGE,source:v.id,sourceHandle:d,target:c,targetHandle:p,data:{sourceType:v.data.type,targetType:a.data.type,isInIteration:T,isInLoop:N,iteration_id:T?a.parentId:void 0,loop_id:N?a.parentId:void 0,_connectedNodeIsSelected:!0},zIndex:a.parentId?T?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0});let A=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([{type:"remove",edge:k[h]},...I?[{type:"add",edge:I}]:[],...E?[{type:"add",edge:E}]:[]],[...w,v]),P=S(c).map(e=>e.id);if(y((0,t.produce)(w,t=>{t.forEach(t=>{t.data.selected=!1,A[t.id]&&(t.data={...t.data,...A[t.id]}),P.includes(t.id)&&(t.position.x+=O.NODE_WIDTH_X_OFFSET),t.data.type===C.BlockEnum.Iteration&&e.parentId===t.id&&t.data._children?.push({nodeId:v.id,nodeType:v.data.type}),t.data.type===C.BlockEnum.Loop&&e.parentId===t.id&&t.data._children?.push({nodeId:v.id,nodeType:v.data.type})}),t.push(v),D&&t.push(D),b&&t.push(b)})),v.data.type===C.BlockEnum.VariableAssigner||v.data.type===C.BlockEnum.VariableAggregator){let{setShowAssignVariablePopup:t}=f.getState();t({nodeId:e.id,nodeData:e.data,variableAssignerNodeId:v.id,variableAssignerNodeData:v.data,variableAssignerNodeHandleId:r,parentNode:w.find(e=>e.id===v.parentId),x:-25,y:44})}m((0,t.produce)(k,e=>{e.splice(h,1),e.forEach(e=>{e.data={...e.data,_connectedNodeIsSelected:!1}}),I&&e.push(I),E&&e.push(E)}))}I(),z(E.NodeAdd,{nodeId:v.id})},[_,g,I,z,f,S,$]),ed=(0,a.useCallback)((e,a,n,d)=>{if(_())return;let{getNodes:r,setNodes:l,edges:s,setEdges:u}=g.getState(),c=r(),p=c.find(t=>t.id===e),f=(0,o.getConnectedEdges)([p],s),h=c.filter(e=>e.data.type===a),{defaultValue:y}=$[a],{newNode:S,newIterationStartNode:k,newLoopStartNode:m}=(0,M.generateNewNode)({type:(0,M.getNodeCustomTypeByNodeDataType)(a),data:{...y,title:h.length>0?`${y.title} ${h.length+1}`:y.title,...d,_connectedSourceHandleIds:[],_connectedTargetHandleIds:[],selected:p.data.selected,isInIteration:p.data.isInIteration,isInLoop:p.data.isInLoop,iteration_id:p.data.iteration_id,loop_id:p.data.loop_id},position:{x:p.position.x,y:p.position.y},parentId:p.parentId,extent:p.extent,zIndex:p.zIndex}),w=c.find(e=>e.id===p.parentId),T=!!w&&w.data.type===C.BlockEnum.Iteration,N=!!w&&w.data.type===C.BlockEnum.Loop,v=f.filter(t=>t.source===e),D=new Set(v.map(e=>e.sourceHandle||"source")),b=p.data._targetBranches?.[0]?.id,A=n||"source";D.has(A)||(A=b&&D.has(b)?b:D.has("source")?"source":v[0]?.sourceHandle||"source");let P=new Set(v.filter(e=>(e.sourceHandle||"source")===A).map(e=>e.id)),B=S.data._targetBranches?.[0]?.id||"source",x=f.reduce((t,a)=>{if(P.has(a.id)){let o=c.find(e=>e.id===a.target),n=o&&o.id!==e?o:S;if(!n)return t;let i=a.targetHandle||"target",d=n.id===S.id?w||null:c.find(e=>e.id===n.parentId)||null,r=!!d&&d.data.type===C.BlockEnum.Iteration,l=!!d&&d.data.type===C.BlockEnum.Loop;t.push({...a,id:`${S.id}-${B}-${n.id}-${i}`,source:S.id,sourceHandle:B,target:n.id,targetHandle:i,type:O.CUSTOM_EDGE,data:{...a.data||{},sourceType:S.data.type,targetType:n.data.type,isInIteration:r,iteration_id:r?n.parentId:void 0,isInLoop:l,loop_id:l?n.parentId:void 0,_connectedNodeIsSelected:!1},zIndex:n.parentId?r?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0})}if(a.target===e&&a.source!==e&&!P.has(a.id)){let e=c.find(e=>e.id===a.source);if(!e)return t;let o=a.targetHandle||"target",n=a.sourceHandle||"source";t.push({...a,id:`${e.id}-${n}-${S.id}-${o}`,source:e.id,sourceHandle:n,target:S.id,targetHandle:o,type:O.CUSTOM_EDGE,data:{...a.data||{},sourceType:e.data.type,targetType:S.data.type,isInIteration:T,iteration_id:T?S.parentId:void 0,isInLoop:N,loop_id:N?S.parentId:void 0,_connectedNodeIsSelected:!1},zIndex:S.parentId?T?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX:0})}return t},[]),H=(0,t.produce)(c,t=>{t.forEach(e=>{e.data.selected=!1});let a=t.findIndex(t=>t.id===e);t.splice(a,1,S),k&&t.push(k),m&&t.push(m)}),R=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)([...f.map(e=>({type:"remove",edge:e})),...x.map(e=>({type:"add",edge:e}))],H);l((0,t.produce)(H,e=>{e.forEach(e=>{R[e.id]&&(e.data={...e.data,...R[e.id]})})})),u([...s.filter(e=>!f.find(t=>t.id===e.id)),...x]),a===C.BlockEnum.TriggerWebhook?I(!0,!0,{onSuccess:()=>F(S.id)}):I(),z(E.NodeChange,{nodeId:e})},[_,g,I,z,$,F]),er=(0,a.useCallback)(()=>{let{getNodes:e,setNodes:a}=g.getState(),o=e();a((0,t.produce)(o,e=>{e.forEach(e=>{e.data.selected=!1})}))},[g]),el=(0,a.useCallback)((e,t)=>{if(t.type===L.CUSTOM_NOTE_NODE||t.type===P.CUSTOM_ITERATION_START_NODE||t.type===L.CUSTOM_NOTE_NODE||t.type===H.CUSTOM_LOOP_START_NODE)return;e.preventDefault();let{x:a,y:o}=document.querySelector("#workflow-container").getBoundingClientRect();f.setState({panelMenu:void 0,selectionMenu:void 0,edgeMenu:void 0,nodeMenu:{top:e.clientY-o,left:e.clientX-a,nodeId:t.id}}),Q(t.id)},[f,Q]),es=(0,a.useCallback)(e=>{if(_())return;let{setClipboardElements:t}=f.getState(),{getNodes:a}=g.getState(),o=a();if(e){let a=o.find(t=>t.id===e&&t.data.type!==C.BlockEnum.Start&&t.type!==P.CUSTOM_ITERATION_START_NODE&&t.type!==H.CUSTOM_LOOP_START_NODE&&t.data.type!==C.BlockEnum.LoopEnd&&t.data.type!==C.BlockEnum.KnowledgeBase&&t.data.type!==C.BlockEnum.DataSourceEmpty);a&&t([a])}else{let e=o.filter(e=>{if(!e.data._isBundled)return!1;if(e.type===L.CUSTOM_NOTE_NODE)return!0;let{metaData:t}=$[e.data.type];return!t.isSingleton&&!e.data.isInIteration&&!e.data.isInLoop});if(e.length)return void t(e);let a=o.find(e=>{if(!e.data.selected)return!1;if(e.type===L.CUSTOM_NOTE_NODE)return!0;let{metaData:t}=$[e.data.type];return!t.isSingleton});a&&t([a])}},[_,g,f]),eu=(0,a.useCallback)(()=>{if(_())return;let{clipboardElements:e,mousePosition:a}=f.getState(),{getNodes:o,setNodes:n,edges:i,setEdges:d}=g.getState(),r=[],l=[],s=o();if(e.length){let{x:o,y:u}=(0,M.getTopLeftNodePosition)(e),{screenToFlowPosition:c}=h,p=c({x:a.pageX,y:a.pageY}),g=p.x-o,f=p.y-u,y={},S={},k=[];e.forEach((e,t)=>{let a=e.data.type,{newNode:o,newIterationStartNode:n,newLoopStartNode:i}=(0,M.generateNewNode)({type:e.type,data:{...e.type!==L.CUSTOM_NOTE_NODE&&$[a].defaultValue,...e.data,selected:!1,_isBundled:!1,_connectedSourceHandleIds:[],_connectedTargetHandleIds:[],_dimmed:!1,title:(0,M.genNewNodeTitleFromOld)(e.data.title)},position:{x:e.position.x+g,y:e.position.y+f},extent:e.extent,zIndex:e.zIndex});o.id=o.id+t;let d=[];if(e.data.type===C.BlockEnum.Iteration){n.parentId=o.id,o.data.start_node_id=n.id,y[s.find(t=>t.parentId===e.id&&t.type===P.CUSTOM_ITERATION_START_NODE).id]=n.id;let{copyChildren:t,newIdMapping:a}=v(e.id,o.id,y);d=t,y=a,d.forEach(e=>{o.data._children?.push({nodeId:e.id,nodeType:e.data.type})}),d.push(n)}else if(e.data.type===C.BlockEnum.Loop){i.parentId=o.id,o.data.start_node_id=i.id,y[s.find(t=>t.parentId===e.id&&t.type===H.CUSTOM_LOOP_START_NODE).id]=i.id;let{copyChildren:t,newIdMapping:a}=V(e.id,o.id,y);d=t,y=a,d.forEach(e=>{o.data._children?.push({nodeId:e.id,nodeType:e.data.type})}),d.push(i)}else{let t=s.find(e=>e.selected);if(t){if([C.BlockEnum.End].includes(e.data.type))return;if(t.data.type===C.BlockEnum.Iteration||t.data.type===C.BlockEnum.Loop){let e=t.data.type===C.BlockEnum.Iteration;o.data.isInIteration=e,o.data.iteration_id=e?t.id:void 0,o.data.isInLoop=!e,o.data.loop_id=e?void 0:t.id,o.parentId=t.id,o.zIndex=e?O.ITERATION_CHILDREN_Z_INDEX:O.LOOP_CHILDREN_Z_INDEX,o.positionAbsolute={x:o.position.x,y:o.position.y},o.position=(0,M.getNestedNodePosition)(o,t),k.push({parentId:t.id,childId:o.id,childType:o.data.type})}}}y[e.id]=o.id,r.push(o),S[o.id]=o,d.length&&(d.forEach(e=>{S[e.id]=e}),r.push(...d))}),i.forEach(e=>{let t=y[e.source],a=y[e.target];if(t&&a){let o=S[t],n=S[a],i=o?.parentId&&o.parentId===n?.parentId?S[o.parentId]??s.find(e=>e.id===o.parentId):null,d=i?.data.type===C.BlockEnum.Iteration,r=i?.data.type===C.BlockEnum.Loop,u={...e,id:`${t}-${e.sourceHandle}-${a}-${e.targetHandle}`,source:t,target:a,data:{...e.data,isInIteration:d,iteration_id:d?i?.id:void 0,isInLoop:r,loop_id:r?i?.id:void 0,_connectedNodeIsSelected:!1},zIndex:i?d?O.ITERATION_CHILDREN_Z_INDEX:r?O.LOOP_CHILDREN_Z_INDEX:0:0};l.push(u)}}),n((0,t.produce)(s,e=>{k.forEach(t=>{let{parentId:a,childId:o,childType:n}=t,i=e.find(e=>e.id===a);i&&i.data._children?.push({nodeId:o,nodeType:n})}),e.push(...r)})),d([...i,...l]),z(E.NodePaste,{nodeId:r?.[0]?.id}),I()}},[_,f,g,h,z,I,v,V,$]),ec=(0,a.useCallback)(e=>{_()||(es(e),eu())},[_,es,eu]),ep=(0,a.useCallback)(()=>{if(_())return;let{getNodes:e,edges:t}=g.getState(),a=e(),o=a.filter(e=>e.data._isBundled);if(o.length)return void o.forEach(e=>en(e.id));if(t.some(e=>e.selected))return;let n=a.find(e=>e.data.selected);n&&en(n.id)},[g,_,en]),eg=(0,a.useCallback)((e,a)=>{let o,n;if(_())return;let{getNodes:i,setNodes:d}=g.getState(),{x:r,y:l,width:s,height:u}=a,c=i(),p=c.find(t=>t.id===e);if(c.filter(e=>p.data._children?.find(t=>t.nodeId===e.id)).forEach(e=>{o?e.position.x+e.width>o.position.x+o.width&&(o=e):o=e,n?e.position.y+e.height>n.position.y+n.height&&(n=e):n=e}),o&&n){let e=c.find(e=>e.id===o.parentId),t=e?.data.type===C.BlockEnum.Iteration?O.ITERATION_PADDING:O.LOOP_PADDING;if(s{t.forEach(t=>{t.id===e&&(t.data.width=s,t.data.height=u,t.width=s,t.height=u,t.position.x=r,t.position.y=l)})})),I(),z(E.NodeResize,{nodeId:e})},[_,g,I,z]),ef=(0,a.useCallback)(e=>{if(_())return;let{getNodes:a,setNodes:n,edges:d,setEdges:r}=g.getState(),l=a(),s=l.find(t=>t.id===e),u=(0,o.getConnectedEdges)([s],d),c=(0,i.getNodesConnectedSourceOrTargetHandleIdsMap)(u.map(e=>({type:"remove",edge:e})),l);n((0,t.produce)(l,e=>{e.forEach(e=>{c[e.id]&&(e.data={...e.data,...c[e.id]})})})),r((0,t.produce)(d,e=>e.filter(e=>!u.find(t=>t.id===e.id)))),I(),z(E.EdgeDelete)},[g,_,I,z]),eh=(0,a.useCallback)(()=>{if(_()||w())return;let{setEdges:e,setNodes:t}=g.getState();G();let{edges:a,nodes:o}=y.getState();(0!==a.length||0!==o.length)&&(e(a),t(o),f.setState({edgeMenu:void 0}))},[f,g,G,y,_,w]),ey=(0,a.useCallback)(()=>{if(_()||w())return;let{setEdges:e,setNodes:t}=g.getState();K();let{edges:a,nodes:o}=y.getState();(0!==a.length||0!==o.length)&&(e(a),t(o),f.setState({edgeMenu:void 0}))},[K,g,f,y,_,w]),[eI,eS]=(0,a.useState)(!1);return{handleNodeDragStart:X,handleNodeDrag:Z,handleNodeDragStop:Y,handleNodeEnter:q,handleNodeLeave:j,handleNodeSelect:Q,handleNodeClick:J,handleNodeConnect:ee,handleNodeConnectStart:et,handleNodeConnectEnd:ea,handleNodeDelete:en,handleNodeChange:ed,handleNodeAdd:ei,handleNodesCancelSelected:er,handleNodeContextMenu:el,handleNodesCopy:es,handleNodesPaste:eu,handleNodesDuplicate:ec,handleNodesDelete:ep,handleNodeResize:eg,handleNodeDisconnect:ef,handleHistoryBack:eh,handleHistoryForward:ey,dimOtherNodes:(0,a.useCallback)(()=>{if(eI)return;let{getNodes:e,setNodes:a,edges:n,setEdges:i}=g.getState(),d=e(),r=d.find(e=>e.data.selected);if(!r)return;eS(!0);let l=(0,A.getNodeUsedVars)(r),s=[];l.forEach(e=>{let t=d.find(t=>t.id===e?.[0]);t&&!s.includes(t)&&s.push(t)});let u=(0,o.getOutgoers)(r,d,n);for(let e=0;e{u.some(t=>t.id===e.id)||u.push(e)})}let c=[];u.forEach(e=>{(0,A.getNodeUsedVars)(e).some(e=>e?.[0]===r.id)&&(c.some(t=>t.id===e.id)||c.push(e))});let p=[...s,...c,r];a((0,t.produce)(d,e=>{e.forEach(e=>{p.find(t=>t.id===e.id)||(e.data._dimmed=!0)})}));let f=[];s.forEach(e=>{f.push({id:`tmp_${e.id}-source-${r.id}-target`,type:O.CUSTOM_EDGE,source:e.id,sourceHandle:"source_tmp",target:r.id,targetHandle:"target_tmp",animated:!0,data:{sourceType:e.data.type,targetType:r.data.type,_isTemp:!0,_connectedNodeIsHovering:!0}})}),c.forEach(e=>{f.push({id:`tmp_${r.id}-source-${e.id}-target`,type:O.CUSTOM_EDGE,source:r.id,sourceHandle:"source_tmp",target:e.id,targetHandle:"target_tmp",animated:!0,data:{sourceType:r.data.type,targetType:e.data.type,_isTemp:!0,_connectedNodeIsHovering:!0}})}),i((0,t.produce)(n,e=>{e.forEach(e=>{e.data._dimmed=!0}),e.push(...f)}))},[eI,g]),undimAllNodes:(0,a.useCallback)(()=>{let{getNodes:e,setNodes:a,edges:o,setEdges:n}=g.getState(),i=e();eS(!1),a((0,t.produce)(i,e=>{e.forEach(e=>{e.data._dimmed=!1})})),n((0,t.produce)(o.filter(e=>!e.data._isTemp),e=>{e.forEach(e=>{e.data._dimmed=!1})}))},[g])}};e.s([],257988);var U=e.i(410439);e.i(681401),new U.default,e.s(["usePanelInteractions",0,()=>{let e=(0,n.useWorkflowStore)(),t=(0,a.useCallback)(t=>{t.preventDefault();let{x:a,y:o}=document.querySelector("#workflow-container").getBoundingClientRect();e.setState({nodeMenu:void 0,selectionMenu:void 0,edgeMenu:void 0,panelMenu:{top:t.clientY-o,left:t.clientX-a}})},[e]),o=(0,a.useCallback)(()=>{e.setState({panelMenu:void 0})},[e]);return{handlePaneContextMenu:t,handlePaneContextmenuCancel:o,handleNodeContextmenuCancel:(0,a.useCallback)(()=>{e.setState({nodeMenu:void 0})},[e]),handleEdgeContextmenuCancel:(0,a.useCallback)(()=>{e.setState({edgeMenu:void 0})},[e])}}],568603),e.s(["useSelectionInteractions",0,()=>{let e=(0,o.useStoreApi)(),i=(0,n.useWorkflowStore)(),d=(0,a.useCallback)(()=>{let{getNodes:a,setNodes:o,edges:n,setEdges:i,userSelectionRect:d}=e.getState();if(!d?.width||!d?.height){let e=a();o((0,t.produce)(e,e=>{e.forEach(e=>{e.data._isBundled&&(e.data._isBundled=!1)})})),i((0,t.produce)(n,e=>{e.forEach(e=>{e.data._isBundled&&(e.data._isBundled=!1)})}))}},[e]),r=(0,a.useCallback)(a=>{let{nodes:o,edges:n}=a,{getNodes:i,setNodes:d,edges:r,setEdges:l,userSelectionRect:s}=e.getState(),u=i();s?.width&&s?.height&&(d((0,t.produce)(u,e=>{e.forEach(e=>{o.find(t=>t.id===e.id)?e.data._isBundled=!0:e.data._isBundled=!1})})),l((0,t.produce)(r,e=>{e.forEach(e=>{n.find(t=>t.id===e.id)?e.data._isBundled=!0:e.data._isBundled=!1})})))},[e]),l=(0,a.useCallback)((a,o)=>{let{getNodes:n,setNodes:d}=e.getState();i.setState({nodeAnimation:!1});let r=n();d((0,t.produce)(r,e=>{e.forEach(e=>{let t=o.find(t=>t.id===e.id);t&&(e.position=t.position)})}))},[e,i]),s=(0,a.useCallback)(()=>{let{getNodes:a,setNodes:o,edges:n,setEdges:i}=e.getState();e.setState({userSelectionRect:null,userSelectionActive:!0});let d=a();o((0,t.produce)(d,e=>{e.forEach(e=>{e.data._isBundled&&(e.data._isBundled=!1)})})),i((0,t.produce)(n,e=>{e.forEach(e=>{e.data._isBundled&&(e.data._isBundled=!1)})}))},[e]);return{handleSelectionStart:d,handleSelectionChange:r,handleSelectionDrag:l,handleSelectionCancel:s,handleSelectionContextMenu:(0,a.useCallback)(e=>{if(!e.target.classList.contains("react-flow__nodesselection-rect"))return;e.preventDefault();let{x:t,y:a}=document.querySelector("#workflow-container").getBoundingClientRect();i.setState({nodeMenu:void 0,panelMenu:void 0,edgeMenu:void 0,selectionMenu:{top:e.clientY-a,left:e.clientX-t}})},[i]),handleSelectionContextmenuCancel:(0,a.useCallback)(()=>{i.setState({selectionMenu:void 0})},[i])}}],77352)},337160,e=>{"use strict";var t=e.i(942347);e.s(["useSerialAsyncCallback",0,(e,a)=>{let o=(0,t.useRef)(Promise.resolve());return(0,t.useCallback)(function(){for(var t=arguments.length,n=Array(t),i=0;ivoid 0).then(()=>e(...n));return o.current=d,d},[e,a])}])},872135,e=>{"use strict";e.i(491401);var t=e.i(585736);e.s(["useSetWorkflowVarsWithValue",0,()=>({fetchInspectVars:(0,t.useHooksStore)(e=>e.fetchInspectVars)})])},586136,e=>{"use strict";var t=e.i(805735),a=e.i(942347),o=e.i(841501);e.s(["useEdgesInteractionsWithoutSync",0,()=>{let e=(0,o.useStoreApi)();return{handleEdgeCancelRunningStatus:(0,a.useCallback)(()=>{let{edges:a,setEdges:o}=e.getState();o((0,t.produce)(a,e=>{e.forEach(e=>{e.data._sourceRunningStatus=void 0,e.data._targetRunningStatus=void 0,e.data._waitingRun=!1})}))},[e])}}])},213889,e=>{"use strict";var t=e.i(805735),a=e.i(942347),o=e.i(841501),n=e.i(390622);e.s(["useNodesInteractionsWithoutSync",0,()=>{let e=(0,o.useStoreApi)(),i=(0,a.useCallback)(()=>{let{getNodes:a,setNodes:o}=e.getState(),n=a();o((0,t.produce)(n,e=>{e.forEach(e=>{e.data._runningStatus=void 0,e.data._waitingRun=!1})}))},[e]);return{handleNodeCancelRunningStatus:i,handleCancelAllNodeSuccessStatus:(0,a.useCallback)(()=>{let{getNodes:a,setNodes:o}=e.getState(),i=a();o((0,t.produce)(i,e=>{e.forEach(e=>{e.data._runningStatus===n.NodeRunningStatus.Succeeded&&(e.data._runningStatus=void 0)})}))},[e]),handleCancelNodeSuccessStatus:(0,a.useCallback)(a=>{let{getNodes:o,setNodes:i}=e.getState();i((0,t.produce)(o(),e=>{let t=e.find(e=>e.id===a);t&&t.data._runningStatus===n.NodeRunningStatus.Succeeded&&(t.data._runningStatus=void 0,t.data._waitingRun=!1)}))},[e])}}])},845780,856105,413741,383923,892323,556354,340821,886485,e=>{"use strict";e.s([],845780),e.i(368148),e.i(3340),e.i(944419),e.i(804612);var t=e.i(735738);e.i(959095),e.i(554499);var a=e.i(265522);e.i(257988),e.i(148280);var o=e.i(604208);e.i(568603);var n=e.i(77352);e.i(337160),e.i(872135),e.s(["useShortcuts",()=>v],413741);var i=e.i(335415),d=e.i(942347),r=e.i(841501),l=e.i(571566);e.s(["useWorkflowCanvasMaximize",()=>T,"useWorkflowInteractions",()=>E,"useWorkflowMoveMode",()=>m,"useWorkflowOrganize",()=>_,"useWorkflowUpdate",()=>w],856105);var s=e.i(805735),u=e.i(698094),c=e.i(959752),p=e.i(720315);e.i(275225);var g=e.i(705405),f=e.i(390622);e.i(905691);var h=e.i(722681),y=e.i(322034),I=e.i(586136),S=e.i(213889),k=e.i(339512);let E=()=>{let e=(0,g.useWorkflowStore)(),{handleNodeCancelRunningStatus:t}=(0,S.useNodesInteractionsWithoutSync)(),{handleEdgeCancelRunningStatus:a}=(0,I.useEdgesInteractionsWithoutSync)();return{handleCancelDebugAndPreviewPanel:(0,d.useCallback)(()=>{e.setState({showDebugAndPreviewPanel:!1,workflowRunningData:void 0}),t(),a()},[e,t,a])}},m=()=>{let e=(0,g.useStore)(e=>e.setControlMode),{getNodesReadOnly:t}=(0,p.useNodesReadOnly)(),{handleSelectionCancel:a}=(0,n.useSelectionInteractions)();return{handleModePointer:(0,d.useCallback)(()=>{t()||e(f.ControlMode.Pointer)},[t,e]),handleModeHand:(0,d.useCallback)(()=>{t()||(e(f.ControlMode.Hand),a())},[t,e,a])}},_=()=>{let e=(0,g.useWorkflowStore)(),t=(0,r.useStoreApi)(),a=(0,r.useReactFlow)(),{getNodesReadOnly:n}=(0,p.useNodesReadOnly)(),{saveStateToHistory:i}=(0,k.useWorkflowHistory)(),{handleSyncWorkflowDraft:l}=(0,o.useNodesSyncDraft)();return{handleLayout:(0,d.useCallback)(async()=>{if(n())return;e.setState({nodeAnimation:!0});let{getNodes:o,edges:d,setNodes:r}=t.getState(),{setViewport:u}=a,p=o(),g=p.filter(e=>(e.data.type===f.BlockEnum.Loop||e.data.type===f.BlockEnum.Iteration)&&!e.parentId&&e.type===c.CUSTOM_NODE),y=(await Promise.all(g.map(async e=>[e.id,await (0,h.getLayoutForChildNodes)(e.id,p,d)]))).reduce((e,t)=>{let[a,o]=t;return o&&(e[a]=o),e},{}),I={};g.forEach(e=>{let t=y[e.id];if(!t)return;let{bounds:a,nodes:o}=t;if(!o.size)return;let n=a.maxX-a.minX+2*c.NODE_LAYOUT_HORIZONTAL_PADDING,i=a.maxY-a.minY+2*c.NODE_LAYOUT_VERTICAL_PADDING;I[e.id]={width:Math.max(e.width||0,n),height:Math.max(e.height||0,i)}});let S=(0,s.produce)(p,e=>{e.forEach(e=>{(e.data.type===f.BlockEnum.Loop||e.data.type===f.BlockEnum.Iteration)&&I[e.id]&&(e.width=I[e.id].width,e.height=I[e.id].height,e.data.type===f.BlockEnum.Loop?(e.data.width=I[e.id].width,e.data.height=I[e.id].height):e.data.type===f.BlockEnum.Iteration&&(e.data.width=I[e.id].width,e.data.height=I[e.id].height))})}),E=await (0,h.getLayoutByDagre)(S,d),m=new Map;E.nodes.forEach(e=>{if(void 0!==e.layer){let t=m.get(e.layer),a={minY:t?Math.min(t.minY,e.y):e.y,maxHeight:t?Math.max(t.maxHeight,e.height):e.height};m.set(e.layer,a)}}),r((0,s.produce)(S,e=>{e.forEach(e=>{if(!e.parentId&&e.type===c.CUSTOM_NODE){let t=E.nodes.get(e.id);if(!t)return;let a=t.y;if(void 0!==t.layer){let e=m.get(t.layer);e&&(a=e.minY+e.maxHeight/2-t.height/2)}e.position={x:t.x,y:a}}}),g.forEach(t=>{let a=y[t.id];if(!a)return;let o=e.filter(e=>e.parentId===t.id),{bounds:n,nodes:i}=a;o.forEach(e=>{let t=i.get(e.id);t&&(e.position={x:c.NODE_LAYOUT_HORIZONTAL_PADDING+(t.x-n.minX),y:c.NODE_LAYOUT_VERTICAL_PADDING+(t.y-n.minY)})})})})),u({x:0,y:0,zoom:.7}),i(k.WorkflowHistoryEvent.LayoutOrganize),setTimeout(()=>{l()})},[n,t,a,e,l,i])}},w=()=>{let e=(0,r.useReactFlow)(),{eventEmitter:t}=(0,u.useEventEmitterContextContext)();return{handleUpdateWorkflowCanvas:(0,d.useCallback)(a=>{let{nodes:o,edges:n,viewport:i}=a,{setViewport:d}=e;t?.emit({type:c.WORKFLOW_DATA_UPDATE,payload:{nodes:(0,y.initialNodes)(o,n),edges:(0,y.initialEdges)(n,o)}}),i&&"number"==typeof i.x&&"number"==typeof i.y&&"number"==typeof i.zoom&&d(i)},[t,e])}},T=()=>{let{eventEmitter:e}=(0,u.useEventEmitterContextContext)(),t=(0,g.useStore)(e=>e.maximizeCanvas),a=(0,g.useStore)(e=>e.setMaximizeCanvas),{getNodesReadOnly:o}=(0,p.useNodesReadOnly)();return{handleToggleMaximizeCanvas:(0,d.useCallback)(()=>{o()||(a(!t),localStorage.setItem("workflow-canvas-maximize",String(!t)),e?.emit({type:"workflow-canvas-maximize",payload:!t}))},[e,o,t,a])}};var N=e.i(706416),C=e.i(276145);let v=()=>{let{handleNodesCopy:e,handleNodesPaste:n,handleNodesDuplicate:s,handleNodesDelete:u,handleHistoryBack:c,handleHistoryForward:p,dimOtherNodes:f,undimAllNodes:h}=(0,a.useNodesInteractions)(),{shortcutsEnabled:y}=(0,C.useWorkflowHistoryStore)(),{handleSyncWorkflowDraft:I}=(0,o.useNodesSyncDraft)(),{handleEdgeDelete:S}=(0,t.useEdgesInteractions)(),k=(0,g.useWorkflowStore)(),{handleModeHand:E,handleModePointer:w}=m(),{handleLayout:v}=_(),{handleToggleMaximizeCanvas:D}=T(),{zoomTo:b,getZoom:O,fitView:A}=(0,r.useReactFlow)(),P=(0,d.useCallback)(e=>!(0,N.isEventTargetInputArea)(e.target),[]),B=(0,d.useCallback)(()=>{let e=document.getSelection();return!e||e.isCollapsed},[]);(0,i.useKeyPress)(["delete","backspace"],e=>{P(e)&&(e.preventDefault(),u(),S())}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.c`,t=>{let{showDebugAndPreviewPanel:a}=k.getState();P(t)&&B()&&!a&&(t.preventDefault(),e())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.v`,e=>{let{showDebugAndPreviewPanel:t}=k.getState();P(e)&&!t&&(e.preventDefault(),n())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.d`,e=>{P(e)&&(e.preventDefault(),s())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("alt")}.r`,e=>{P(e)&&(e.preventDefault(),window._toggleTestRunDropdown&&window._toggleTestRunDropdown())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.z`,e=>{let{showDebugAndPreviewPanel:t}=k.getState();P(e)&&!t&&(e.preventDefault(),y&&c())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)([`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.y`,`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.shift.z`],e=>{P(e)&&(e.preventDefault(),y&&p())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("h",e=>{P(e)&&(e.preventDefault(),E())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("v",e=>{P(e)&&(e.preventDefault(),w())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.o`,e=>{P(e)&&(e.preventDefault(),v())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("f",e=>{P(e)&&(e.preventDefault(),D())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.1`,e=>{P(e)&&(e.preventDefault(),A(),I())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("shift.1",e=>{P(e)&&(e.preventDefault(),b(1),I())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("shift.5",e=>{P(e)&&(e.preventDefault(),b(.5),I())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.dash`,e=>{P(e)&&(e.preventDefault(),b(Math.max(O()-.1,.25)),I())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)(`${(0,N.getKeyboardKeyCodeBySystem)("ctrl")}.equalsign`,e=>{P(e)&&(e.preventDefault(),b(Math.min(O()+.1,2)),I())},{exactMatch:!0,useCapture:!0}),(0,i.useKeyPress)("shift",e=>{P(e)&&f()},{exactMatch:!0,useCapture:!0,events:["keydown"]}),(0,i.useKeyPress)(e=>"Shift"===e.key,e=>{P(e)&&h()},{exactMatch:!0,useCapture:!0,events:["keyup"]}),(0,d.useEffect)(()=>{let e=()=>{D()};return window.addEventListener(l.ZEN_TOGGLE_EVENT,e),()=>{window.removeEventListener(l.ZEN_TOGGLE_EVENT,e)}},[D])};e.i(95131),e.s(["useWorkflowMode",0,()=>{let e=(0,g.useStore)(e=>e.historyWorkflowData),t=(0,g.useStore)(e=>e.isRestoring);return(0,d.useMemo)(()=>({normal:!e&&!t,restoring:t,viewHistory:!!e}),[e,t])}],383923),e.i(491401);var D=e.i(585736);e.s(["useWorkflowRefreshDraft",0,()=>({handleRefreshWorkflowDraft:(0,D.useHooksStore)(e=>e.handleRefreshWorkflowDraft)})],892323),e.s(["useWorkflowRun",0,()=>{let e=(0,D.useHooksStore)(e=>e.handleBackupDraft),t=(0,D.useHooksStore)(e=>e.handleLoadBackupDraft),a=(0,D.useHooksStore)(e=>e.handleRestoreFromPublishedWorkflow);return{handleBackupDraft:e,handleLoadBackupDraft:t,handleRun:(0,D.useHooksStore)(e=>e.handleRun),handleStopRun:(0,D.useHooksStore)(e=>e.handleStopRun),handleRestoreFromPublishedWorkflow:a}}],556354),e.s(["useWorkflowSearch",()=>H],340821);var b=e.i(162115),O=e.i(87403),A=e.i(946700),P=e.i(120219),B=e.i(154033),M=e.i(842090),x=e.i(997908);let H=()=>{let e=(0,r.useNodes)(),{handleNodeSelect:t}=(0,a.useNodesInteractions)(),{data:o}=(0,B.useAllBuiltInTools)(),{data:n}=(0,B.useAllCustomTools)(),{data:i}=(0,B.useAllWorkflowTools)(),{data:l}=(0,B.useAllMCPTools)(),s=(0,d.useCallback)(e=>{if(e?.type!==f.BlockEnum.Tool)return;let t={[A.CollectionType.builtIn]:o||[],[A.CollectionType.custom]:n||[],[A.CollectionType.mcp]:l||[]},a=e.provider_type&&t[e.provider_type]||i;return a?.find(t=>(0,M.canFindTool)(t.id,e.provider_id))?.icon},[o,n,i,l]),u=(0,d.useCallback)(e=>e?.type!==f.BlockEnum.LLM?{}:e.model?{provider:e.model.provider,name:e.model.name,mode:e.model.mode}:{},[]),c=(0,d.useMemo)(()=>e.filter(e=>{if(!e.id||!e.data||"sticky"===e.type)return!1;let t=e.data;return!["iteration-start","loop-start"].includes(t?.type)}).map(e=>{let t=e.data;return{id:e.id,title:t?.title||t?.type||"Untitled",type:t?.type||"",desc:t?.desc||"",blockType:t?.type,nodeData:t,toolIcon:s(t),modelInfo:u(t)}}),[e,s,u]),p=(0,d.useCallback)((e,t)=>{if(!t)return 1;let a=e.title.toLowerCase(),o=e.type.toLowerCase(),n=e.desc?.toLowerCase()||"",i=e.modelInfo?.provider?.toLowerCase()||"",d=e.modelInfo?.name?.toLowerCase()||"",r=e.modelInfo?.mode?.toLowerCase()||"",l=0;return a.startsWith(t)?l+=100:a.includes(t)&&(l+=50),o===t?l+=80:o.includes(t)&&(l+=30),n.includes(t)&&(l+=20),d&&d.includes(t)&&(l+=60),i&&i.includes(t)&&(l+=40),r&&r.includes(t)&&(l+=30),l},[]),g=(0,d.useCallback)(e=>{if(!c.length)return[];let t=e.toLowerCase().trim();return c.map(e=>{let a=p(e,t);return a>0?{id:e.id,title:e.title,description:e.desc||e.type,type:"workflow-node",path:`#${e.id}`,icon:(0,b.jsx)(P.default,{type:e.blockType,className:"shrink-0",size:"sm",toolIcon:e.toolIcon}),metadata:{nodeId:e.id,nodeData:e.nodeData},data:e.nodeData,score:a}:null}).filter(e=>null!==e).sort((e,a)=>t?(a.score||0)-(e.score||0):e.title.localeCompare(a.title))},[c,p]);return(0,d.useEffect)(()=>(c.length>0&&(O.workflowNodesAction.searchFn=g),()=>{O.workflowNodesAction.searchFn=void 0}),[c,g]),(0,d.useEffect)(()=>(0,x.setupNodeSelectionListener)(t),[t]),null};e.s(["useWorkflowStartRun",0,()=>{let e=(0,D.useHooksStore)(e=>e.handleStartWorkflowRun),t=(0,D.useHooksStore)(e=>e.handleWorkflowStartRunInWorkflow),a=(0,D.useHooksStore)(e=>e.handleWorkflowStartRunInChatflow),o=(0,D.useHooksStore)(e=>e.handleWorkflowTriggerScheduleRunInWorkflow),n=(0,D.useHooksStore)(e=>e.handleWorkflowTriggerWebhookRunInWorkflow);return{handleStartWorkflowRun:e,handleWorkflowStartRunInWorkflow:t,handleWorkflowStartRunInChatflow:a,handleWorkflowTriggerScheduleRunInWorkflow:o,handleWorkflowTriggerWebhookRunInWorkflow:n,handleWorkflowTriggerPluginRunInWorkflow:(0,D.useHooksStore)(e=>e.handleWorkflowTriggerPluginRunInWorkflow),handleWorkflowRunAllTriggersInWorkflow:(0,D.useHooksStore)(e=>e.handleWorkflowRunAllTriggersInWorkflow)}}],886485),e.i(949250)}]);