Update baserow_storage.py

baserow_storage.py

@@ -600,41 +600,75 @@ def get_deployment_by_id(deploy_id: str) -> Optional[Dict]:
         logger.error(f"Échec de la récupération du déploiement Baserow. Status: {response.status_code}, Body: {response.text}")
         return None
 
-def save_new_deployment(
-    user_id: str, 
-    deploy_id: str, 
-    index_file_present: bool, # Non utilisé directement ici, mais requis par l'appel dans web_routes.py
-    full_repo_path: str
-) -> tuple[bool, str, Optional[int]]:
+def save_new_repository(
+    user_id: int, 
+    repo_data: Dict
+) -> tuple[bool, str]:
     """
-    Enregistre les données d'un nouveau déploiement dans Baserow en mettant 
-    à jour la ligne de l'utilisateur principal.
-    
-    C'est la fonction manquante qui cause l'ImportError.
+    Ajoute un nouveau dépôt à la liste 'FIELD_REPOS_DATA' de l'utilisateur.
+    Ceci remplace l'ancienne approche 'save_new_deployment' qui supposait un seul déploiement par utilisateur.
     """
-    # 1. Récupérer l'ID de ligne interne Baserow de l'utilisateur
-    user_data = load_primary_user_by_id(user_id) 
-    
-    if not user_data:
-        # L'utilisateur (Primary) n'existe pas dans la base de données.
-        return False, f"Erreur: Utilisateur principal ID '{user_id}' non trouvé pour l'enregistrement du déploiement.", None
     
-    user_baserow_row_id = user_data.get('baserow_row_id')
-    
-    if not user_baserow_row_id:
-        return False, f"Erreur critique: ID de ligne Baserow manquant pour l'utilisateur '{user_id}'.", None
-    
-    # 2. Mettre à jour la ligne utilisateur avec les données de déploiement 
-    # (ceci utilise la fonction existante update_user_deployment_data)
-    success, message = update_user_deployment_data(
-        user_baserow_row_id=user_baserow_row_id,
-        deploy_id=deploy_id,
-        user_link=user_id, # L'ID interne de l'utilisateur (UUID) sert de lien
-        hf_repo_path=full_repo_path
+    user_record = load_primary_user_data(filters={FIELD_ID: user_id}, single_record=True)
+    if not user_record:
+        logger.error(f"Utilisateur ID '{user_id}' non trouvé pour l'enregistrement du dépôt.")
+        return False, "Utilisateur non trouvé."
+
+    row_id = user_record.get('id')
+    if not row_id:
+        return False, f"Erreur critique: ID de ligne Baserow manquant pour l'utilisateur '{user_id}'."
+
+    # 1. Récupérer et désérialiser la liste des dépôts existants
+    repos_json = user_record.get(FIELD_REPOS_DATA)
+    try:
+        # Baserow renvoie 'None' ou une chaîne vide si le champ est vide
+        existing_repos = json.loads(repos_json) if repos_json and isinstance(repos_json, str) else []
+    except json.JSONDecodeError:
+        logger.warning(f"Champs Repositories Data corrompu pour l'utilisateur {user_id}. Réinitialisation.")
+        existing_repos = []
+
+    # 2. Ajouter le nouveau dépôt
+    existing_repos.append(repo_data)
+
+    # 3. Sérialiser la liste mise à jour
+    updated_repos_json = json.dumps(existing_repos)
+
+    # 4. Mettre à jour Baserow
+    url = f"{DATA_BASE_URL}table/{PRIMARY_USERS_TABLE_ID}/{row_id}/"
+    data = {
+        FIELD_REPOS_DATA: updated_repos_json
+    }
+
+    response = _make_baserow_request(
+        method="PATCH", 
+        url=url, 
+        data=data,
+        log_response=True
     )
-    
-    # 3. Retourner le succès, le message et l'ID de ligne Baserow
-    return success, message, user_baserow_row_id
+
+    if response.status_code == 200:
+        logger.info(f"Nouveau dépôt '{repo_data['repo_name']}' enregistré pour l'utilisateur ID {user_id}.")
+        return True, "Dépôt enregistré avec succès."
+    else:
+        # Gérer l'échec de la mise à jour (ex: données trop volumineuses ou erreur API)
+        error_message = response.text
+        logger.error(f"Échec de l'enregistrement du dépôt pour l'utilisateur {user_id}: {error_message}")
+        return False, f"Échec de la mise à jour Baserow: {error_message}"
+
+# Nouvelle fonction pour récupérer la liste de tous les dépôts d'un utilisateur
+def get_all_user_repositories(user_id: int) -> list:
+    """Récupère tous les dépôts d'un utilisateur depuis le champ JSON."""
+    user_record = load_primary_user_data(filters={FIELD_ID: user_id}, single_record=True)
+    if not user_record:
+        return []
+        
+    repos_json = user_record.get(FIELD_REPOS_DATA)
+    try:
+        return json.loads(repos_json) if repos_json and isinstance(repos_json, str) else []
+    except json.JSONDecodeError:
+        logger.warning(f"Champs Repositories Data corrompu pour l'utilisateur {user_id}.")
+        return []
+
 
 def delete_deployment_by_id(deploy_id: str) -> tuple[bool, str]:
     """