From ae9a06b05c37adb3cbb9fc6a040fd872f4bfb172 Mon Sep 17 00:00:00 2001
From: Jingze <52855280+Jing-ze@users.noreply.github.com>
Date: Mon, 31 Mar 2025 18:38:52 +0800
Subject: [PATCH] fix: mcp proxy eventData (#1985)

---
 plugins/golang-filter/mcp-server/filter.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/golang-filter/mcp-server/filter.go b/plugins/golang-filter/mcp-server/filter.go
index 198132f30..a9aa96b9c 100644
--- a/plugins/golang-filter/mcp-server/filter.go
+++ b/plugins/golang-filter/mcp-server/filter.go
@@ -161,7 +161,8 @@ func (f *filter) EncodeData(buffer api.BufferInstance, endStream bool) api.Statu
 		sessionID := f.proxyURL.Query().Get("sessionId")
 		if 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 {
 				api.LogErrorf("Failed to publish wasm mcp server message to Redis: %v", publishErr)
 			}