Refactor WebSocket connection code in RimeNonJsonTTSService for improved readability

This commit is contained in:
Gokul Js
2025-11-19 22:46:36 +05:30
parent de4e9c54f6
commit cc861d6b70

View File

@@ -746,7 +746,9 @@ class RimeNonJsonTTSService(InterruptibleTTSService):
params = "&".join(f"{k}={v}" for k, v in self._settings.items() if v is not None)
url = f"{self._url}?{params}"
headers = {"Authorization": f"Bearer {self._api_key}"}
self._websocket = await websocket_connect(url, additional_headers=headers, max_size=1024 * 1024 * 16)
self._websocket = await websocket_connect(
url, additional_headers=headers, max_size=1024 * 1024 * 16
)
await self._call_event_handler("on_connected")
except Exception as e:
logger.error(f"{self} exception: {e}")