Update app.py

app.py

@@ -70,52 +70,51 @@ conversation_start_times: Dict[str, str] = {}
 # 🤖 FONCTION D'ENVOI TÉLÉGRAM
 # ======================================================================
 
-def send_llm_interaction_to_telegram(question: str, reponse_llm: str, session_id: str, token: str, chat_id: str):
+def send_telegram_message(message: str, token: str, chat_id: str):
     """
-    Envoie une notification d'interaction Question/Réponse à Telegram.
-    C'est la fonction principale pour l'archivage.
+    Fonction générique pour envoyer un message à Telegram.
     """
     if not TELEGRAM_NOTIFICATIONS_ENABLED:
         return
 
-    # Construction du message formaté
-    MESSAGE = f"""
-*🔔 Nouvelle Interaction LLM 🔔*
-*Session ID:* `{session_id}`
-*Heure:* {time.strftime('%Y-%m-%d %H:%M:%S')}
-
-*Question (Utilisateur):*
-{question}
-
-*Réponse (LLM - Début):*
-{reponse_llm[:200]}... (Voir le log pour la réponse complète)
-"""
-
-    # Construction de l'URL pour la méthode 'sendMessage'
     url = f"https://api.telegram.org/bot{token}/sendMessage"
-
-    # Paramètres de la requête
     params = {
         "chat_id": chat_id,
-        "text": MESSAGE,
+        "text": message,
         "parse_mode": "Markdown"
     }
 
     try:
-        # Envoi de la requête POST (avec un timeout pour ne pas ralentir l'API principale)
         response = requests.post(url, params=params, timeout=5)
         response.raise_for_status()
 
         if response.json().get("ok"):
-            # Affiche dans le log du serveur (pas dans le terminal)
-            print(f"✅ Notification Telegram envoyée pour la session {session_id}.")
+            print(f"✅ Message Telegram envoyé.")
         else:
             print(f"❌ Échec envoi Telegram: {response.json().get('description')}")
 
     except requests.exceptions.RequestException as e:
-        print(f"❌ Erreur connexion Telegram (Vérifiez le TOKEN/Réseau): {e}")
+        print(f"❌ Erreur connexion Telegram (Vérifiez le TOKEN/Réseau) : {e}")
     except Exception as e:
-        print(f"❌ Erreur inattendue Telegram: {e}")
+        print(f"❌ Erreur inattendue Telegram : {e}")
+
+def send_llm_interaction_to_telegram(question: str, reponse_llm: str, session_id: str, token: str, chat_id: str):
+    """
+    Construit le message d'interaction Q/R et l'envoie via Telegram.
+    """
+    # Construction du message formaté
+    MESSAGE = f"""
+*🔔 Nouvelle Interaction LLM 🔔*
+*Session ID:* `{session_id}`
+*Heure:* {time.strftime('%Y-%m-%d %H:%M:%S')}
+
+*Question (Utilisateur):*
+{question}
+
+*Réponse (LLM - Début):*
+{reponse_llm[:200]}... (Voir le log pour la réponse complète)
+"""
+    send_telegram_message(MESSAGE, token, chat_id)
 
 
 # ======================================================================
@@ -408,7 +407,6 @@ def api_get_answer():
     try:
         data = request.get_json()
         query_text = data.get('query_text')
-        # Utiliser un ID par défaut si non fourni
         session_id = data.get('session_id', 'archive')
 
         if not query_text:
@@ -466,6 +464,11 @@ def api_clear_history():
 if __name__ == '__main__':
     print("start app.py")
     if initialize_global_resources():
+        
+        # ➡️ ENVOI DE LA NOTIFICATION TÉLÉGRAM AU DÉMARRAGE
+        startup_message = f"🚀 **Application RAG Démarrée**\nHeure: {time.strftime('%Y-%m-%d %H:%M:%S')}\nToutes les ressources sont chargées."
+        send_telegram_message(startup_message, TELEGRAM_TOKEN, TELEGRAM_CHAT_ID)
+        # ------------------------------------------------------
 
         try:
             import socket