Create app.py

app.py

@@ -0,0 +1,89 @@
+import io
+import os
+import wave
+from pathlib import Path
+
+from fastapi import FastAPI, HTTPException, Header
+from fastapi.responses import StreamingResponse
+from huggingface_hub import hf_hub_download
+from piper import PiperVoice
+
+app = FastAPI()
+
+# Senha simples que o app Flutter precisa enviar em todo request
+API_SECRET = os.environ.get("API_SECRET", "")
+
+MODEL_REPO = "Lucasllfs/Razo-piper-voice"
+MODEL_FILE = "pt-BR-razo-medium.onnx"
+CONFIG_FILE = "pt-BR-razo-medium.onnx.json"
+
+_voice = None
+
+
+def get_voice():
+    """Baixa o modelo (se ainda não estiver em cache) e carrega o Piper."""
+    global _voice
+    if _voice is None:
+        cache_dir = "/tmp/razo_model"
+        Path(cache_dir).mkdir(parents=True, exist_ok=True)
+
+        onnx_path = hf_hub_download(
+            repo_id=MODEL_REPO,
+            filename=MODEL_FILE,
+            cache_dir=cache_dir,
+        )
+
+        # O config no repositório se chama "config.json", então tentamos
+        # os dois nomes possíveis para não quebrar caso o autor renomeie.
+        try:
+            config_path = hf_hub_download(
+                repo_id=MODEL_REPO,
+                filename=CONFIG_FILE,
+                cache_dir=cache_dir,
+            )
+        except Exception:
+            config_path = hf_hub_download(
+                repo_id=MODEL_REPO,
+                filename="config.json",
+                cache_dir=cache_dir,
+            )
+            # Piper espera o config com o mesmo nome do .onnx + ".json"
+            expected_path = onnx_path + ".json"
+            if not os.path.exists(expected_path):
+                os.symlink(config_path, expected_path)
+            config_path = expected_path
+
+        _voice = PiperVoice.load(onnx_path, config_path=config_path)
+
+    return _voice
+
+
+def check_auth(authorization: str | None):
+    if not API_SECRET:
+        # Se nenhuma senha foi configurada no Space, libera (modo dev)
+        return
+    if authorization != f"Bearer {API_SECRET}":
+        raise HTTPException(status_code=401, detail="Não autorizado")
+
+
+@app.get("/")
+def health():
+    return {"status": "ok", "voice": "razo-pt-BR"}
+
+
+@app.post("/tts")
+def synthesize(payload: dict, authorization: str | None = Header(default=None)):
+    check_auth(authorization)
+
+    text = payload.get("text", "").strip()
+    if not text:
+        raise HTTPException(status_code=400, detail="Campo 'text' vazio")
+
+    voice = get_voice()
+
+    buffer = io.BytesIO()
+    with wave.open(buffer, "wb") as wav_file:
+        voice.synthesize(text, wav_file)
+
+    buffer.seek(0)
+    return StreamingResponse(buffer, media_type="audio/wav")