Upload 17 files

app.py

@@ -1492,6 +1492,9 @@ async def run_job(job_id: str, params: dict):
         from datetime import datetime, timezone
         now = datetime.now(timezone.utc)
         system += f"\n\nDate et heure actuelles (UTC) : {now.strftime('%Y-%m-%d %H:%M:%S')} ({now.strftime('%A %d %B %Y')})"
+        # Instruction de sentinelle <end> : le modèle DOIT terminer sa réponse par <end>
+        # pour indiquer qu'il a fini. Si absent, on retry.
+        system += "\n\nIMPORTANT : Tu DOIS terminer chaque réponse finale par la balise <end> (sans autre texte après). Cette balise indique que ta réponse est complète."
         # FILTRER les messages tool et assistant.avec_tool_calls de l'historique :
         # - Les messages tool n'ont pas de tool_call_id valide (le client ne peut pas le reconstruire)
         # - Les assistant.avec_tool_calls doivent être suivis de tool messages, sinon l'API rejette
@@ -1616,6 +1619,56 @@ async def run_job(job_id: str, params: dict):
         if job["tool_calls"] and provider in ("openai", "groq", "custom"):
             await _execute_tool_calls(job, params)
 
+        # 5) Vérifier que la réponse n'est pas vide et contient <end>.
+        #    Si elle est vide OU ne contient pas <end>, on retry jusqu'à 3 fois
+        #    en demandant au modèle de compléter sa réponse.
+        max_retries = 3
+        for retry in range(max_retries):
+            # Si le job a été annulé, ne pas retry
+            if job["cancel_event"].is_set():
+                break
+            current_buffer = job["buffer"]
+            # Vérifier si on a une réponse non vide ET contenant <end>
+            has_end = "<end>" in current_buffer
+            has_content = any(seg.get("type") == "text" and seg.get("content", "").strip()
+                              for seg in job.get("segments", []))
+            if has_end and has_content:
+                break  # Réponse complète, on sort
+            if retry == max_retries - 1:
+                break  # Dernier retry, on accepte ce qu'on a
+            # Retry : demander au modèle de compléter
+            print(f"[INFO] Réponse incomplète (empty={not has_content}, end={has_end}), retry {retry+1}/{max_retries}")
+            job["status_text"] = "Finalisation de la réponse..."
+            retry_messages = list(params.get("messages", []))
+            # Ajouter le dernier message assistant (même incomplet)
+            retry_messages.append({"role": "assistant", "content": current_buffer or "(vide)"})
+            retry_messages.append({"role": "user", "content": "Ta réponse précédente semble incomplète ou vide. Donne-moi maintenant une réponse complète et détaillée. N'oublie pas de terminer par la balise <end>."})
+            buffer_before_retry = len(job["buffer"])
+            job["tool_calls"] = []  # reset pour éviter de re-exécuter les tools
+            try:
+                if provider == "openai":
+                    await run_openai_like(job, "https://api.openai.com/v1/chat/completions", api_key, model, system, retry_messages, tools=None, reasoning_effort=reasoning_effort)
+                elif provider == "groq":
+                    await run_openai_like(job, "https://api.groq.com/openai/v1/chat/completions", api_key, model, system, retry_messages, tools=None, reasoning_effort=reasoning_effort)
+                elif provider == "custom":
+                    await run_openai_like(job, base_url.rstrip("/") + "/chat/completions", api_key, model, system, retry_messages, tools=None, reasoning_effort=reasoning_effort)
+                # Ajouter le nouveau texte comme segment
+                retry_text = job["buffer"][buffer_before_retry:]
+                if retry_text:
+                    job["segments"].append({"type": "text", "content": retry_text})
+            except Exception as retry_err:
+                print(f"[WARN] Retry {retry+1} échoué: {retry_err}")
+                break
+            job["status_text"] = None
+
+        # 6) Strip la balise <end> du buffer et des segments
+        if "<end>" in job["buffer"]:
+            job["buffer"] = job["buffer"].replace("<end>", "").rstrip()
+        if job.get("segments"):
+            for seg in job["segments"]:
+                if seg.get("type") == "text" and "<end>" in (seg.get("content") or ""):
+                    seg["content"] = seg["content"].replace("<end>", "").rstrip()
+
         job["status"] = "cancelled" if job["cancel_event"].is_set() else "done"
 
         # 5) Log usage

static/index.html

@@ -9,7 +9,7 @@
   <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">
   <script src="https://cdn.jsdelivr.net/npm/marked/marked.min.js"></script>
   <script src="https://cdnjs.cloudflare.com/ajax/libs/localforage/1.10.0/localforage.min.js"></script>
-  <link rel="stylesheet" href="/static/css/main.css?v=18">
+  <link rel="stylesheet" href="/static/css/main.css?v=20">
 </head>
 <body>
 
@@ -335,7 +335,7 @@
     </div>
   </div>
 
-  <script src="/static/js/i18n.js?v=18"></script>
-  <script src="/static/js/app.js?v=18"></script>
+  <script src="/static/js/i18n.js?v=20"></script>
+  <script src="/static/js/app.js?v=20"></script>
 </body>
 </html>

static/js/app.js

@@ -805,6 +805,48 @@ const App = {
     }
   },
 
+  // Reconstruit les messages envoyés à l'API en incluant l'historique des tool calls et leurs résultats.
+  // Pour chaque message assistant qui a utilisé des tools, on inclut:
+  // - Le texte généré
+  // - Un résumé des tools appelés + leurs résultats (en format texte dans le contenu)
+  // Le modèle reçoit donc le contexte complet de ses recherches précédentes.
+  buildApiMessages(chat) {
+    const msgs = [];
+    const recent = chat.messages.slice(-20);  // Garder les 20 derniers messages
+    for (const m of recent) {
+      if (m.role === 'user') {
+        msgs.push({ role: 'user', content: m.content || '' });
+      } else if (m.role === 'assistant') {
+        let content = m.content || '';
+        // Si le message a des segments, reconstruire le contenu avec les tool calls
+        if (m.segments && m.segments.length > 0) {
+          content = '';
+          for (const seg of m.segments) {
+            if (seg.type === 'text') {
+              content += seg.content || '';
+            } else if (seg.type === 'tool_call') {
+              let argsStr = '';
+              try { argsStr = JSON.stringify(seg.args); } catch (e) { argsStr = String(seg.args || ''); }
+              content += `\n\n[Outil utilisé: ${seg.name}]\nArguments: ${argsStr}\nRésultat: ${(seg.result || '').substring(0, 2000)}\n`;
+            }
+          }
+        }
+        // Aussi inclure les toolCalls (ancien format) si segments absent
+        if (!m.segments && m.toolCalls && m.toolCalls.length > 0) {
+          for (const tc of m.toolCalls) {
+            let argsStr = '';
+            try { argsStr = JSON.stringify(tc.args); } catch (e) { argsStr = String(tc.args || ''); }
+            content += `\n\n[Outil utilisé: ${tc.tool || tc.name}]\nArguments: ${argsStr}\nRésultat: ${(tc.result_preview || '').substring(0, 2000)}\n`;
+          }
+        }
+        if (content.trim()) {
+          msgs.push({ role: 'assistant', content: content.trim() });
+        }
+      }
+    }
+    return msgs;
+  },
+
   async sendMessage() {
     const input = document.getElementById('messageInput');
     const text = input.value.trim();
@@ -856,7 +898,7 @@ const App = {
     const apiKey = '';
     const system = `Tu es un assistant IA utile, précis et honnête. Réponds dans la langue de l'utilisateur. Formatte tes réponses en Markdown quand pertinent.`;
 
-    const messages = chat.messages.filter(m => m.role !== 'assistant' || m.content).slice(-20).map(m => ({ role: m.role, content: m.content }));
+    const messages = this.buildApiMessages(chat);
 
     // Séparer images et fichiers texte pour l'envoi au serveur
     const allAttachments = attachments.length > 0 ? attachments : (userMsg.attachments || []);
@@ -1074,7 +1116,7 @@ const App = {
       const model = chat.model;
       const customProvider = chat.customProviderName || '';
       const baseUrl = chat.baseUrl || '';
-      const messages = chat.messages.filter(m => m.role !== 'assistant' || m.content).slice(-20).map(m => ({ role: m.role, content: m.content }));
+      const messages = this.buildApiMessages(chat);
       // Récupérer les attachments du dernier message user (pour retry avec images/fichiers)
       const userAttachments = lastUser.attachments || [];
       const images = userAttachments.filter(a => a.base64).map(a => ({ base64: a.base64, mime: a.mime }));