use _speech_lock to prefent espeak and piper speaks the same time

Author: sl5net

config/maps/plugins/z_fallback_llm/de-DE/radio_deep_dive.py

@@ -1,3 +1,4 @@
+# config/maps/plugins/z_fallback_llm/de-DE/radio_deep_dive.py
 import os
 import random
 import re
@@ -7,8 +8,11 @@
 import datetime
 import sys
 import urllib.request
+import threading
+
 from pathlib import Path
 import subprocess  # Added for espeak support
+# config/maps/plugins/z_fallback_llm/de-DE/radio_deep_dive.py
 
 # --- METADATA ---
 VERSION = "1.1.0"
@@ -27,6 +31,7 @@
 # Go up to the repository root
 REPO_ROOT = SCRIPT_DIR.parents[4]
 
+_speech_lock = threading.Lock()
 
 def init_db():
     """
@@ -179,29 +184,29 @@ def save_to_aura_db(question, answer, file_path):
 PIPER_SERVER_URL = f"https://{PIPER_SERVER_HOST}:{PIPER_SERVER_PORT}/speak"
 PIPER_SPEAK_FILE = os.path.expanduser("~/projects/py/TTS/speak_file.py")
 
-import threading
 
 def speak(text, voice="de-de", pitch=50, blocking=False, use_espeak=False):
     if not text or not globals().get('SPEECH_ENABLED', True):
         return None
 
     def _do_speak(use_espeak2):
-        if not use_espeak2:
+        with _speech_lock:  # 🔒 Nur eine Sprachausgabe gleichzeitig
+            if not use_espeak2:
+                try:
+                    with open('/tmp/speak_server_input.txt', 'w') as f:
+                        f.write(text)
+                    requests.post(PIPER_SERVER_URL, verify=False, timeout=60)
+                    return
+                except requests.exceptions.ConnectionError:
+                    print("  !! Piper Server nicht erreichbar — Fallback zu espeak")
+                except Exception as e:
+                    print(f"  !! Piper Error: {e} — Fallback zu espeak-ng")
+
+            # Fallback: espeak-ng
             try:
-                with open('/tmp/speak_server_input.txt', 'w') as f:
-                    f.write(text)
-                requests.post(PIPER_SERVER_URL, verify=False, timeout=60)
-                return
-            except requests.exceptions.ConnectionError:
-                print("  !! Piper Server nicht erreichbar — Fallback zu espeak")
+                subprocess.run(["espeak-ng", "-v", voice, "-s", "150", "-p", str(pitch), text])
             except Exception as e:
-                print(f"  !! Piper Error: {e} — Fallback zu espeak")
-
-        # Fallback: espeak
-        try:
-            subprocess.run(["espeak", "-v", voice, "-s", "150", "-p", str(pitch), text])
-        except Exception as e:
-            print(f"  !! Speech Error (espeak): {e}")
+                print(f"  !! Speech Error (espeak-ng): {e}")
 
     t = threading.Thread(target=_do_speak, args=(use_espeak,))
     t.start()

scripts/py/func/checks/integrity_rules.py

@@ -187,6 +187,11 @@
 
 
 
+    "config/maps/plugins/z_fallback_llm/de-DE/radio_deep_dive.py": [
+        'espeak-ng',
+        'lstrip("/docs/',
+    ],
+
     # should_remove_zips_after_unpack=true It's eventually useful to have it sometimes longer but maybe not online and not at costumers
 
     # --- Start of Ensures language selection is included ---