fix: 修复空文本块和stop_reason判断问题

主要修复：
1. handlers.go: 移除预先发送的空content_block_start，避免空文本块违规
   - 依赖sse_state_manager的自动启动机制，只在有实际内容时才生成块
   - 确保每个content_block都有实际内容

2. stop_reason_manager.go: 修复stop_reason判断逻辑
   - 根据Claude API规范，只要消息包含tool_use块就应返回"tool_use"
   - 修复之前只检查活跃工具导致的错误判断

3. converter/codewhisperer.go: 优化消息处理逻辑
   - 改进user消息缓冲处理流程

4. parser/tool_lifecycle_manager.go: 清理未使用的方法
   - 删除allToolsCompleted()方法

这些修复确保完全符合Claude API规范，避免SSE事件序列违规

Author: caidaoli

converter/codewhisperer.go

@@ -387,7 +387,9 @@ func BuildCodeWhispererRequest(anthropicReq types.AnthropicRequest, ctx *gin.Con
 			if msg.Role == "user" {
 				// 收集user消息到缓冲区
 				userMessagesBuffer = append(userMessagesBuffer, msg)
-			} else if msg.Role == "assistant" {
+				continue
+			}
+			if msg.Role == "assistant" {
 				// 遇到assistant，处理之前累积的user消息
 				if len(userMessagesBuffer) > 0 {
 					// 合并所有累积的user消息

parser/tool_lifecycle_manager.go

@@ -345,11 +345,6 @@ func (tlm *ToolLifecycleManager) GetCompletedTools() map[string]*ToolExecution {
 	return result
 }
 
-// allToolsCompleted 检查是否所有工具都已完成
-func (tlm *ToolLifecycleManager) allToolsCompleted() bool {
-	return len(tlm.activeTools) == 0
-}
-
 // getOrAssignBlockIndex 获取或分配块索引
 func (tlm *ToolLifecycleManager) getOrAssignBlockIndex(toolID string) int {
 	if index, exists := tlm.blockIndexMap[toolID]; exists {
@@ -379,7 +374,7 @@ func (tlm *ToolLifecycleManager) generateTextIntroduction(firstTool ToolCall) []
 	// 修复：删除重复的content_block_start和content_block_stop
 	// 原因：block[0]已在sendInitialEvents()中启动（handlers.go:148-156），会在sendFinalEvents()中关闭
 	// 这里只需要发送content_block_delta来添加介绍文本即可
-	// 
+	//
 	// 之前的问题：
 	// 1. sendInitialEvents发送content_block_start(index:0) → SSEStateManager标记block[0].Started=true
 	// 2. generateTextIntroduction再次发送content_block_start(index:0) → 违规！block已started但未stopped

server/handlers.go

@@ -123,8 +123,15 @@ func handleGenericStreamRequest(c *gin.Context, anthropicReq types.AnthropicRequ
 
 // createAnthropicStreamEvents 创建Anthropic流式初始事件
 func createAnthropicStreamEvents(messageId string, inputTokens int, model string) []map[string]any {
-	// 创建完整的初始事件序列，包括content_block_start
-	// 这确保符合Claude API规范的完整SSE事件序列
+	// 创建基础初始事件序列，不包含content_block_start
+	// 
+	// 关键修复：移除预先发送的空文本块
+	// 问题：如果预先发送content_block_start(text)，但上游只返回tool_use没有文本，
+	//      会导致空文本块（start -> stop 之间没有delta），违反Claude API规范
+	// 
+	// 解决方案：依赖sse_state_manager.handleContentBlockDelta()中的自动启动机制
+	//          只有在实际收到内容（文本或工具）时才动态生成content_block_start
+	//          这确保每个content_block都有实际内容
 	events := []map[string]any{
 		{
 			"type": "message_start",
@@ -145,14 +152,6 @@ func createAnthropicStreamEvents(messageId string, inputTokens int, model string
 		{
 			"type": "ping",
 		},
-		{
-			"type":  "content_block_start",
-			"index": 0,
-			"content_block": map[string]any{
-				"type": "text",
-				"text": "",
-			},
-		},
 	}
 	return events
 }

server/stop_reason_manager.go

@@ -55,10 +55,23 @@ func (srm *StopReasonManager) DetermineStopReason() string {
 		return "max_tokens"
 	}
 
-	// 规则2: 检查是否有活跃的工具调用等待执行
-	// 根据Claude规范：只有当Claude主动调用工具且期待工具执行时才使用tool_use
-	if srm.hasActiveToolCalls {
-		logger.Debug("确定stop_reason: tool_use - 检测到活跃工具调用")
+	// 规则2: 检查是否有工具调用（活跃或已完成）
+	// *** 关键修复：根据Claude规范，只要消息包含tool_use块，stop_reason就应该是tool_use ***
+	// 根据 Anthropic API 文档 (https://docs.anthropic.com/en/api/messages-streaming):
+	//   stop_reason: "tool_use" - The model wants to use a tool
+	// 
+	// 只要消息中包含任何 tool_use 内容块（无论是正在流式传输还是已完成），
+	// stop_reason 就应该是 "tool_use"。这与工具的"生命周期状态"无关。
+	//
+	// 之前的BUG: 只检查 hasActiveToolCalls（正在流式传输的工具）
+	// 问题场景: 工具块关闭后被移到 completedTools，导致 hasActiveToolCalls=false，
+	//          错误返回 "end_turn" 而非 "tool_use"
+	//
+	// 修复: 检查 hasActiveToolCalls OR hasCompletedTools
+	if srm.hasActiveToolCalls || srm.hasCompletedTools {
+		logger.Debug("确定stop_reason: tool_use - 消息包含工具调用",
+			logger.Bool("has_active", srm.hasActiveToolCalls),
+			logger.Bool("has_completed", srm.hasCompletedTools))
 		return "tool_use"
 	}
 

server/stream_processor.go

@@ -46,6 +46,7 @@ type StreamProcessorContext struct {
 
 	// 工具调用跟踪
 	toolUseIdByBlockIndex map[int]string
+	completedToolUseIds   map[string]bool // 已完成的工具ID集合（用于stop_reason判断）
 
 	// 原始数据缓冲
 	rawDataBuffer *strings.Builder
@@ -72,6 +73,7 @@ func NewStreamProcessorContext(
 		tokenEstimator:        utils.NewTokenEstimator(),
 		compliantParser:       parser.NewCompliantEventStreamParser(false),
 		toolUseIdByBlockIndex: make(map[int]string),
+		completedToolUseIds:   make(map[string]bool),
 		rawDataBuffer:         utils.GetStringBuilder(),
 	}
 }
@@ -99,6 +101,14 @@ func (ctx *StreamProcessorContext) Cleanup() {
 		ctx.toolUseIdByBlockIndex = nil
 	}
 
+	// 清理已完成工具集合
+	if ctx.completedToolUseIds != nil {
+		for k := range ctx.completedToolUseIds {
+			delete(ctx.completedToolUseIds, k)
+		}
+		ctx.completedToolUseIds = nil
+	}
+
 	// 清空文本聚合状态
 	ctx.pendingText = ""
 	ctx.lastFlushedText = ""
@@ -217,6 +227,9 @@ func (ctx *StreamProcessorContext) sendInitialEvents(eventCreator func(string, i
 	// 直接使用上下文中的 inputTokens（已经通过 TokenEstimator 精确计算）
 	initialEvents := eventCreator(ctx.messageID, ctx.inputTokens, ctx.req.Model)
 
+	// 注意：初始事件现在只包含 message_start 和 ping
+	// content_block_start 会在收到实际内容时由 sse_state_manager 自动生成
+	// 这避免了发送空内容块（如果上游只返回 tool_use 而没有文本）
 	for _, event := range initialEvents {
 		// 使用状态管理器发送事件
 		if err := ctx.sseStateManager.SendEvent(ctx.c, ctx.sender, event); err != nil {
@@ -269,6 +282,12 @@ func (ctx *StreamProcessorContext) processToolUseStop(dataMap map[string]any) {
 	}
 
 	if toolId, exists := ctx.toolUseIdByBlockIndex[idx]; exists && toolId != "" {
+		// *** 关键修复：在删除前先记录到已完成工具集合 ***
+		// 问题：直接删除导致sendFinalEvents()中len(toolUseIdByBlockIndex)==0
+		// 结果：stop_reason错误判断为end_turn而非tool_use
+		// 解决：先添加到completedToolUseIds，保持工具调用的证据
+		ctx.completedToolUseIds[toolId] = true
+
 		logger.Debug("工具执行完成",
 			logger.String("tool_id", toolId),
 			logger.Int("block_index", idx))
@@ -367,10 +386,17 @@ func (ctx *StreamProcessorContext) sendFinalEvents() error {
 	}
 
 	// 更新工具调用状态
-	ctx.stopReasonManager.UpdateToolCallStatus(
-		len(ctx.toolUseIdByBlockIndex) > 0,
-		len(ctx.toolUseIdByBlockIndex) > 0,
-	)
+	// 使用已完成工具集合来判断，因为toolUseIdByBlockIndex在stop时已被清空
+	hasActiveTools := len(ctx.toolUseIdByBlockIndex) > 0
+	hasCompletedTools := len(ctx.completedToolUseIds) > 0
+
+	logger.Debug("更新工具调用状态",
+		logger.Bool("has_active_tools", hasActiveTools),
+		logger.Bool("has_completed_tools", hasCompletedTools),
+		logger.Int("active_count", len(ctx.toolUseIdByBlockIndex)),
+		logger.Int("completed_count", len(ctx.completedToolUseIds)))
+
+	ctx.stopReasonManager.UpdateToolCallStatus(hasActiveTools, hasCompletedTools)
 
 	// 计算输出tokens（使用TokenEstimator统一算法）
 	content := ctx.rawDataBuffer.String()[:utils.IntMin(ctx.totalOutputChars*4, ctx.rawDataBuffer.Len())]