mirror of https://github.com/langgenius/dify.git
sync workflow publish to mcp server
This commit is contained in:
parent
a9e74b21f1
commit
6c7a3ce4bb
|
|
@ -16,6 +16,7 @@ import {
|
|||
useUpdateMCPServer,
|
||||
} from '@/service/use-tools'
|
||||
import cn from '@/utils/classnames'
|
||||
import { webSocketClient } from '@/app/components/workflow/collaboration/core/websocket-manager'
|
||||
|
||||
export type ModalProps = {
|
||||
appID: string
|
||||
|
|
@ -59,6 +60,21 @@ const MCPServerModal = ({
|
|||
return res
|
||||
}
|
||||
|
||||
const emitMcpServerUpdate = (action: 'created' | 'updated') => {
|
||||
const socket = webSocketClient.getSocket(appID)
|
||||
if (!socket) return
|
||||
|
||||
const timestamp = Date.now()
|
||||
socket.emit('collaboration_event', {
|
||||
type: 'mcp_server_update',
|
||||
data: {
|
||||
action,
|
||||
timestamp,
|
||||
},
|
||||
timestamp,
|
||||
})
|
||||
}
|
||||
|
||||
const submit = async () => {
|
||||
if (!data) {
|
||||
const payload: any = {
|
||||
|
|
@ -71,6 +87,7 @@ const MCPServerModal = ({
|
|||
|
||||
await createMCPServer(payload)
|
||||
invalidateMCPServerDetail(appID)
|
||||
emitMcpServerUpdate('created')
|
||||
onHide()
|
||||
}
|
||||
else {
|
||||
|
|
@ -83,6 +100,7 @@ const MCPServerModal = ({
|
|||
payload.description = description
|
||||
await updateMCPServer(payload)
|
||||
invalidateMCPServerDetail(appID)
|
||||
emitMcpServerUpdate('updated')
|
||||
onHide()
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue