fix: 优化工具调用与思考模式的兼容性处理

- 修复思考内容开始标记识别逻辑,添加缓冲区处理跨块内容
- 工具调用时自动禁用 auto_web_search 避免冲突
- 优化 glm_block 前文本提取,正确处理 details 标签
- 关闭 preview_mode 以提升稳定性
- 添加上游响应和工具处理的调试日志

Author: chanhanzhan

internal/chat.go

@@ -120,7 +120,7 @@ func extractAllMediaURLs(messages []Message) (imageURLs, videoURLs []string) {
 	return imageURLs, videoURLs
 }
 
-func makeUpstreamRequest(token string, messages []Message, model string, imageURLs, videoURLs []string) (*http.Response, string, error) {
+func makeUpstreamRequest(token string, messages []Message, model string, imageURLs, videoURLs []string, hasTools bool) (*http.Response, string, error) {
 	payload, err := DecodeJWTPayload(token)
 	if err != nil || payload == nil {
 		return nil, "", fmt.Errorf("invalid token")
@@ -244,8 +244,8 @@ func makeUpstreamRequest(token string, messages []Message, model string, imageUR
 		"features": map[string]interface{}{
 			"image_generation": true,
 			"web_search":       true,
-			"auto_web_search":  autoWebSearch,
-			"preview_mode":     true,
+			"auto_web_search":  autoWebSearch && !hasTools,
+			"preview_mode":     false,
 			"flags":            []string{},
 			"enable_thinking":  enableThinking,
 		},
@@ -370,10 +370,15 @@ type ThinkingFilter struct {
 
 func (f *ThinkingFilter) ProcessThinking(deltaContent string) string {
 	if !f.hasSeenFirstThinking {
-		f.hasSeenFirstThinking = true
-		if idx := strings.Index(deltaContent, "> "); idx != -1 {
-			deltaContent = deltaContent[idx+2:]
+		// 合并缓存和当前内容，查找 "> " 作为思考内容的开始标记
+		combined := f.buffer + deltaContent
+		if idx := strings.Index(combined, "> "); idx != -1 {
+			f.hasSeenFirstThinking = true
+			f.buffer = ""
+			deltaContent = combined[idx+2:]
 		} else {
+			// 没找到开始标记，缓存当前内容继续等待
+			f.buffer = combined
 			return ""
 		}
 	}
@@ -556,7 +561,7 @@ func HandleChatCompletions(w http.ResponseWriter, r *http.Request) {
 			}
 		}
 
-		resp, modelName, err := makeUpstreamRequest(token, messages, req.Model, reqImageURLs, reqVideoURLs)
+		resp, modelName, err := makeUpstreamRequest(token, messages, req.Model, reqImageURLs, reqVideoURLs, len(req.Tools) > 0)
 		if err != nil {
 			LogError("Upstream request failed (attempt %d): %v", attempt+1, err)
 			lastError = err.Error()
@@ -1094,6 +1099,8 @@ func handleNonStreamResponse(w http.ResponseWriter, body io.ReadCloser, completi
 
 	for scanner.Scan() {
 		line := scanner.Text()
+		LogDebug("[Upstream] %s", line)
+
 		if !strings.HasPrefix(line, "data: ") {
 			continue
 		}
@@ -1723,6 +1730,8 @@ func handleNonStreamResponseWithRetry(w http.ResponseWriter, body io.ReadCloser,
 
 	for scanner.Scan() {
 		line := scanner.Text()
+		LogDebug("[Upstream] %s", line)
+
 		if !strings.HasPrefix(line, "data: ") {
 			continue
 		}

internal/models.go

@@ -594,9 +594,13 @@ func FormatImageSearchResults(results []ImageSearchResult) string {
 func ExtractTextBeforeGlmBlock(editContent string) string {
 	if idx := strings.Index(editContent, "<glm_block"); idx != -1 {
 		text := editContent[:idx]
-		if strings.HasSuffix(text, "\n") {
-			text = text[:len(text)-1]
+		// 如果包含 </details>，只取 </details> 之后的内容
+		if detailsIdx := strings.Index(text, "</details>"); detailsIdx != -1 {
+			text = text[detailsIdx+len("</details>"):]
 		}
+		// 去掉开头和结尾的换行
+		text = strings.TrimPrefix(text, "\n")
+		text = strings.TrimSuffix(text, "\n")
 		return text
 	}
 	return ""

internal/tools.go

@@ -129,16 +129,20 @@ func getToolChoiceInstructions(toolChoice interface{}, toolNames []string) strin
 
 func ProcessMessagesWithTools(messages []Message, tools []Tool, toolChoice interface{}) []Message {
 	if !Cfg.ToolSupport || len(tools) == 0 {
+		LogDebug("[Tools] Tool support disabled or no tools provided")
 		return messages
 	}
 	if tc, ok := toolChoice.(string); ok && tc == "none" {
+		LogDebug("[Tools] Tool choice is 'none', skipping tool processing")
 		return messages
 	}
 
 	toolPrompt := GenerateToolPrompt(tools, toolChoice)
 	if toolPrompt == "" {
+		LogDebug("[Tools] Generated empty tool prompt")
 		return messages
 	}
+	LogDebug("[Tools] Injecting tool prompt for %d tools", len(tools))
 
 	processed := make([]Message, len(messages))
 	copy(processed, messages)