jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-03-10 19:51:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: Bypass the response body processing for MCP streamable transport (#3187)

Browse Source
This commit is contained in:
Kent Dong
2025-12-03 16:01:08 +08:00
committed by GitHub
parent 116e7c6904
commit 3e24d66079
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
plugins/golang-filter/mcp-session/filter.go
View File

@@ -238,10 +238,9 @@ func (f *filter) EncodeData(buffer api.BufferInstance, endStream bool) api.Statu
ret := api.Continue
api.LogDebugf("Upstream Type: %s", f.matchedRule.UpstreamType)
switch f.matchedRule.UpstreamType {
case common.RestUpstream, common.StreamableUpstream:
case common.RestUpstream:
api.LogDebugf("Encoding data from Rest upstream")
ret = f.encodeDataFromRestUpstream(buffer, endStream)
break
case common.SSEUpstream:
api.LogDebugf("Encoding data from SSE upstream")
ret = f.encodeDataFromSSEUpstream(buffer, endStream)
@@ -249,6 +248,8 @@ func (f *filter) EncodeData(buffer api.BufferInstance, endStream bool) api.Statu
// Always continue as long as the stream has ended.
ret = api.Continue
}
case common.StreamableUpstream:
// Do nothing for streamable upstream
}
return ret
}