fix history chat

Author: thanhtulearncode

app/routers/admin.py

@@ -180,7 +180,7 @@ async def upload_json_faq(
         faq_items = await IngestionService.parse_json_faq(file)
         count = 0
         for item in faq_items:
-            # Check for duplicates
+            # Vérification des doublons
             existing = db.exec(select(FAQItem).where(FAQItem.question == item["question"])).first()
             if not existing:
                 new_faq = FAQItem(
@@ -210,7 +210,7 @@ async def upload_pdf_doc(
         chunks = await IngestionService.parse_pdf_document(file)
         count = 0
         for item in chunks:
-             # Check for duplicates
+            # Vérification des doublons
             existing = db.exec(select(FAQItem).where(FAQItem.question == item["question"])).first()
             if not existing:
                 new_faq = FAQItem(
@@ -235,8 +235,7 @@ async def list_documents(
     db: Session = Depends(get_session),
     current_user = Depends(get_current_admin_user)
 ):
-    """Display list of source documents"""
-    # SQLite doesn't support DISTINCT ON, so we group by source
+    """Affiche la liste des documents sources"""
     results = db.exec(
         select(FAQItem.source, func.count(FAQItem.id))
         .where(FAQItem.source != None)
@@ -258,10 +257,10 @@ async def delete_document(
     db: Session = Depends(get_session),
     current_user = Depends(get_current_admin_user)
 ):
-    """Delete all items linked to a document"""
+    """Supprime toutes les questions liées à un document"""
     items = db.exec(select(FAQItem).where(FAQItem.source == filename)).all()
 
-    # Delete from ChromaDB and database
+    # Suppression de ChromaDB et de la base de données
     service = RAGService()
     for item in items:
         await service.remove_faq_item(item.id)

app/routers/chat.py

@@ -67,6 +67,30 @@ async def feedback_endpoint(
     db.commit()
     return {"message": "Feedback enregistré"}
 
+@router.get("/chat/history/{user_id}")
+async def get_history_endpoint(
+    user_id: str,
+    db: Session = Depends(get_session)
+):
+    """Récupère l'historique complet des interactions pour un utilisateur"""
+    interactions = db.exec(
+        select(ChatInteraction)
+        .where(ChatInteraction.user_session_id == user_id)
+        .order_by(ChatInteraction.timestamp)
+    ).all()
+    
+    history_data = [
+        {
+            "user_message": i.message,
+            "bot_response": i.response,
+            "timestamp": i.timestamp.isoformat(),
+            "provider": i.provider
+        }
+        for i in interactions
+    ]
+    
+    return {"history": history_data}
+
 @router.post("/chat")
 async def chat_endpoint(request: ChatRequest, db: Session = Depends(get_session)):
     """Endpoint principal pour le chat avec streaming"""

app/services/ingestion.py

@@ -33,10 +33,8 @@ async def parse_pdf_document(file: UploadFile) -> List[Dict[str, str]]:
             for i, page in enumerate(reader.pages):
                 # Extraction with "layout" mode which preserves spaces better
                 text = page.extract_text(extraction_mode="layout")
-                
                 if not text or not text.strip():
                     continue
-                
                 # Cleanup
                 text = text.replace("\n", " ")
                 text = re.sub(r"([a-z])([A-Z])", r"\1 \2", text)

app/services/llm_factory.py

@@ -105,14 +105,12 @@ async def generate_response(self, prompt: str) -> dict:
 
     async def generate_stream(self, prompt: str):
         """Attempts to stream with the first available provider."""
-        # Note: For streaming, we simplify by trying the first provider without complex fallback
-        # or we could implement similar logic
         for provider in self.providers:
             try:
                 logger.info(f"Start streaming with {provider.name}")
                 async for chunk in provider.generate_stream(prompt):
                     yield {"chunk": chunk, "provider": provider.name}
-                return # Success
+                return
             except Exception as e:
                 logger.error(f"Stream error {provider.name}: {e}")
                 continue

static/js/chatbot.js

@@ -445,7 +445,7 @@ async function handleSendMessage() {
     hideTypingIndicator();
     console.error(error);
     showToast("Erreur de connexion", "error");
-    addMessage("❌ Erreur de connexion", false, { isError: true }, Date.now().toString());
+    addMessage("Erreur de connexion", false, { isError: true }, Date.now().toString());
   } finally {
     input.disabled = false;
     sendBtn.disabled = false;