opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-15 18:06:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: rm WorkflowEvent type

Browse Source
This commit is contained in:
hjlarry 2026-04-09 13:32:56 +08:00
parent 4695fb66ae
commit e180434902
1 changed files with 5 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
web/app/components/workflow/index.tsx
View File

@ -141,18 +141,6 @@ type WorkflowDataUpdatePayload = {
environment_variables?: EnvironmentVariable[]
}
type WorkflowEvent = {
type?: string
payload?: unknown
}
const isWorkflowDataUpdatePayload = (payload: unknown): payload is WorkflowDataUpdatePayload => {
if (!payload || typeof payload !== 'object')
return false
const candidate = payload as WorkflowDataUpdatePayload
return Array.isArray(candidate.nodes) && Array.isArray(candidate.edges)
}
export type WorkflowProps = {
nodes: Node[]
edges: Edge[]
@ -292,7 +280,6 @@ export const Workflow: FC<WorkflowProps> = memo(({
handleCommentIconClick(target)
}, [activeComment, handleCommentIconClick, visibleComments])
const store = useStoreApi()
eventEmitter?.useSubscription((v: any) => {
if (v.type === WORKFLOW_DATA_UPDATE) {
setNodes(v.payload.nodes)
@ -300,13 +287,13 @@ export const Workflow: FC<WorkflowProps> = memo(({
setEdges(v.payload.edges)
workflowStore.setState({ edgeMenu: undefined })
if (workflowEvent.payload.viewport)
reactflow.setViewport(workflowEvent.payload.viewport)
if (v.payload.viewport)
reactflow.setViewport(v.payload.viewport)
if (workflowEvent.payload.hash)
setSyncWorkflowDraftHash(workflowEvent.payload.hash)
if (v.payload.hash)
setSyncWorkflowDraftHash(v.payload.hash)
onWorkflowDataUpdate?.(workflowEvent.payload)
onWorkflowDataUpdate?.(v.payload)
setTimeout(() => setControlPromptEditorRerenderKey(Date.now()))
}