Update web_routes.py

web_routes.py

@@ -1,5 +1,5 @@
 # web_routes.py (Version API Pure - Logique Métier Conservée)
-
+from decorators import api_session_required 
 import shutil
 # Suppression de render_template, redirect, url_for, flash
 from flask import Blueprint, request, jsonify, send_from_directory, current_app, session 
@@ -198,21 +198,29 @@ def delete_project_api(deploy_id):
 # NOUVELLES ROUTES POUR LA GESTION DES DÉPÔTS (GitForge)
 # ----------------------------------------------------------------------
 
+
 @web_bp.route('/api/create_repository', methods=['POST'])
-@login_required
-def create_repository():
-    """Point API pour créer un nouveau dépôt utilisateur."""
+@api_session_required # ⬅️ CHANGEMENT CLÉ : Utiliser le décorateur API basé sur la session
+def create_repository(client_user): # ⬅️ CHANGEMENT CLÉ : Accepter l'objet utilisateur injecté
+    """
+    Point API pour créer un nouveau dépôt utilisateur.
+    L'utilisateur est authentifié et fourni par le décorateur @api_session_required via la session.
+    """
+    
+    # 1. Récupération de l'ID utilisateur à partir de l'objet injecté
+    # L'authentification (vérification de la session) est gérée par le décorateur.
+    user_id = client_user['uuid'] 
     
-    user_id = session.get('user_id')
     data = request.get_json()
     
-    if not user_id:
-        return jsonify({"success": False, "message": "Session utilisateur requise."}), 401
+    # L'ancienne vérification 'if not user_id' est désormais gérée par le décorateur.
+    
     if not data or 'repo-name' not in data or 'visibility' not in data:
         return jsonify({"success": False, "message": "Nom et visibilité du dépôt requis."}), 400
 
     repo_name = data.get('repo-name').strip()
     # Créer un slug simple pour le chemin HF et l'URL
+    # secure_filename doit être importé de werkzeug.utils
     repo_slug = secure_filename(repo_name).lower().replace('-', '_') 
     
     if not repo_slug:
@@ -224,12 +232,12 @@ def create_repository():
         return jsonify({"success": False, "message": "Visibilité invalide."}), 400
 
     # 1. Vérification des limites de plan (À implémenter plus tard si besoin)
-    # limit = get_plan_limit(user_plan) # Utiliser cette ligne quand la vérification du plan sera là
+    # limit = get_plan_limit(client_user.get('user_plan')) 
 
     # 2. Vérification de l'existence du slug (pour s'assurer que l'utilisateur ne crée pas de doublon)
     existing_repos = get_all_user_repositories(user_id)
     if any(repo['repo_slug'] == repo_slug for repo in existing_repos):
-         return jsonify({"success": False, "message": f"Un dépôt avec le nom '{repo_name}' existe déjà."}), 409
+          return jsonify({"success": False, "message": f"Un dépôt avec le nom '{repo_name}' existe déjà."}), 409
     
     # 3. Préparation des données du nouveau dépôt
     repo_id = str(uuid.uuid4()) # ID unique pour le dépôt
@@ -237,7 +245,7 @@ def create_repository():
         "repo_id": repo_id,
         "repo_name": repo_name,
         "repo_slug": repo_slug,
-        "user_id": user_id,
+        "user_id": user_id, # ⬅️ ID utilisateur récupéré et correctement utilisé
         "visibility": visibility,
         "license": data.get('license', 'None'),
         "description": data.get('description', ''),
@@ -249,16 +257,14 @@ def create_repository():
         success_db, message_db = save_new_repository(user_id, new_repo_data)
         
         if not success_db:
-             return jsonify({"success": False, "message": f"Échec de l'enregistrement du dépôt: {message_db}"}), 500
+              return jsonify({"success": False, "message": f"Échec de l'enregistrement du dépôt: {message_db}"}), 500
         
         # 5. Création du dossier initial sur Hugging Face (Stockage de fichiers)
         success_hf, message_hf = create_empty_repo_folder_on_hf(repo_slug, str(user_id))
         
         if not success_hf:
-            # NOTE: On peut choisir de laisser la BDD à jour et logguer l'erreur HF 
-            # ou essayer de rollback. Pour l'instant, on log l'erreur et on permet de réessayer plus tard.
+            # On log l'erreur et on retourne quand même un succès BDD, mais un avertissement
             current_app.logger.error(f"Échec de l'initialisation HF pour {repo_slug}: {message_hf}")
-            # On retourne quand même un succès BDD, mais un avertissement
             return jsonify({
                 "success": True, 
                 "message": f"Dépôt créé dans la BDD. Avertissement: Échec de l'initialisation du dossier sur Hugging Face ({message_hf}).",
@@ -273,10 +279,10 @@ def create_repository():
         }), 201
 
     except Exception as e:
+        # current_app doit être importé de flask
         current_app.logger.error(f"Erreur inattendue lors de la création du dépôt: {e}")
         return jsonify({"success": False, "message": "Erreur serveur inattendue."}), 500
 
-
 @web_bp.route('/api/repository_files/<repo_slug>', methods=['GET'])
 @login_required
 def get_repository_files(repo_slug):