import { useCallback } from 'react' import produce from 'immer' import { useBoolean } from 'ahooks' import { uuid4 } from '@sentry/utils' import { useIsChatMode, useIsNodeInLoop, useNodesReadOnly, useWorkflow, } from '../../hooks' import { VarType } from '../../types' import type { ErrorHandleMode, ValueSelector, Var } from '../../types' import useNodeCrud from '../_base/hooks/use-node-crud' import { getNodeInfoById, getNodeUsedVarPassToServerKey, getNodeUsedVars, isSystemVar, toNodeOutputVars } from '../_base/components/variable/utils' import useOneStepRun from '../_base/hooks/use-one-step-run' import { getOperators } from './utils' import { LogicalOperator } from './types' import type { HandleAddCondition, HandleAddSubVariableCondition, HandleRemoveCondition, HandleToggleConditionLogicalOperator, HandleToggleSubVariableConditionLogicalOperator, HandleUpdateCondition, HandleUpdateSubVariableCondition, LoopNodeType } from './types' import useIsVarFileAttribute from './use-is-var-file-attribute' const DELIMITER = '@@@@@' const useConfig = (id: string, payload: LoopNodeType) => { const { nodesReadOnly: readOnly } = useNodesReadOnly() const { isNodeInLoop } = useIsNodeInLoop(id) const isChatMode = useIsChatMode() const { inputs, setInputs } = useNodeCrud(id, payload) const filterInputVar = useCallback((varPayload: Var) => { return [VarType.array, VarType.arrayString, VarType.arrayNumber, VarType.arrayObject, VarType.arrayFile].includes(varPayload.type) }, []) // output const { getLoopNodeChildren, getBeforeNodesInSameBranch } = useWorkflow() const beforeNodes = getBeforeNodesInSameBranch(id) const loopChildrenNodes = getLoopNodeChildren(id) const canChooseVarNodes = [...beforeNodes, ...loopChildrenNodes] const childrenNodeVars = toNodeOutputVars(loopChildrenNodes, isChatMode) // single run const loopInputKey = `${id}.input_selector` const { isShowSingleRun, showSingleRun, hideSingleRun, toVarInputs, runningStatus, handleRun: doHandleRun, handleStop, runInputData, setRunInputData, runResult, loopRunResult, } = useOneStepRun({ id, data: inputs, loopInputKey, defaultRunInputData: { [loopInputKey]: [''], }, }) const [isShowLoopDetail, { setTrue: doShowLoopDetail, setFalse: doHideLoopDetail, }] = useBoolean(false) const hideLoopDetail = useCallback(() => { hideSingleRun() doHideLoopDetail() }, [doHideLoopDetail, hideSingleRun]) const showLoopDetail = useCallback(() => { doShowLoopDetail() }, [doShowLoopDetail]) const backToSingleRun = useCallback(() => { hideLoopDetail() showSingleRun() }, [hideLoopDetail, showSingleRun]) const { getIsVarFileAttribute, } = useIsVarFileAttribute({ nodeId: id, }) const { usedOutVars, allVarObject } = (() => { const vars: ValueSelector[] = [] const varObjs: Record = {} const allVarObject: Record = {} loopChildrenNodes.forEach((node) => { const nodeVars = getNodeUsedVars(node).filter(item => item && item.length > 0) nodeVars.forEach((varSelector) => { if (varSelector[0] === id) { // skip Loop node itself variable: item, index return } const isInLoop = isNodeInLoop(varSelector[0]) if (isInLoop) // not pass loop inner variable return const varSectorStr = varSelector.join('.') if (!varObjs[varSectorStr]) { varObjs[varSectorStr] = true vars.push(varSelector) } let passToServerKeys = getNodeUsedVarPassToServerKey(node, varSelector) if (typeof passToServerKeys === 'string') passToServerKeys = [passToServerKeys] passToServerKeys.forEach((key: string, index: number) => { allVarObject[[varSectorStr, node.id, index].join(DELIMITER)] = { inSingleRunPassedKey: key, } }) }) }) const res = toVarInputs(vars.map((item) => { const varInfo = getNodeInfoById(canChooseVarNodes, item[0]) return { label: { nodeType: varInfo?.data.type, nodeName: varInfo?.data.title || canChooseVarNodes[0]?.data.title, // default start node title variable: isSystemVar(item) ? item.join('.') : item[item.length - 1], }, variable: `${item.join('.')}`, value_selector: item, } })) return { usedOutVars: res, allVarObject, } })() const handleRun = useCallback((data: Record) => { const formattedData: Record = {} Object.keys(allVarObject).forEach((key) => { const [varSectorStr, nodeId] = key.split(DELIMITER) formattedData[`${nodeId}.${allVarObject[key].inSingleRunPassedKey}`] = data[varSectorStr] }) formattedData[loopInputKey] = data[loopInputKey] doHandleRun(formattedData) }, [allVarObject, doHandleRun, loopInputKey]) const inputVarValues = (() => { const vars: Record = {} Object.keys(runInputData) .filter(key => ![loopInputKey].includes(key)) .forEach((key) => { vars[key] = runInputData[key] }) return vars })() const setInputVarValues = useCallback((newPayload: Record) => { const newVars = { ...newPayload, [loopInputKey]: runInputData[loopInputKey], } setRunInputData(newVars) }, [loopInputKey, runInputData, setRunInputData]) const loop = runInputData[loopInputKey] const setLoop = useCallback((newLoop: string[]) => { setRunInputData({ ...runInputData, [loopInputKey]: newLoop, }) }, [loopInputKey, runInputData, setRunInputData]) const changeErrorResponseMode = useCallback((item: { value: unknown }) => { const newInputs = produce(inputs, (draft) => { draft.error_handle_mode = item.value as ErrorHandleMode }) setInputs(newInputs) }, [inputs, setInputs]) const handleAddCondition = useCallback((valueSelector, varItem) => { const newInputs = produce(inputs, (draft) => { if (!draft.break_conditions) draft.break_conditions = [] draft.break_conditions?.push({ id: uuid4(), varType: varItem.type, variable_selector: valueSelector, comparison_operator: getOperators(varItem.type, getIsVarFileAttribute(valueSelector) ? { key: valueSelector.slice(-1)[0] } : undefined)[0], value: '', }) }) setInputs(newInputs) }, [getIsVarFileAttribute, inputs, setInputs]) const handleRemoveCondition = useCallback((conditionId) => { const newInputs = produce(inputs, (draft) => { draft.break_conditions = draft.break_conditions?.filter(item => item.id !== conditionId) }) setInputs(newInputs) }, [inputs, setInputs]) const handleUpdateCondition = useCallback((conditionId, newCondition) => { const newInputs = produce(inputs, (draft) => { const targetCondition = draft.break_conditions?.find(item => item.id === conditionId) if (targetCondition) Object.assign(targetCondition, newCondition) }) setInputs(newInputs) }, [inputs, setInputs]) const handleToggleConditionLogicalOperator = useCallback(() => { const newInputs = produce(inputs, (draft) => { draft.logical_operator = draft.logical_operator === LogicalOperator.and ? LogicalOperator.or : LogicalOperator.and }) setInputs(newInputs) }, [inputs, setInputs]) const handleAddSubVariableCondition = useCallback((conditionId: string, key?: string) => { const newInputs = produce(inputs, (draft) => { const condition = draft.break_conditions?.find(item => item.id === conditionId) if (!condition) return if (!condition?.sub_variable_condition) { condition.sub_variable_condition = { logical_operator: LogicalOperator.and, conditions: [], } } const subVarCondition = condition.sub_variable_condition if (subVarCondition) { if (!subVarCondition.conditions) subVarCondition.conditions = [] const svcComparisonOperators = getOperators(VarType.string, { key: key || '' }) subVarCondition.conditions.push({ id: uuid4(), key: key || '', varType: VarType.string, comparison_operator: (svcComparisonOperators && svcComparisonOperators.length) ? svcComparisonOperators[0] : undefined, value: '', }) } }) setInputs(newInputs) }, [inputs, setInputs]) const handleRemoveSubVariableCondition = useCallback((conditionId: string, subConditionId: string) => { const newInputs = produce(inputs, (draft) => { const condition = draft.break_conditions?.find(item => item.id === conditionId) if (!condition) return if (!condition?.sub_variable_condition) return const subVarCondition = condition.sub_variable_condition if (subVarCondition) subVarCondition.conditions = subVarCondition.conditions.filter(item => item.id !== subConditionId) }) setInputs(newInputs) }, [inputs, setInputs]) const handleUpdateSubVariableCondition = useCallback((conditionId, subConditionId, newSubCondition) => { const newInputs = produce(inputs, (draft) => { const targetCondition = draft.break_conditions?.find(item => item.id === conditionId) if (targetCondition && targetCondition.sub_variable_condition) { const targetSubCondition = targetCondition.sub_variable_condition.conditions.find(item => item.id === subConditionId) if (targetSubCondition) Object.assign(targetSubCondition, newSubCondition) } }) setInputs(newInputs) }, [inputs, setInputs]) const handleToggleSubVariableConditionLogicalOperator = useCallback((conditionId) => { const newInputs = produce(inputs, (draft) => { const targetCondition = draft.break_conditions?.find(item => item.id === conditionId) if (targetCondition && targetCondition.sub_variable_condition) targetCondition.sub_variable_condition.logical_operator = targetCondition.sub_variable_condition.logical_operator === LogicalOperator.and ? LogicalOperator.or : LogicalOperator.and }) setInputs(newInputs) }, [inputs, setInputs]) const handleUpdateLoopCount = useCallback((value: number) => { const newInputs = produce(inputs, (draft) => { draft.loop_count = value }) setInputs(newInputs) }, [inputs, setInputs]) return { readOnly, inputs, filterInputVar, childrenNodeVars, loopChildrenNodes, isShowSingleRun, showSingleRun, hideSingleRun, isShowLoopDetail, showLoopDetail, hideLoopDetail, backToSingleRun, runningStatus, handleRun, handleStop, runResult, inputVarValues, setInputVarValues, usedOutVars, loop, setLoop, loopInputKey, loopRunResult, handleAddCondition, handleRemoveCondition, handleUpdateCondition, handleToggleConditionLogicalOperator, handleAddSubVariableCondition, handleUpdateSubVariableCondition, handleRemoveSubVariableCondition, handleToggleSubVariableConditionLogicalOperator, handleUpdateLoopCount, changeErrorResponseMode, } } export default useConfig