style: gofmt antigravity_gateway_service.go
This commit is contained in:
@@ -1994,14 +1994,14 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map
|
|||||||
}
|
}
|
||||||
|
|
||||||
result, _, setParts := getOrCreateGeminiParts(response)
|
result, _, setParts := getOrCreateGeminiParts(response)
|
||||||
|
|
||||||
// 合并策略:
|
// 合并策略:
|
||||||
// 1. 保持原始顺序
|
// 1. 保持原始顺序
|
||||||
// 2. 连续的普通 text parts 合并为一个
|
// 2. 连续的普通 text parts 合并为一个
|
||||||
// 3. thinking、functionCall、inlineData 等保持原样
|
// 3. thinking、functionCall、inlineData 等保持原样
|
||||||
var mergedParts []any
|
var mergedParts []any
|
||||||
var textBuffer strings.Builder
|
var textBuffer strings.Builder
|
||||||
|
|
||||||
flushTextBuffer := func() {
|
flushTextBuffer := func() {
|
||||||
if textBuffer.Len() > 0 {
|
if textBuffer.Len() > 0 {
|
||||||
mergedParts = append(mergedParts, map[string]any{
|
mergedParts = append(mergedParts, map[string]any{
|
||||||
@@ -2010,7 +2010,7 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map
|
|||||||
textBuffer.Reset()
|
textBuffer.Reset()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, part := range collectedParts {
|
for _, part := range collectedParts {
|
||||||
// 检查是否是普通 text part
|
// 检查是否是普通 text part
|
||||||
if text, ok := part["text"].(string); ok {
|
if text, ok := part["text"].(string); ok {
|
||||||
@@ -2029,10 +2029,10 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map
|
|||||||
mergedParts = append(mergedParts, part)
|
mergedParts = append(mergedParts, part)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 刷新剩余的 text
|
// 刷新剩余的 text
|
||||||
flushTextBuffer()
|
flushTextBuffer()
|
||||||
|
|
||||||
setParts(mergedParts)
|
setParts(mergedParts)
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
@@ -2318,7 +2318,7 @@ func (s *AntigravityGatewayService) handleClaudeStreamToNonStreaming(c *gin.Cont
|
|||||||
// 保留最后一个有 parts 的响应,并收集所有 parts
|
// 保留最后一个有 parts 的响应,并收集所有 parts
|
||||||
if parts := extractGeminiParts(parsed); len(parts) > 0 {
|
if parts := extractGeminiParts(parsed); len(parts) > 0 {
|
||||||
lastWithParts = parsed
|
lastWithParts = parsed
|
||||||
|
|
||||||
// 收集所有 parts(text、thinking、functionCall、inlineData 等)
|
// 收集所有 parts(text、thinking、functionCall、inlineData 等)
|
||||||
collectedParts = append(collectedParts, parts...)
|
collectedParts = append(collectedParts, parts...)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user