From 3ed70b2a1e9d69e3b4500bd0c44c847d6e17c33d Mon Sep 17 00:00:00 2001 From: johnlanni Date: Tue, 9 Sep 2025 20:05:39 +0800 Subject: [PATCH] more compatiable fix for SAA --- plugins/golang-filter/mcp-session/filter.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/golang-filter/mcp-session/filter.go b/plugins/golang-filter/mcp-session/filter.go index f31fa2404..e67da1151 100644 --- a/plugins/golang-filter/mcp-session/filter.go +++ b/plugins/golang-filter/mcp-session/filter.go @@ -264,7 +264,7 @@ func (f *filter) encodeDataFromRestUpstream(buffer api.BufferInstance, endStream sessionID := f.proxyURL.Query().Get("sessionId") if sessionID != "" { channel := common.GetSSEChannelName(sessionID) - eventData := fmt.Sprintf("event: message\ndata: %s\n\n", buffer.String()) + eventData := fmt.Sprintf("event: message\ndata: %s\n\n", strings.TrimSuffix(buffer.String(), "\n")) publishErr := f.config.redisClient.Publish(channel, eventData) if publishErr != nil { api.LogErrorf("Failed to publish wasm mcp server message to Redis: %v", publishErr)