Update internal/monica/sse.go

internal/monica/sse.go

@@ -26,14 +26,8 @@ const (
 
 // SSEData 用于解析 Monica SSE json
 type SSEData struct {
-	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"`
+	Text     string `json:"text"`
+	Finished bool   `json:"finished"`
 }
 
 var sseDataPool = sync.Pool{
@@ -122,44 +116,22 @@ func StreamMonicaSSEToClient(model string, w io.Writer, r io.Reader) error {
 				},
 			}
 		} else {
-			// 检查是否是思考内容
-			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,
-						},
-					},
-				}
-			} 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,
+			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,
 					},
-				}
+				},
 			}
 		}
 
@@ -189,4 +161,4 @@ func StreamMonicaSSEToClient(model string, w io.Writer, r io.Reader) error {
 		// 将对象放回对象池
 		sseDataPool.Put(sseObj)
 	}
-}
+}