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

opt: unify the end-of-line markers in the MCP session filter. (#2403)

Browse Source
This commit is contained in:
澄潭
2025-06-12 18:58:56 +08:00
committed by GitHub
parent 95f32002d2
commit 087cb48fc5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/golang-filter/mcp-session/common/sse.go
View File

@@ -136,7 +136,7 @@ func (s *SSEServer) HandleSSE(cb api.FilterCallbackHandler, stopChan chan struct
} }
// Send the initial endpoint event // Send the initial endpoint event
initialEvent := fmt.Sprintf("event: endpoint\ndata: %s\r\n\r\n", messageEndpoint) initialEvent := fmt.Sprintf("event: endpoint\ndata: %s\n\n", messageEndpoint)
err = s.redisClient.Publish(channel, initialEvent) err = s.redisClient.Publish(channel, initialEvent)
if err != nil { if err != nil {
api.LogErrorf("Failed to send initial event: %v", err) api.LogErrorf("Failed to send initial event: %v", err)
@@ -210,7 +210,7 @@ func (s *SSEServer) HandleMessage(w http.ResponseWriter, r *http.Request, body j
var status int var status int
// Only send response if there is one (not for notifications) // Only send response if there is one (not for notifications)
if response != nil { if response != nil {
if sessionID != ""{ if sessionID != "" {
w.WriteHeader(http.StatusAccepted) w.WriteHeader(http.StatusAccepted)
status = http.StatusAccepted status = http.StatusAccepted
} else { } else {