Method validateMessageHistory

pkg/agent/agent.go:1623–1667

validateMessageHistory 验证消息历史格式是否正确 DeepSeek 等 API 要求：每个包含 tool_calls 的 assistant 消息后必须紧跟对应的 tool_result 消息 注意：__parse_error__ 标记的消息不在这里处理，而是在 convertMessages 中替换为有效 JSON

(messages []types.Message)

// DeepSeek 等 API 要求：每个包含 tool_calls 的 assistant 消息后必须紧跟对应的 tool_result 消息
// 注意：__parse_error__ 标记的消息不在这里处理，而是在 convertMessages 中替换为有效 JSON
func (a *Agent) validateMessageHistory(messages []types.Message) bool {
	for i, msg := range messages {
		// 检查是否有 tool_calls，并收集所有 tool_call IDs
		var toolCallIDs []string
		hasToolCalls := false
		for _, block := range msg.ContentBlocks {
			if toolUse, ok := block.(*types.ToolUseBlock); ok {
				hasToolCalls = true
				toolCallIDs = append(toolCallIDs, toolUse.ID)
				// 注意：不再检查 __parse_error__，让 convertMessages 处理
			}
		}

		if hasToolCalls {
			// 如果是最后一条消息，无效（tool_calls 必须有 response）
			if i+1 >= len(messages) {
				return false
			}

			// 检查紧接着的下一条消息是否包含 tool_result
			nextMsg := messages[i+1]
			var toolResultIDs []string
			hasToolResult := false
			for _, block := range nextMsg.ContentBlocks {
				if toolResult, ok := block.(*types.ToolResultBlock); ok {
					hasToolResult = true
					toolResultIDs = append(toolResultIDs, toolResult.ToolUseID)
				}
			}

			if !hasToolResult {
				return false
			}

			// 验证每个 tool_call ID 都有对应的 tool_result
			for _, toolCallID := range toolCallIDs {
				found := slices.Contains(toolResultIDs, toolCallID)
				if !found {
					return false
				}
			}
		}
	}
	return true
}

// removeIncompleteToolCalls 移除所有不完整的 tool_call 序列
// 策略：找到第一个不完整的 tool_call，截断到该位置之前