opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-08-29 00:16:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

broadcast workflow updates after DSL import

Browse Source
This commit is contained in:
hjlarry 2026-04-13 18:00:51 +08:00
parent 5e0e0982bc
commit df5d3a6dbc
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
web/app/components/workflow/__tests__/update-dsl-modal.spec.tsx
View File

@ -17,6 +17,7 @@ class MockFileReader {
vi.stubGlobal('FileReader', MockFileReader as unknown as typeof FileReader)
const mockEmit = vi.fn()
const mockEmitWorkflowUpdate = vi.hoisted(() => vi.fn())
vi.mock('@/app/components/base/ui/toast', () => ({
toast: {
@ -39,6 +40,12 @@ vi.mock('@/service/workflow', () => ({
fetchWorkflowDraft: (path: string) => mockFetchWorkflowDraft(path),
}))
vi.mock('../collaboration/core/collaboration-manager', () => ({
collaborationManager: {
emitWorkflowUpdate: mockEmitWorkflowUpdate,
},
}))
const mockHandleCheckPluginDependencies = vi.fn()
vi.mock('@/app/components/workflow/plugin-dependency/hooks', () => ({
usePluginDependencies: () => ({
@ -138,6 +145,7 @@ describe('UpdateDSLModal', () => {
expect(mockEmit).toHaveBeenCalledWith(expect.objectContaining({
type: 'WORKFLOW_DATA_UPDATE',
}))
expect(mockEmitWorkflowUpdate).toHaveBeenCalledWith('app-1')
expect(defaultProps.onImport).toHaveBeenCalledTimes(1)
expect(defaultProps.onCancel).toHaveBeenCalledTimes(1)
})
@ -187,6 +195,7 @@ describe('UpdateDSLModal', () => {
await waitFor(() => {
expect(mockImportDSLConfirm).toHaveBeenCalledWith({ import_id: 'import-2' })
})
expect(mockEmitWorkflowUpdate).toHaveBeenCalledWith('app-1')
})
it('should open the pending modal after the timeout and allow dismissing it', async () => {

4
web/app/components/workflow/update-dsl-modal.tsx
View File

@ -114,6 +114,7 @@ const UpdateDSLModal = ({
}
await handleWorkflowUpdate(appId)
collaborationManager.emitWorkflowUpdate(appId)
onImport?.()
const payload = getImportNotificationPayload(status, t)
toast[payload.type](payload.message, payload.children ? { description: payload.children } : undefined)
@ -183,9 +184,6 @@ const UpdateDSLModal = ({
if (isImportCompleted(status)) {
await handleCompletedImport(status, app_id)
// Notify other collaboration clients about the workflow update
if (app_id)
collaborationManager.emitWorkflowUpdate(app_id)
}
else if (status === DSLImportStatus.FAILED) {
setLoading(false)