From 4f0c2b794c08d8519ddd065d9b711dd9a5588d44 Mon Sep 17 00:00:00 2001 From: 0xff26b9a8 <25315788+0xff26b9a8@users.noreply.github.com> Date: Thu, 22 Jan 2026 14:38:55 +0800 Subject: [PATCH] style: gofmt antigravity_gateway_service.go --- .../internal/service/antigravity_gateway_service.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/backend/internal/service/antigravity_gateway_service.go b/backend/internal/service/antigravity_gateway_service.go index fe3cf414..3b847bcb 100644 --- a/backend/internal/service/antigravity_gateway_service.go +++ b/backend/internal/service/antigravity_gateway_service.go @@ -1994,14 +1994,14 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map } result, _, setParts := getOrCreateGeminiParts(response) - + // 合并策略: // 1. 保持原始顺序 // 2. 连续的普通 text parts 合并为一个 // 3. thinking、functionCall、inlineData 等保持原样 var mergedParts []any var textBuffer strings.Builder - + flushTextBuffer := func() { if textBuffer.Len() > 0 { mergedParts = append(mergedParts, map[string]any{ @@ -2010,7 +2010,7 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map textBuffer.Reset() } } - + for _, part := range collectedParts { // 检查是否是普通 text part if text, ok := part["text"].(string); ok { @@ -2029,10 +2029,10 @@ func mergeCollectedPartsToResponse(response map[string]any, collectedParts []map mergedParts = append(mergedParts, part) } } - + // 刷新剩余的 text flushTextBuffer() - + setParts(mergedParts) return result } @@ -2318,7 +2318,7 @@ func (s *AntigravityGatewayService) handleClaudeStreamToNonStreaming(c *gin.Cont // 保留最后一个有 parts 的响应,并收集所有 parts if parts := extractGeminiParts(parsed); len(parts) > 0 { lastWithParts = parsed - + // 收集所有 parts(text、thinking、functionCall、inlineData 等) collectedParts = append(collectedParts, parts...) }