jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-05-27 06:07:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: mcp proxy eventData (#1985)

Browse Source
This commit is contained in:
Jingze
2025-03-31 18:38:52 +08:00
committed by GitHub
parent 9ebe968921
commit ae9a06b05c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
plugins/golang-filter/mcp-server/filter.go
View File

@@ -161,7 +161,8 @@ func (f *filter) EncodeData(buffer api.BufferInstance, endStream bool) api.Statu
sessionID := f.proxyURL.Query().Get("sessionId") sessionID := f.proxyURL.Query().Get("sessionId")
if sessionID != "" { if sessionID != "" {
channel := internal.GetSSEChannelName(sessionID) channel := internal.GetSSEChannelName(sessionID)
publishErr := f.config.redisClient.Publish(channel, buffer.String()) eventData := fmt.Sprintf("event: message\ndata: %s\n\n", buffer.String())
publishErr := f.config.redisClient.Publish(channel, eventData)
if publishErr != nil { if publishErr != nil {
api.LogErrorf("Failed to publish wasm mcp server message to Redis: %v", publishErr) api.LogErrorf("Failed to publish wasm mcp server message to Redis: %v", publishErr)
} }