Method run

packages/components/nodes/agentflow/Loop/Loop.ts:104–151

(nodeData: INodeData, _: string, options: ICommonObject)

    }

    async run(nodeData: INodeData, _: string, options: ICommonObject): Promise<any> {
        const loopBackToNode = nodeData.inputs?.loopBackToNode as string
        const _maxLoopCount = nodeData.inputs?.maxLoopCount as string
        const fallbackMessage = nodeData.inputs?.fallbackMessage as string
        const _loopUpdateState = nodeData.inputs?.loopUpdateState

        const state = options.agentflowRuntime?.state as ICommonObject

        const loopBackToNodeId = loopBackToNode.split('-')[0]
        const loopBackToNodeLabel = loopBackToNode.split('-')[1]

        const data = {
            nodeID: loopBackToNodeId,
            maxLoopCount: _maxLoopCount ? parseInt(_maxLoopCount) : 5
        }

        const finalOutput = 'Loop back to ' + `${loopBackToNodeLabel} (${loopBackToNodeId})`

        // Update flow state if needed
        let newState = { ...state }
        if (_loopUpdateState && Array.isArray(_loopUpdateState) && _loopUpdateState.length > 0) {
            newState = updateFlowState(state, _loopUpdateState)
        }

        // Process template variables in state
        if (newState && Object.keys(newState).length > 0) {
            for (const key in newState) {
                if (newState[key].toString().includes('{{ output }}')) {
                    newState[key] = finalOutput
                }
            }
        }

        const returnOutput = {
            id: nodeData.id,
            name: this.name,
            input: data,
            output: {
                content: finalOutput,
                nodeID: loopBackToNodeId,
                maxLoopCount: _maxLoopCount ? parseInt(_maxLoopCount) : 5,
                fallbackMessage
            },
            state: newState
        }

        return returnOutput
    }
}

module.exports = { nodeClass: Loop_Agentflow }