debug avec ia

fonction/first_class.py

@@ -293,6 +293,29 @@ class RecordTwitch:
             pass
         return url
 
+    def get_url_with_retry(self, max_attempts=10, retry_delay=30):
+        """
+        Essaie de récupérer l'URL du flux avec des tentatives répétées
+        """
+        sprint(self.script_name,"green","start get_url_with_retry")
+        attempt = 1
+        
+        while attempt <= max_attempts and self.running:
+            sprint(self.script_name,"yellow",f"Tentative {attempt}/{max_attempts} de récupération du flux...")
+            
+            url = self.get_url()
+            if url:
+                sprint(self.script_name,"green",f"Flux trouvé après {attempt} tentative(s)")
+                return url
+            
+            if attempt < max_attempts:
+                sprint(self.script_name,"yellow",f"Aucun flux trouvé. Nouvelle tentative dans {retry_delay} secondes...")
+                time.sleep(retry_delay)
+            
+            attempt += 1
+        
+        sprint(self.script_name,"red",f"Impossible de récupérer l'URL du flux après {max_attempts} tentatives")
+        return None
 
 
     def loop_run(self, intervalle):#boucle pour déplacer les fichier fini enregistrement
@@ -377,9 +400,20 @@ class RecordTwitch:
         self.running = True
         self.clear_diretory()
 
-        self.stream_url = self.get_url()
-        if not self.stream_url:
-            sprint(self.script_name,"red","Impossible de récupérer l'URL du flux")
+        # Boucle infinie pour attendre qu'un flux soit disponible
+        while self.running:
+            self.stream_url = self.get_url_with_retry()
+            if not self.stream_url:
+                sprint(self.script_name,"red","Aucun flux disponible. Attente de 60 secondes avant nouvelle tentative...")
+                time.sleep(60)  # Attendre 1 minute avant de réessayer
+                continue
+            
+            # Si on arrive ici, on a trouvé un flux
+            sprint(self.script_name,"green","Flux trouvé ! Démarrage de l'enregistrement...")
+            break
+
+        if not self.running:
+            sprint(self.script_name,"yellow","Arrêt demandé pendant la recherche de flux")
             return
 
         record_thread = Thread(target=self.record_audio)