mirror of
https://github.com/langgenius/dify.git
synced 2026-03-28 14:01:53 -04:00
Co-authored-by: CodingOnStar <hanxujiang@dify.com> Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
122 lines
3.8 KiB
TypeScript
122 lines
3.8 KiB
TypeScript
import type {
|
|
BlockEnum,
|
|
ChildNodeTypeCount,
|
|
Node,
|
|
} from '../../types'
|
|
import { produce } from 'immer'
|
|
import { useCallback } from 'react'
|
|
import { useTranslation } from 'react-i18next'
|
|
import { useStoreApi } from 'reactflow'
|
|
import { useNodesMetaData } from '@/app/components/workflow/hooks'
|
|
import {
|
|
generateNewNode,
|
|
getNodeCustomTypeByNodeDataType,
|
|
} from '../../utils'
|
|
import {
|
|
buildIterationChildCopy,
|
|
getIterationChildren,
|
|
getIterationContainerBounds,
|
|
getIterationContainerResize,
|
|
getNextChildNodeTypeCount,
|
|
getRestrictedIterationPosition,
|
|
} from './use-interactions.helpers'
|
|
|
|
export const useNodeIterationInteractions = () => {
|
|
const { t } = useTranslation()
|
|
const store = useStoreApi()
|
|
const { nodesMap: nodesMetaDataMap } = useNodesMetaData()
|
|
|
|
const handleNodeIterationRerender = useCallback((nodeId: string) => {
|
|
const {
|
|
getNodes,
|
|
setNodes,
|
|
} = store.getState()
|
|
|
|
const nodes = getNodes()
|
|
const currentNode = nodes.find(n => n.id === nodeId)!
|
|
const childrenNodes = nodes.filter(n => n.parentId === nodeId)
|
|
const resize = getIterationContainerResize(currentNode, getIterationContainerBounds(childrenNodes))
|
|
|
|
if (resize.width || resize.height) {
|
|
const newNodes = produce(nodes, (draft) => {
|
|
draft.forEach((n) => {
|
|
if (n.id === nodeId) {
|
|
if (resize.width) {
|
|
n.data.width = resize.width
|
|
n.width = resize.width
|
|
}
|
|
if (resize.height) {
|
|
n.data.height = resize.height
|
|
n.height = resize.height
|
|
}
|
|
}
|
|
})
|
|
})
|
|
|
|
setNodes(newNodes)
|
|
}
|
|
}, [store])
|
|
|
|
const handleNodeIterationChildDrag = useCallback((node: Node) => {
|
|
const { getNodes } = store.getState()
|
|
const nodes = getNodes()
|
|
|
|
return {
|
|
restrictPosition: getRestrictedIterationPosition(node, nodes.find(n => n.id === node.parentId)),
|
|
}
|
|
}, [store])
|
|
|
|
const handleNodeIterationChildSizeChange = useCallback((nodeId: string) => {
|
|
const { getNodes } = store.getState()
|
|
const nodes = getNodes()
|
|
const currentNode = nodes.find(n => n.id === nodeId)!
|
|
const parentId = currentNode.parentId
|
|
|
|
if (parentId)
|
|
handleNodeIterationRerender(parentId)
|
|
}, [store, handleNodeIterationRerender])
|
|
|
|
const handleNodeIterationChildrenCopy = useCallback((nodeId: string, newNodeId: string, idMapping: Record<string, string>) => {
|
|
const { getNodes } = store.getState()
|
|
const nodes = getNodes()
|
|
const childrenNodes = getIterationChildren(nodes, nodeId)
|
|
const newIdMapping = { ...idMapping }
|
|
const childNodeTypeCount: ChildNodeTypeCount = {}
|
|
|
|
const copyChildren = childrenNodes.map((child, index) => {
|
|
const childNodeType = child.data.type as BlockEnum
|
|
const nodesWithSameType = nodes.filter(node => node.data.type === childNodeType)
|
|
const nextCount = getNextChildNodeTypeCount(childNodeTypeCount, childNodeType, nodesWithSameType.length)
|
|
const title = nodesWithSameType.length > 0
|
|
? `${t(`blocks.${childNodeType}`, { ns: 'workflow' })} ${nextCount}`
|
|
: t(`blocks.${childNodeType}`, { ns: 'workflow' })
|
|
const childCopy = buildIterationChildCopy({
|
|
child,
|
|
childNodeType,
|
|
defaultValue: nodesMetaDataMap![childNodeType].defaultValue as Node['data'],
|
|
title,
|
|
newNodeId,
|
|
})
|
|
const { newNode } = generateNewNode({
|
|
...childCopy,
|
|
type: getNodeCustomTypeByNodeDataType(childNodeType),
|
|
})
|
|
newNode.id = `${newNodeId}${newNode.id + index}`
|
|
newIdMapping[child.id] = newNode.id
|
|
return newNode
|
|
})
|
|
|
|
return {
|
|
copyChildren,
|
|
newIdMapping,
|
|
}
|
|
}, [nodesMetaDataMap, store, t])
|
|
|
|
return {
|
|
handleNodeIterationRerender,
|
|
handleNodeIterationChildDrag,
|
|
handleNodeIterationChildSizeChange,
|
|
handleNodeIterationChildrenCopy,
|
|
}
|
|
}
|