Update app.py

app.py

@@ -125,34 +125,41 @@ async def create_chat_completion(request: ChatCompletionRequest):
         if last_message.role != "user":
             raise HTTPException(status_code=400, detail="Last message must be from user")
 
-        # Формируем историю диалога в текстовом формате
+        # Объединяем system prompt с сообщением пользователя
         system_prompt = ""
-        text_history = ""
-        
-        # Проходим по всем сообщениям для формирования истории
-        for i, msg in enumerate(request.messages[:-1]):  # исключаем последнее сообщение
+        for msg in request.messages:
             if msg.role == "system":
                 system_prompt = msg.content
-            else:
-                if text_history:
-                    text_history += "\\n"  # Двойной обратный слеш для экранирования
-                text_history += msg.content
-        
-        # Объединяем system prompt с сообщением пользователя
+                break
+
         user_message = last_message.content
         if system_prompt:
             combined_message = f"{system_prompt}\n\n{user_message}"
         else:
             combined_message = user_message
         
+        # Формируем историю диалога для Flowise
+        history = []
+        for i, msg in enumerate(request.messages[:-1]):  # исключаем последнее сообщение
+            if msg.role == "user":
+                history.append({
+                    "role": "userMessage",
+                    "content": msg.content
+                })
+            elif msg.role == "assistant":
+                history.append({
+                    "role": "apiMessage",
+                    "content": msg.content
+                })
+        
         # Формируем запрос к Flowise
         flowise_request = {
             "question": combined_message
         }
         
         # Добавляем историю, если она есть
-        if text_history:
-            flowise_request["history"] = text_history
+        if history:
+            flowise_request["history"] = history
             
         # Засекаем время начала запроса
         start_time = time.time()