Update internal/monica/sse.go

internal/monica/sse.go

@@ -26,8 +26,14 @@ const (
 
 // SSEData 用于解析 Monica SSE json
 type SSEData struct {
-	Text     string `json:"text"`
-	Finished bool   `json:"finished"`
+	Text        string `json:"text"`
+	Finished    bool   `json:"finished"`
+	AgentStatus struct {
+		Type     string `json:"type"`
+		Metadata struct {
+			ReasoningDetail string `json:"reasoning_detail"`
+		} `json:"metadata"`
+	} `json:"agent_status"`
 }
 
 var sseDataPool = sync.Pool{
@@ -116,22 +122,44 @@ func StreamMonicaSSEToClient(model string, w io.Writer, r io.Reader) error {
 				},
 			}
 		} else {
-			sseMsg = types.ChatCompletionStreamResponse{
-				ID:                "chatcmpl-" + chatId,
-				Object:            sseObject,
-				SystemFingerprint: fingerprint,
-				Created:           now,
-				Model:             model,
-				Choices: []types.ChatCompletionStreamChoice{
-					{
-						Index: 0,
-						Delta: openai.ChatCompletionStreamChoiceDelta{
-							Role:    openai.ChatMessageRoleAssistant,
-							Content: sseObj.Text,
+			// 检查是否是思考内容
+			if sseObj.AgentStatus.Type == "thinking_detail_stream" {
+				sseMsg = types.ChatCompletionStreamResponse{
+					ID:               "chatcmpl-" + chatId,
+					Object:           sseObject,
+					SystemFingerprint: fingerprint,
+					Created:          now,
+					Model:            model,
+					ReasoningContent: sseObj.AgentStatus.Metadata.ReasoningDetail,
+					Choices: []types.ChatCompletionStreamChoice{
+						{
+							Index: 0,
+							Delta: openai.ChatCompletionStreamChoiceDelta{
+								Role:    openai.ChatMessageRoleAssistant,
+								Content: "",
+							},
+							FinishReason: openai.FinishReasonNull,
 						},
-						FinishReason: openai.FinishReasonNull,
 					},
-				},
+				}
+			} else {
+				sseMsg = types.ChatCompletionStreamResponse{
+					ID:               "chatcmpl-" + chatId,
+					Object:           sseObject,
+					SystemFingerprint: fingerprint,
+					Created:          now,
+					Model:            model,
+					Choices: []types.ChatCompletionStreamChoice{
+						{
+							Index: 0,
+							Delta: openai.ChatCompletionStreamChoiceDelta{
+								Role:    openai.ChatMessageRoleAssistant,
+								Content: sseObj.Text,
+							},
+							FinishReason: openai.FinishReasonNull,
+						},
+					},
+				}
 			}
 		}