musica: usar gradio_client

app.py

@@ -507,7 +507,6 @@ async def ep_musica(file: UploadFile = File(...)):
 @app.post("/generar-musica-ia")
 async def ep_musica_ia(request: Request):
     try:
-        import requests as _req, json as _json
         d = await request.json()
         nicho = d.get("nicho", "espiritual")
         duracion = int(d.get("duracion", 20))
@@ -522,45 +521,22 @@ async def ep_musica_ia(request: Request):
             "naturaleza": "peaceful nature sounds, light acoustic guitar, calm",
             "default": "cinematic background music, neutral mood, no vocals",
         }
-        prompt = next((v for k,v in PROMPTS.items() if k in nicho.lower()), PROMPTS["default"])
-        endpoint = f"{url_fabrica}/gradio_api/call/generar_musica"
-        r1 = _req.post(endpoint, json={"data": [prompt, duracion]}, timeout=60)
-        r1.raise_for_status()
-        event_id = r1.json().get("event_id")
-        if not event_id:
-            return JSONResponse({"error": "Sin event_id de la Fabrica"}, status_code=500)
-        stream_url = f"{url_fabrica}/gradio_api/call/generar_musica/{event_id}"
-        with _req.get(stream_url, stream=True, timeout=300) as stream:
-            for line in stream.iter_lines():
-                if not line: continue
-                decoded = line.decode("utf-8")
-                log(f"[Musica][raw] {decoded[:180]}")
-                if not decoded.startswith("data:"): continue
-                try:
-                    data = _json.loads(decoded[5:].strip())
-                except Exception:
-                    continue
-                if not (isinstance(data, list) and data): continue
-                audio_url = data[0]
-                if audio_url is None: continue
-                if isinstance(audio_url, dict):
-                    audio_url = audio_url.get("url") or audio_url.get("path","") or ""
-                if not isinstance(audio_url, str) or not audio_url:
-                    continue
-                if not audio_url.startswith("http"):
-                    if "/gradio_api/file=" in audio_url:
-                        audio_url = url_fabrica + audio_url
-                    else:
-                        audio_url = url_fabrica + "/gradio_api/file=" + audio_url
-                audio_resp = _req.get(audio_url, timeout=60)
-                audio_resp.raise_for_status()
-                with open("musica.mp3","wb") as f:
-                    f.write(audio_resp.content)
-                ESTADO["musica"] = True
-                log(f"[Musica] OK -> {audio_url[:90]}")
-                return {"ok": True}
-        log("[Musica] La Fabrica no devolvio audio")
-        return JSONResponse({"error": "La Fabrica no devolvio audio"}, status_code=500)
+        prompt = next((v for k, v in PROMPTS.items() if k in nicho.lower()), PROMPTS["default"])
+        from gradio_client import Client
+        client = Client(url_fabrica)
+        ruta = client.predict(prompt, duracion, api_name="/generar_musica")
+        if isinstance(ruta, (list, tuple)) and ruta:
+            ruta = ruta[0]
+        if isinstance(ruta, dict):
+            ruta = ruta.get("path") or ruta.get("name") or ""
+        if not ruta or not os.path.exists(ruta):
+            log(f"[Musica] sin fichero valido: {ruta}")
+            return JSONResponse({"error": "La Fabrica no devolvio audio"}, status_code=500)
+        with open(ruta, "rb") as fi, open("musica.mp3", "wb") as fo:
+            fo.write(fi.read())
+        ESTADO["musica"] = True
+        log(f"[Musica] OK -> {ruta}")
+        return {"ok": True}
     except Exception as e:
         log(f"[Musica] ERROR: {e}")
         return JSONResponse({"error": str(e)[:200]}, status_code=500)