import { useCallback } from 'react' import produce from 'immer' import type { EdgeMouseHandler, NodeMouseHandler, OnConnect, } from 'reactflow' import { getConnectedEdges, getIncomers, useStoreApi, } from 'reactflow' import type { BlockEnum, Node, SelectedNode, } from './types' import { NodeInitialData } from './constants' import { getLayoutByDagre } from './utils' export const useWorkflow = () => { const store = useStoreApi() const handleLayout = useCallback(async () => { const { getNodes, edges, setNodes, } = store.getState() const layout = getLayoutByDagre(getNodes(), edges) const newNodes = produce(getNodes(), (draft) => { draft.forEach((node) => { const nodeWithPosition = layout.node(node.id) node.position = { x: nodeWithPosition.x, y: nodeWithPosition.y, } }) }) setNodes(newNodes) }, [store]) const handleEnterNode = useCallback((_, node) => { const { getNodes, setNodes, edges, setEdges, } = store.getState() const newNodes = produce(getNodes(), (draft) => { const currentNode = draft.find(n => n.id === node.id)! currentNode.data.hovering = true }) setNodes(newNodes) const newEdges = produce(edges, (draft) => { const connectedEdges = getConnectedEdges([node], edges) connectedEdges.forEach((edge) => { const currentEdge = draft.find(e => e.id === edge.id) if (currentEdge) currentEdge.data = { ...currentEdge.data, connectedNodeIsHovering: true } }) }) setEdges(newEdges) }, [store]) const handleLeaveNode = useCallback((_, node) => { const { getNodes, setNodes, edges, setEdges, } = store.getState() const newNodes = produce(getNodes(), (draft) => { const currentNode = draft.find(n => n.id === node.id)! currentNode.data.hovering = false }) setNodes(newNodes) const newEdges = produce(edges, (draft) => { const connectedEdges = getConnectedEdges([node], edges) connectedEdges.forEach((edge) => { const currentEdge = draft.find(e => e.id === edge.id) if (currentEdge) currentEdge.data = { ...currentEdge.data, connectedNodeIsHovering: false } }) }) setEdges(newEdges) }, [store]) const handleSelectNode = useCallback((nodeId: string, cancelSelection?: boolean) => { const { getNodes, setNodes, } = store.getState() const newNodes = produce(getNodes(), (draft) => { draft.forEach(node => node.selected = false) const selectedNode = draft.find(node => node.id === nodeId)! if (!cancelSelection) selectedNode.selected = true }) setNodes(newNodes) }, [store]) const handleConnectNode = useCallback(({ source, sourceHandle, target, targetHandle, }) => { const { edges, setEdges, } = store.getState() const newEdges = produce(edges, (draft) => { const filtered = draft.filter(edge => edge.source !== source && edge.target !== target) filtered.push({ id: `${source}-${target}`, type: 'custom', source: source!, target: target!, sourceHandle, targetHandle, }) return filtered }) setEdges(newEdges) handleLayout() }, [store, handleLayout]) const handleEnterEdge = useCallback((_, edge) => { const { edges, setEdges, } = store.getState() const newEdges = produce(edges, (draft) => { const currentEdge = draft.find(e => e.id === edge.id)! currentEdge.data = { ...currentEdge.data, hovering: true } }) setEdges(newEdges) }, [store]) const handleLeaveEdge = useCallback((_, edge) => { const { edges, setEdges, } = store.getState() const newEdges = produce(edges, (draft) => { const currentEdge = draft.find(e => e.id === edge.id)! currentEdge.data = { ...currentEdge.data, hovering: false } }) setEdges(newEdges) }, [store]) const handleDeleteEdge = useCallback(() => { const { edges, setEdges, } = store.getState() const newEdges = produce(edges, (draft) => { const index = draft.findIndex(edge => edge.selected) if (index > -1) draft.splice(index, 1) }) setEdges(newEdges) handleLayout() }, [store, handleLayout]) const handleUpdateNodeData = useCallback(({ id, data }: SelectedNode) => { const { getNodes, setNodes, } = store.getState() const newNodes = produce(getNodes(), (draft) => { const currentNode = draft.find(node => node.id === id)! currentNode.data = { ...currentNode.data, ...data } }) setNodes(newNodes) }, [store]) const handleAddNextNode = useCallback((currentNodeId: string, nodeType: BlockEnum, sourceHandle: string) => { const { getNodes, setNodes, edges, setEdges, } = store.getState() const nodes = getNodes() const currentNode = nodes.find(node => node.id === currentNodeId)! const nextNode: Node = { id: `${Date.now()}`, type: 'custom', data: NodeInitialData[nodeType], position: { x: currentNode.position.x + 304, y: 0, }, selected: true, } const newEdge = { id: `${currentNode.id}-${nextNode.id}`, type: 'custom', source: currentNode.id, sourceHandle, target: nextNode.id, targetHandle: 'target', } const newNodes = produce(nodes, (draft) => { draft.forEach((node) => { node.selected = false }) draft.push(nextNode) }) setNodes(newNodes) const newEdges = produce(edges, (draft) => { draft.push(newEdge) }) setEdges(newEdges) }, [store]) const handleChangeCurrentNode = useCallback((currentNodeId: string, nodeType: BlockEnum, sourceHandle?: string) => { const { getNodes, setNodes, edges, setEdges, } = store.getState() const nodes = getNodes() const currentNode = nodes.find(node => node.id === currentNodeId)! const incomers = getIncomers(currentNode, nodes, edges) const connectedEdges = getConnectedEdges([currentNode], edges) const newCurrentNode: Node = { id: `${Date.now()}`, type: 'custom', data: NodeInitialData[nodeType], position: { x: currentNode.position.x, y: currentNode.position.y, }, } const newNodes = produce(nodes, (draft) => { const index = draft.findIndex(node => node.id === currentNodeId) draft.splice(index, 1, newCurrentNode) }) setNodes(newNodes) if (incomers.length === 1) { const parentNodeId = incomers[0].id const newEdge = { id: `${parentNodeId}-${newCurrentNode.id}`, type: 'custom', source: parentNodeId, sourceHandle: sourceHandle || 'source', target: newCurrentNode.id, targetHandle: 'target', } const newEdges = produce(edges, (draft) => { const filtered = draft.filter(edge => !connectedEdges.find(connectedEdge => connectedEdge.id === edge.id)) filtered.push(newEdge) return filtered }) setEdges(newEdges) } }, [store]) const handleDeleteNode = useCallback((nodeId: string) => { const { getNodes, setNodes, edges, setEdges, } = store.getState() const newNodes = produce(getNodes(), (draft) => { const index = draft.findIndex(node => node.id === nodeId) if (index > -1) draft.splice(index, 1) }) setNodes(newNodes) const connectedEdges = getConnectedEdges([{ id: nodeId } as Node], edges) const newEdges = produce(edges, (draft) => { return draft.filter(edge => !connectedEdges.find(connectedEdge => connectedEdge.id === edge.id)) }) setEdges(newEdges) }, [store]) return { handleEnterNode, handleLeaveNode, handleSelectNode, handleEnterEdge, handleLeaveEdge, handleConnectNode, handleDeleteEdge, handleUpdateNodeData, handleAddNextNode, handleChangeCurrentNode, handleDeleteNode, handleLayout, } }