Update models/tts_router.py

models/tts_router.py

@@ -110,60 +110,48 @@ def _tts_with_pyttsx3(text: str) -> Optional[str]:
 def _tts_with_piper(text: str) -> Optional[str]:
     model = os.getenv("PIPER_MODEL")
     piper_bin = os.getenv("PIPER_BIN", "piper")
-
-    print(f"[TTS][PIPER] model={model} exists={os.path.exists(model) if model else None} bin={piper_bin}")
-
     if not (model and os.path.exists(model)):
-        print("[TTS][PIPER] missing or invalid PIPER_MODEL")
         return None
 
-    # Accept absolute custom binary or PATH binary
-    if os.path.isabs(piper_bin):
-        if not os.path.exists(piper_bin):
-            print("[TTS][PIPER] absolute PIPER_BIN not found:", piper_bin)
-            return None
-        _ensure_exec(piper_bin)
-    else:
-        if not _have(piper_bin):
-            print("[TTS][PIPER] binary not in PATH:", piper_bin)
-            return None
+    # accept either absolute binary path or something in PATH
+    bin_is_abs = os.path.isabs(piper_bin) and os.path.exists(piper_bin)
+    bin_in_path = which(piper_bin) is not None
+    if not (bin_is_abs or bin_in_path):
+        print(f"[TTS][PIPER] binary not found: {piper_bin}")
+        return None
 
-    out_dir = ensure_runtime_audio_dir()
-    out_path = os.path.join(out_dir, f"tts_{uuid.uuid4().hex}.wav")
-    safe_text = re.sub(r"[\x00-\x1F]+", " ", text).strip() or "Hello."
+    # Prefer system espeak-ng data if available
+    if not os.getenv("ESPEAK_DATA_PATH"):
+        for cand in ("/usr/share/espeak-ng-data", "/usr/share/espeak-data",
+                     "models/piper/espeak-ng-data"):
+            if os.path.isdir(cand):
+                os.environ["ESPEAK_DATA_PATH"] = cand
+                break
 
-    cmd = [piper_bin, "--model", model, "--output_file", out_path]
-    # Optional: speed/pitch envs
-    spd = os.getenv("PIPER_SPEED")
-    pit = os.getenv("PIPER_PITCH")
-    if spd: cmd += ["--length_scale", spd]
-    if pit: cmd += ["--pitch", pit]
+    out_path = os.path.join(ensure_runtime_audio_dir(), f"tts_{uuid.uuid4().hex}.wav")
+    safe_text = re.sub(r"[\x00-\x1F]+", " ", text).strip()
 
     try:
-        print("[TTS][PIPER] running:", " ".join(cmd))
+        # show stderr during debugging
         p = subprocess.Popen(
-            cmd,
+            [piper_bin, "--model", model, "--output_file", out_path],
             stdin=subprocess.PIPE,
-            stdout=subprocess.PIPE,
+            stdout=subprocess.DEVNULL,
             stderr=subprocess.PIPE,
+            env=os.environ.copy(),
         )
-        stdout, stderr = p.communicate(input=safe_text.encode("utf-8"), timeout=60)
-        rc = p.returncode
-        ok = os.path.exists(out_path) and _is_valid_wav(out_path)
-        print(f"[TTS][PIPER] rc={rc} wrote={out_path if os.path.exists(out_path) else 'None'} valid={ok}")
+        _, err = p.communicate(input=safe_text.encode("utf-8"), timeout=60)
+        ok = (p.returncode == 0 and _is_valid_wav(out_path))
         if not ok:
-            if stderr:
+            if err:
                 try:
-                    print("[TTS][PIPER][stderr]", stderr.decode("utf-8", "ignore")[:500])
+                    print("[TTS][PIPER][stderr]", err.decode("utf-8", "ignore")[:500])
                 except Exception:
                     pass
-        return out_path if ok else None
-    except subprocess.TimeoutExpired:
-        p.kill()
-        print("[TTS][PIPER] timeout")
-        return None
+            return None
+        return out_path
     except Exception as e:
-        print("[TTS][PIPER] error:", e)
+        print("[TTS] Piper error:", e)
         return None
 
 def _tts_with_say(text: str) -> Optional[str]: