diff --git a/bridge/aria_bridge.py b/bridge/aria_bridge.py index 2a40927..4d5d4f0 100644 --- a/bridge/aria_bridge.py +++ b/bridge/aria_bridge.py @@ -1449,13 +1449,16 @@ class ARIABridge: self._pending_stt[request_id] = future try: + model = getattr(self.stt_engine, "model_size", "small") + logger.info("[rvs] stt_request → whisper-bridge (id=%s, model=%s, %dKB)", + request_id[:8], model, len(audio_b64) // 1365) await self._send_to_rvs({ "type": "stt_request", "payload": { "requestId": request_id, "audio": audio_b64, "mimeType": mime_type, - "model": getattr(self.stt_engine, "model_size", "small"), + "model": model, "language": getattr(self.stt_engine, "language", "de"), }, "timestamp": int(loop.time() * 1000), diff --git a/xtts/whisper/bridge.py b/xtts/whisper/bridge.py index aa23f6c..69128b1 100644 --- a/xtts/whisper/bridge.py +++ b/xtts/whisper/bridge.py @@ -214,13 +214,20 @@ async def run_loop(runner: WhisperRunner) -> None: payload = msg.get("payload", {}) or {} if mtype == "stt_request": + req_id = payload.get("requestId", "?") + audio_len = len(payload.get("audio", "")) + logger.info("stt_request empfangen (id=%s, %dKB Audio)", + req_id[:8] if req_id != "?" else "?", audio_len // 1365) asyncio.create_task(handle_stt_request(ws, payload, runner)) elif mtype == "config": new_model = payload.get("whisperModel") if new_model and new_model != runner.model_size: logger.info("Config-Broadcast: Whisper-Modell → %s", new_model) asyncio.create_task(runner.ensure_loaded(new_model)) - # andere Types (chat, heartbeat, ...) einfach ignorieren + else: + # Alle anderen Nachrichten debug-loggen — hilft beim Diagnostizieren, + # ob stt_request ueberhaupt durch den RVS kommt + logger.debug("Unbeachteter Type: %s", mtype) except Exception as e: logger.warning("Verbindung verloren: %s", e) if use_tls and RVS_TLS_FALLBACK and not tls_fallback_tried: