mirror of
https://github.com/langgenius/dify.git
synced 2026-01-05 22:15:52 +00:00
init edges
This commit is contained in:
@@ -168,7 +168,7 @@ const WorkflowWrap = memo(() => {
|
||||
}, [data])
|
||||
const edgesData = useMemo(() => {
|
||||
if (data)
|
||||
return initialEdges(data.graph.edges)
|
||||
return initialEdges(data.graph.edges, data.graph.nodes)
|
||||
|
||||
return []
|
||||
}, [data])
|
||||
|
||||
@@ -42,10 +42,21 @@ export const initialNodes = (nodes: Node[], edges: Edge[]) => {
|
||||
})
|
||||
}
|
||||
|
||||
export const initialEdges = (edges: Edge[]) => {
|
||||
export const initialEdges = (edges: Edge[], nodes: Node[]) => {
|
||||
const nodesMap = nodes.reduce((acc, node) => {
|
||||
acc[node.id] = node
|
||||
|
||||
return acc
|
||||
}, {} as Record<string, Node>)
|
||||
return edges.map((edge) => {
|
||||
edge.type = 'custom'
|
||||
|
||||
if (!edge.data?.sourceType)
|
||||
edge.data = { ...edge.data, sourceType: nodesMap[edge.source].data.type! } as any
|
||||
|
||||
if (!edge.data?.targetType)
|
||||
edge.data = { ...edge.data, targetType: nodesMap[edge.target].data.type! } as any
|
||||
|
||||
return edge
|
||||
})
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user