和上次一样。

dbgpt/app/openapi/api_v1/api_v1.py

@@ -533,7 +533,10 @@ async def stream_generator(chat, incremental: bool, model_name: str):
         if chunk:
             msg = chunk.replace("\ufffd", "")
             if incremental:
-                incremental_output = msg[len(previous_response):]
+                incremental_output = msg[len(previous_response):].replace("\n", "\\n")
+                # 处理连续换行符
+                incremental_output = incremental_output.replace("\n\n", "\\n\\n")
+
                 choice_data = ChatCompletionResponseStreamChoice(
                     index=0,
                     delta=DeltaMessage(role="assistant", content=incremental_output),
@@ -541,9 +544,7 @@ async def stream_generator(chat, incremental: bool, model_name: str):
                 chunk = ChatCompletionStreamResponse(
                     id=chat.chat_session_id, choices=[choice_data], model=model_name
                 )
-                json_chunk = model_to_json(
-                    chunk, exclude_unset=True, ensure_ascii=False
-                )
+                json_chunk = model_to_json(chunk, exclude_unset=True, ensure_ascii=False)
                 yield f"data: {json_chunk}\n\n"
             else:
                 # TODO generate an openai-compatible streaming responses