|
@@ -3,17 +3,29 @@ import {
|
|
|
useState,
|
|
|
} from 'react'
|
|
|
import { useTranslation } from 'react-i18next'
|
|
|
-import { useReactFlow } from 'reactflow'
|
|
|
-import { useWorkflowStore } from '../store'
|
|
|
-import { DSL_EXPORT_CHECK, WORKFLOW_DATA_UPDATE } from '../constants'
|
|
|
-import type { WorkflowDataUpdator } from '../types'
|
|
|
+import { useReactFlow, useStoreApi } from 'reactflow'
|
|
|
+import produce from 'immer'
|
|
|
+import { useStore, useWorkflowStore } from '../store'
|
|
|
import {
|
|
|
+ CUSTOM_NODE, DSL_EXPORT_CHECK,
|
|
|
+ WORKFLOW_DATA_UPDATE,
|
|
|
+} from '../constants'
|
|
|
+import type { Node, WorkflowDataUpdator } from '../types'
|
|
|
+import { ControlMode } from '../types'
|
|
|
+import {
|
|
|
+ getLayoutByDagre,
|
|
|
initialEdges,
|
|
|
initialNodes,
|
|
|
} from '../utils'
|
|
|
+import {
|
|
|
+ useNodesReadOnly,
|
|
|
+ useSelectionInteractions,
|
|
|
+ useWorkflowReadOnly,
|
|
|
+} from '../hooks'
|
|
|
import { useEdgesInteractions } from './use-edges-interactions'
|
|
|
import { useNodesInteractions } from './use-nodes-interactions'
|
|
|
import { useNodesSyncDraft } from './use-nodes-sync-draft'
|
|
|
+import { WorkflowHistoryEvent, useWorkflowHistory } from './use-workflow-history'
|
|
|
import { useEventEmitterContextContext } from '@/context/event-emitter'
|
|
|
import { fetchWorkflowDraft } from '@/service/workflow'
|
|
|
import { exportAppConfig } from '@/service/apps'
|
|
@@ -39,6 +51,158 @@ export const useWorkflowInteractions = () => {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+export const useWorkflowMoveMode = () => {
|
|
|
+ const setControlMode = useStore(s => s.setControlMode)
|
|
|
+ const {
|
|
|
+ getNodesReadOnly,
|
|
|
+ } = useNodesReadOnly()
|
|
|
+ const { handleSelectionCancel } = useSelectionInteractions()
|
|
|
+
|
|
|
+ const handleModePointer = useCallback(() => {
|
|
|
+ if (getNodesReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ setControlMode(ControlMode.Pointer)
|
|
|
+ }, [getNodesReadOnly, setControlMode])
|
|
|
+
|
|
|
+ const handleModeHand = useCallback(() => {
|
|
|
+ if (getNodesReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ setControlMode(ControlMode.Hand)
|
|
|
+ handleSelectionCancel()
|
|
|
+ }, [getNodesReadOnly, setControlMode, handleSelectionCancel])
|
|
|
+
|
|
|
+ return {
|
|
|
+ handleModePointer,
|
|
|
+ handleModeHand,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+export const useWorkflowOrganize = () => {
|
|
|
+ const workflowStore = useWorkflowStore()
|
|
|
+ const store = useStoreApi()
|
|
|
+ const reactflow = useReactFlow()
|
|
|
+ const { getNodesReadOnly } = useNodesReadOnly()
|
|
|
+ const { saveStateToHistory } = useWorkflowHistory()
|
|
|
+ const { handleSyncWorkflowDraft } = useNodesSyncDraft()
|
|
|
+
|
|
|
+ const handleLayout = useCallback(async () => {
|
|
|
+ if (getNodesReadOnly())
|
|
|
+ return
|
|
|
+ workflowStore.setState({ nodeAnimation: true })
|
|
|
+ const {
|
|
|
+ getNodes,
|
|
|
+ edges,
|
|
|
+ setNodes,
|
|
|
+ } = store.getState()
|
|
|
+ const { setViewport } = reactflow
|
|
|
+ const nodes = getNodes()
|
|
|
+ const layout = getLayoutByDagre(nodes, edges)
|
|
|
+ const rankMap = {} as Record<string, Node>
|
|
|
+
|
|
|
+ nodes.forEach((node) => {
|
|
|
+ if (!node.parentId && node.type === CUSTOM_NODE) {
|
|
|
+ const rank = layout.node(node.id).rank!
|
|
|
+
|
|
|
+ if (!rankMap[rank]) {
|
|
|
+ rankMap[rank] = node
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ if (rankMap[rank].position.y > node.position.y)
|
|
|
+ rankMap[rank] = node
|
|
|
+ }
|
|
|
+ }
|
|
|
+ })
|
|
|
+
|
|
|
+ const newNodes = produce(nodes, (draft) => {
|
|
|
+ draft.forEach((node) => {
|
|
|
+ if (!node.parentId && node.type === CUSTOM_NODE) {
|
|
|
+ const nodeWithPosition = layout.node(node.id)
|
|
|
+
|
|
|
+ node.position = {
|
|
|
+ x: nodeWithPosition.x - node.width! / 2,
|
|
|
+ y: nodeWithPosition.y - node.height! / 2 + rankMap[nodeWithPosition.rank!].height! / 2,
|
|
|
+ }
|
|
|
+ }
|
|
|
+ })
|
|
|
+ })
|
|
|
+ setNodes(newNodes)
|
|
|
+ const zoom = 0.7
|
|
|
+ setViewport({
|
|
|
+ x: 0,
|
|
|
+ y: 0,
|
|
|
+ zoom,
|
|
|
+ })
|
|
|
+ saveStateToHistory(WorkflowHistoryEvent.LayoutOrganize)
|
|
|
+ setTimeout(() => {
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ })
|
|
|
+ }, [getNodesReadOnly, store, reactflow, workflowStore, handleSyncWorkflowDraft, saveStateToHistory])
|
|
|
+ return {
|
|
|
+ handleLayout,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+export const useWorkflowZoom = () => {
|
|
|
+ const { handleSyncWorkflowDraft } = useNodesSyncDraft()
|
|
|
+ const { getWorkflowReadOnly } = useWorkflowReadOnly()
|
|
|
+ const {
|
|
|
+ zoomIn,
|
|
|
+ zoomOut,
|
|
|
+ zoomTo,
|
|
|
+ fitView,
|
|
|
+ } = useReactFlow()
|
|
|
+
|
|
|
+ const handleFitView = useCallback(() => {
|
|
|
+ if (getWorkflowReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ fitView()
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ }, [getWorkflowReadOnly, fitView, handleSyncWorkflowDraft])
|
|
|
+
|
|
|
+ const handleBackToOriginalSize = useCallback(() => {
|
|
|
+ if (getWorkflowReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ zoomTo(1)
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ }, [getWorkflowReadOnly, zoomTo, handleSyncWorkflowDraft])
|
|
|
+
|
|
|
+ const handleSizeToHalf = useCallback(() => {
|
|
|
+ if (getWorkflowReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ zoomTo(0.5)
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ }, [getWorkflowReadOnly, zoomTo, handleSyncWorkflowDraft])
|
|
|
+
|
|
|
+ const handleZoomOut = useCallback(() => {
|
|
|
+ if (getWorkflowReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ zoomOut()
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ }, [getWorkflowReadOnly, zoomOut, handleSyncWorkflowDraft])
|
|
|
+
|
|
|
+ const handleZoomIn = useCallback(() => {
|
|
|
+ if (getWorkflowReadOnly())
|
|
|
+ return
|
|
|
+
|
|
|
+ zoomIn()
|
|
|
+ handleSyncWorkflowDraft()
|
|
|
+ }, [getWorkflowReadOnly, zoomIn, handleSyncWorkflowDraft])
|
|
|
+
|
|
|
+ return {
|
|
|
+ handleFitView,
|
|
|
+ handleBackToOriginalSize,
|
|
|
+ handleSizeToHalf,
|
|
|
+ handleZoomOut,
|
|
|
+ handleZoomIn,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
export const useWorkflowUpdate = () => {
|
|
|
const reactflow = useReactFlow()
|
|
|
const workflowStore = useWorkflowStore()
|