jo

app.py

@@ -8,21 +8,37 @@ from werkzeug.utils import secure_filename
 import mimetypes
 from dotenv import load_dotenv
 from datetime import datetime
+import logging
+
+# Configure logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.StreamHandler(),
+        logging.FileHandler('app.log', mode='a', encoding='utf-8')
+    ]
+)
+logger = logging.getLogger(__name__)
 
 app = Flask(__name__)
 app.config['MAX_CONTENT_LENGTH'] = 16 * 1024 * 1024  # 16MB max file size
 load_dotenv()
 
+@app.before_request
+def log_request_info():
+    logger.info(f'Request: {request.method} {request.url} from {request.remote_addr}')
+
 def load_system_instruction():
     """Charge les instructions système depuis le fichier Markdown"""
     try:
         with open('instructions/system_instruction.md', 'r', encoding='utf-8') as f:
             return f.read().strip()
     except FileNotFoundError:
-        print("Erreur: Fichier d'instructions système non trouvé.")
+        logger.error("Fichier d'instructions système non trouvé.")
         return "Tu es un assistant intelligent et amical nommé Mariam. Tu assistes les utilisateurs au mieux de tes capacités. Tu as été créé par Aenir."
     except Exception as e:
-        print(f"Erreur lors du chargement des instructions système: {e}")
+        logger.exception("Erreur lors du chargement des instructions système")
         return "Tu es un assistant intelligent et amical nommé Mariam. Tu assistes les utilisateurs au mieux de tes capacités. Tu as été créé par Aenir."
 
 # Configuration du client Gemini
@@ -30,15 +46,15 @@ API_KEY = os.getenv("GOOGLE_API_KEY")
 SYSTEM_INSTRUCTION = load_system_instruction()
 
 if not API_KEY:
-    print("ATTENTION: GOOGLE_API_KEY non définie dans les variables d'environnement")
-    print("L'application démarrera mais les fonctionnalités de chat seront limitées")
+    logger.warning("GOOGLE_API_KEY non définie dans les variables d'environnement")
+    logger.warning("L'application démarrera mais les fonctionnalités de chat seront limitées")
     client = None
 else:
     try:
         client = genai.Client(api_key=API_KEY)
-        print("Client Gemini initialisé avec succès")
+        logger.info("Client Gemini initialisé avec succès")
     except Exception as e:
-        print(f"ERREUR lors de l'initialisation du client Gemini: {e}")
+        logger.exception("Erreur lors de l'initialisation du client Gemini")
         client = None
 
 # Configuration par défaut
@@ -139,7 +155,7 @@ def chat():
         thinking_enabled = data.get('thinking_enabled', True)
         conversation_id = data.get('conversation_id', 'default')
 
-        print(f"Requête chat reçue: message='{message[:50]}...', conversation_id={conversation_id}")
+        logger.info(f"Requête chat reçue: message='{message[:50]}...', conversation_id={conversation_id}")
 
         # Ajouter le message de l'utilisateur à l'historique
         add_message_to_history(conversation_id, 'user', message)
@@ -173,7 +189,7 @@ def chat():
                     yield f"data: {json.dumps({'type': 'error', 'content': 'API Gemini non configurée. Définissez GOOGLE_API_KEY.'})}\n\n"
                     return
 
-                print(f"Démarrage du streaming pour conversation {conversation_id}")
+                logger.info(f"Démarrage du streaming pour conversation {conversation_id}")
                 response_stream = chat.send_message_stream(
                     message,
                     config=generation_config
@@ -185,7 +201,7 @@ def chat():
 
                 for chunk in response_stream:
                     chunk_count += 1
-                    print(f"Chunk {chunk_count} reçu")
+                    logger.debug(f"Chunk {chunk_count} reçu")
                     for part in chunk.candidates[0].content.parts:
                         if part.text:
                             if part.thought and thinking_enabled:
@@ -194,7 +210,7 @@ def chat():
                             full_response += part.text
                             yield f"data: {json.dumps({'type': 'text', 'content': part.text})}\n\n"
 
-                print(f"Streaming terminé, réponse complète: {len(full_response)} caractères")
+                logger.info(f"Streaming terminé, réponse complète: {len(full_response)} caractères")
 
                 # Ajouter la réponse de l'assistant à l'historique
                 if full_response:
@@ -204,7 +220,7 @@ def chat():
                 yield f"data: {json.dumps({'type': 'end'})}\n\n"
 
             except Exception as e:
-                print(f"ERREUR lors du streaming: {e}")
+                logger.exception("Erreur lors du streaming")
                 yield f"data: {json.dumps({'type': 'error', 'content': f'Erreur API: {str(e)}'})}\n\n"
 
         return Response(generate(), mimetype='text/event-stream', headers={
@@ -230,6 +246,7 @@ def upload_file():
         # Lire le fichier
         file_bytes = file.read()
         mime_type = file.content_type or mimetypes.guess_type(file.filename)[0]
+        logger.info(f"Fichier uploadé: {file.filename}, taille: {len(file_bytes)} bytes, type: {mime_type}")
 
         # Encoder en base64 pour le stockage temporaire
         file_b64 = base64.b64encode(file_bytes).decode()
@@ -255,7 +272,7 @@ def chat_with_file():
         thinking_enabled = data.get('thinking_enabled', True)
         conversation_id = data.get('conversation_id', 'default')
 
-        print(f"Requête chat_with_file reçue: message='{message[:50]}...', fichiers={len(file_data_list)}, conversation_id={conversation_id}")
+        logger.info(f"Requête chat_with_file reçue: message='{message[:50]}...', fichiers={len(file_data_list)}, conversation_id={conversation_id}")
 
         # Ensure file_data_list is a list
         if not isinstance(file_data_list, list):
@@ -308,7 +325,7 @@ def chat_with_file():
                     yield f"data: {json.dumps({'type': 'error', 'content': 'API Gemini non configurée. Définissez GOOGLE_API_KEY.'})}\n\n"
                     return
 
-                print(f"Démarrage du streaming avec fichiers pour conversation {conversation_id}")
+                logger.info(f"Démarrage du streaming avec fichiers pour conversation {conversation_id}")
                 response_stream = chat.send_message_stream(
                     contents,
                     config=generation_config
@@ -320,7 +337,7 @@ def chat_with_file():
 
                 for chunk in response_stream:
                     chunk_count += 1
-                    print(f"Chunk {chunk_count} reçu (avec fichiers)")
+                    logger.debug(f"Chunk {chunk_count} reçu (avec fichiers)")
                     for part in chunk.candidates[0].content.parts:
                         if part.text:
                             if part.thought and thinking_enabled:
@@ -329,7 +346,7 @@ def chat_with_file():
                             full_response += part.text
                             yield f"data: {json.dumps({'type': 'text', 'content': part.text})}\n\n"
 
-                print(f"Streaming avec fichiers terminé, réponse complète: {len(full_response)} caractères")
+                logger.info(f"Streaming avec fichiers terminé, réponse complète: {len(full_response)} caractères")
 
                 # Ajouter la réponse de l'assistant à l'historique
                 if full_response:
@@ -339,7 +356,7 @@ def chat_with_file():
                 yield f"data: {json.dumps({'type': 'end'})}\n\n"
 
             except Exception as e:
-                print(f"ERREUR lors du streaming avec fichiers: {e}")
+                logger.exception("Erreur lors du streaming avec fichiers")
                 yield f"data: {json.dumps({'type': 'error', 'content': f'Erreur API avec fichiers: {str(e)}'})}\n\n"
 
         return Response(generate(), mimetype='text/event-stream', headers={
@@ -360,12 +377,13 @@ def reset_conversation():
         
         if conversation_id in conversations:
             del conversations[conversation_id]
-        
+
         # Marquer la conversation comme terminée dans les métadonnées
         if conversation_id in conversation_metadata:
             conversation_metadata[conversation_id]['status'] = 'reset'
             conversation_metadata[conversation_id]['last_activity'] = datetime.now().isoformat()
-        
+
+        logger.info(f"Conversation {conversation_id} réinitialisée")
         return jsonify({'success': True})
         
     except Exception as e:
@@ -377,10 +395,11 @@ def delete_conversation(conversation_id):
     try:
         if conversation_id in conversations:
             del conversations[conversation_id]
-        
+
         if conversation_id in conversation_metadata:
             del conversation_metadata[conversation_id]
-        
+
+        logger.info(f"Conversation {conversation_id} supprimée")
         return jsonify({'success': True})
     except Exception as e:
         return jsonify({'error': str(e)}), 500
@@ -393,7 +412,8 @@ def export_conversation(conversation_id):
             return jsonify({'error': 'Conversation non trouvée'}), 404
         
         conversation_data = conversation_metadata[conversation_id]
-        
+
+        logger.info(f"Conversation {conversation_id} exportée")
         return jsonify({
             'conversation_id': conversation_id,
             'export_date': datetime.now().isoformat(),
@@ -480,4 +500,4 @@ def debug_api_test():
         })
 
 if __name__ == '__main__':
-    app.run(debug=True, host='0.0.0.0', port=5000)
+    app.run(debug=True, host='0.0.0.0', port=7860)