Upload 30 files

api_client.py

@@ -21,11 +21,6 @@ class APIClient:
         self.base_url = (env_engine_url or base_url or "").rstrip("/")
         # URL específica para el servicio TTS (por defecto usa la variable de entorno API_TTS_URL)
         self.tts_url = tts_url or os.getenv("API_TTS_URL", "https://veureu-tts.hf.space")
-        print(f"🔧 APIClient.__init__ - tts_url recibida: {tts_url}")
-        print(f"🔧 APIClient.__init__ - os.getenv(API_TTS_URL): {os.getenv('API_TTS_URL')}")
-        print(f"🔧 APIClient.__init__ - self.tts_url final: {self.tts_url}")
-        print(f"🔧 APIClient.__init__ - tipo self.tts_url: {type(self.tts_url)}")
-        print(f"🔧 APIClient.__init__ - repr self.tts_url: {repr(self.tts_url)}")
         self.use_mock = use_mock
         self.data_dir = data_dir
         self.timeout = timeout
@@ -134,19 +129,12 @@ class APIClient:
         if not self.tts_url:
             raise ValueError("La URL del servei TTS no està configurada (API_TTS_URL)")
 
-        print(f"🔧 tts_matxa - self.tts_url ANTES de construir URL: {self.tts_url}")
-        print(f"🔧 tts_matxa - tipo self.tts_url: {type(self.tts_url)}")
-        print(f"🔧 tts_matxa - repr self.tts_url: {repr(self.tts_url)}")
-        
         # Usar endpoint apropiado según la longitud del texto
         if len(text) > 480:
             url = f"{self.tts_url.rstrip('/')}/tts/text_long"
         else:
             url = f"{self.tts_url.rstrip('/')}/tts/text"
-        
-        print(f"🔧 tts_matxa - URL final construida: {url}")
-        print(f"🔧 tts_matxa - repr URL final: {repr(url)}")
-        
+
         data = {
             "texto": text,
             "voice": voice,
@@ -154,24 +142,10 @@ class APIClient:
         }
         
         try:
-            print(f"🎯 Llamando TTS a: {url}")
-            print(f"📝 Texto length: {len(text)} caracteres")
-            print(f"🗣️  Voz: {voice}")
-            
-            r = self.session.post(url, data=data, timeout=self.timeout * 2)  # Más tiempo para textos largos
-            print(f"📊 Response status: {r.status_code}")
-            
+            r = self.session.post(url, data=data, timeout=self.timeout * 2)
             r.raise_for_status()
-            
-            # Devolver los bytes directamente para que el cliente los pueda concatenar
-            print(f"✅ Audio recibido: {len(r.content)} bytes")
             return {"mp3_bytes": r.content}
-
         except requests.exceptions.RequestException as e:
-            print(f"❌ Error cridant a TTS: {e}")
-            print(f"❌ URL: {url}")
-            print(f"❌ Data: {data}")
-            # Devolvemos un diccionario con error para que la UI lo muestre
             return {"error": str(e)}
 
 
@@ -190,7 +164,6 @@ class APIClient:
             # El endpoint devuelve un ZIP binario
             return {"zip_bytes": r.content}
         except requests.exceptions.RequestException as e:
-            print(f"[import_databases] Error: {e}")
             return {"error": str(e)}
 
 
@@ -610,13 +583,7 @@ class APIClient:
             raise ValueError("La URL del servei TTS no està configurada (API_TTS_URL)")
 
         url = f"{self.tts_url.rstrip('/')}/tts/srt"
-        
-        print(f"🎬 Reconstruyendo video con AD")
-        print(f"🎯 URL TTS: {url}")
-        print(f"📹 Video: {video_path}")
-        print(f"📝 SRT: {srt_path}")
-        print(f"🗣️  Voz: {voice}")
-        
+
         try:
             with open(video_path, 'rb') as video_file:
                 with open(srt_path, 'rb') as srt_file:
@@ -645,12 +612,10 @@ class APIClient:
             return {"error": "No se encontró el archivo de vídeo MP4 en la respuesta del servidor."}
 
         except requests.exceptions.RequestException as e:
-            print(f"Error cridant a la reconstrucció de vídeo: {e}")
             return {"error": str(e)}
         except zipfile.BadZipFile:
             return {"error": "La respuesta del servidor no fue un archivo ZIP válido."}
         except Exception as e:
-            print(f"Error inesperat: {e}")
             return {"error": str(e)}
 
 
@@ -882,7 +847,6 @@ class APIClient:
             return {"mp3_bytes": r.content}
 
         except requests.exceptions.RequestException as e:
-            print(f"Error cridant a TTS per a text llarg: {e}")
             return {"error": str(e)}
 
 
@@ -915,12 +879,7 @@ def describe_image_with_svision(image_path: str, is_face: bool = True) -> Tuple[
         
         # Conectar al space svision con timeout generoso per al cold start de ZeroGPU
         svision_url = os.getenv("SVISION_URL", "https://veureu-svision.hf.space")
-        print(f"[svision] Connectant a {svision_url}...")
-
-        # La versió actual de gradio_client al Space no accepta el paràmetre hf_token al constructor.
-        # Confiem en la configuració d'entorn del Space per a l'autenticació (si s'escau).
         client = Client(svision_url)
-        print("[svision] Client creat (sense hf_token explícit)")
         
         # Preparar prompt según el tipo
         if is_face:
@@ -928,9 +887,6 @@ def describe_image_with_svision(image_path: str, is_face: bool = True) -> Tuple[
         else:
             prompt = "Descriu aquesta escena breument en 2-3 frases: tipus de localització i elements principals."
         
-        print(f"[svision] Enviant petició (pot trigar si ZeroGPU està en cold start)...")
-        print(f"[svision] Image path: {image_path}")
-        
         import time
         start_time = time.time()
         max_tokens = 256 if is_face else 128
@@ -941,7 +897,6 @@ def describe_image_with_svision(image_path: str, is_face: bool = True) -> Tuple[
 
         for attempt in range(1, max_attempts + 1):
             try:
-                print(f"[svision] Attempt {attempt}/{max_attempts} (wait={wait_seconds}s)")
                 result = client.predict(
                     handle_file(image_path),
                     prompt,
@@ -954,15 +909,11 @@ def describe_image_with_svision(image_path: str, is_face: bool = True) -> Tuple[
                 raise RuntimeError("Resposta buida de svision")
             except Exception as exc:
                 last_error = exc
-                print(f"[svision] Error attempt {attempt}/{max_attempts}: {exc}")
                 if attempt == max_attempts:
                     raise
                 time.sleep(wait_seconds)
                 wait_seconds = min(wait_seconds * 2, 40)
 
-        elapsed = time.time() - start_time
-        print(f"[svision] Resposta rebuda en {elapsed:.1f}s")
-        
         full_description = result.strip() if result else ""
         
         # PASO 1: Eliminar el prompt original que puede aparecer en la respuesta
@@ -1036,15 +987,9 @@ def describe_image_with_svision(image_path: str, is_face: bool = True) -> Tuple[
             words = full_description.split()[:4]
             short_name = " ".join(words).capitalize()
         
-        print(f"[svision] Descripció generada: {full_description[:100]}...")
-        print(f"[svision] Nom: {short_name}")
-        
         return (full_description, short_name)
-        
+
     except Exception as e:
-        print(f"[svision] Error al descriure imatge: {e}")
-        import traceback
-        traceback.print_exc()
         return ("", "")
 
 
@@ -1065,18 +1010,11 @@ def generate_short_scene_name(description: str) -> str:
         
         # URL del space schat
         schat_url = os.getenv("SCHAT_URL", "https://veureu-schat.hf.space")
-        print(f"[schat] Connectant a {schat_url}...")
-
-        # La versió actual de gradio_client al Space no accepta el paràmetre hf_token.
-        # Confiem en la configuració d'entorn per a l'autenticació si és necessari.
         client = Client(schat_url)
-        print("[schat] Client creat (sense hf_token explícit)")
         
         # Preparar prompt
         prompt = f"Basant-te en aquesta descripció d'una escena, genera un nom curt de menys de 3 paraules que la resumeixi:\n\n{description}\n\nNom de l'escena:"
-        
-        print(f"[schat] Generant nom curt per descripció: {description[:100]}...")
-        
+
         # Llamar al endpoint /predict de schat
         # Parámetros típicos: mensaje, historial, max_new_tokens, temperature, top_p, top_k, repetition_penalty
         result = client.predict(
@@ -1118,12 +1056,7 @@ def generate_short_scene_name(description: str) -> str:
         if len(words) > 3:
             short_name = " ".join(words[:3])
         
-        print(f"[schat] Nom curt generat: {short_name}")
-        
         return short_name
-        
+
     except Exception as e:
-        print(f"[schat] Error al generar nom curt: {e}")
-        import traceback
-        traceback.print_exc()
         return ""

app.py

@@ -85,11 +85,7 @@ BACKEND_BASE_URL = (
     or "http://localhost:8000"
 )
 
-TTS_URL = "https://veureu-tts.hf.space"  # Forzar URL correcta
-print(f"🔧 TTS_URL configurada: {TTS_URL}")
-print(f"🔧 Tipo de TTS_URL: {type(TTS_URL)}")
-print(f"🔧 Longitud de TTS_URL: {len(TTS_URL)}")
-print(f"🔧 TTS_URL repr: {repr(TTS_URL)}")
+TTS_URL = "https://veureu-tts.hf.space"
 USE_MOCK = bool(CFG.get("app", {}).get("use_mock", False))  # si no la tienes en el yaml, queda False
 
 COMPLIANCE_CFG = CFG.get("compliance", {}) or {}

scripts/verify_temp_dbs.py

@@ -1,86 +1,16 @@
-"""Verificador de BDs de la demo (para usar desde el Space demo).
+"""Verificador de BDs de la demo — desactivado.
 
-Muestra qué ficheros .db existen en:
-- demo/data/db
-- demo/temp/db
-
-Se puede ejecutar como script independiente o invocado desde el código
-para dejar trazas en el log.
+Este script ya no produce salida en logs.
 """
 
-from pathlib import Path
-import yaml
-
-# Este archivo vive en demo/scripts, así que la raíz de demo es el padre
-DEMO_ROOT = Path(__file__).resolve().parent.parent
-
-
-def read_data_origin() -> str:
-    cfg_path = DEMO_ROOT / "config.yaml"
-    if not cfg_path.exists():
-        return "(config.yaml no encontrado)"
-    try:
-        with cfg_path.open("r", encoding="utf-8") as f:
-            cfg = yaml.safe_load(f) or {}
-        app_cfg = cfg.get("app", {}) or {}
-        return str(app_cfg.get("data_origin", "internal")).lower()
-    except Exception as e:
-        return f"(error leyendo config.yaml: {e})"
-
-
-def list_dbs(path: Path) -> list[str]:
-    if not path.exists():
-        return []
-    return sorted(str(p.name) for p in path.glob("*.db"))
-
 
 def run_verification() -> None:
-    """Ejecuta la verificación y escribe por stdout.
-
-    Pensado para ser llamado desde ensure_temp_databases para dejar
-    trazas en el log del Space demo.
-    """
-    data_origin = read_data_origin()
-    data_db_dir = DEMO_ROOT / "data" / "db"
-    temp_db_dir = DEMO_ROOT / "temp" / "db"
-
-    print("=== Verificación de BDs demo (invocada desde Space demo) ===")
-    print(f"Raíz demo:       {DEMO_ROOT}")
-    print(f"data_origin:     {data_origin}")
-    print(f"data/db dir:     {data_db_dir}")
-    print(f"temp/db dir:     {temp_db_dir}")
-    print()
-
-    data_dbs = list_dbs(data_db_dir)
-    temp_dbs = list_dbs(temp_db_dir)
-
-    print("-- demo/data/db --")
-    if data_dbs:
-        for name in data_dbs:
-            print(f"  - {name}")
-    else:
-        print("  (sin .db)")
-    print()
-
-    print("-- demo/temp/db --")
-    if temp_dbs:
-        for name in temp_dbs:
-            print(f"  - {name}")
-    else:
-        print("  (sin .db)")
-    print()
-
-    missing_in_temp = [n for n in data_dbs if n not in temp_dbs]
-    if missing_in_temp:
-        print("Ficheros presentes en data/db pero NO en temp/db:")
-        for n in missing_in_temp:
-            print(f"  - {n}")
-    else:
-        print("Todos los .db de data/db están también en temp/db (o no hay .db)")
+    """No-op: verificación desactivada."""
+    pass
 
 
 def main() -> None:
-    run_verification()
+    pass
 
 
 if __name__ == "__main__":