fix(client-python): normalize server URI paths before appending task service

packages/client-python/src/rocketride/mixins/connection.py

@@ -313,8 +313,11 @@ def _get_websocket_uri(uri: str) -> str:
         parsed = urllib.parse.urlparse(normalized)
 
         ws_scheme = 'wss' if parsed.scheme in ('https', 'wss') else 'ws'
-        ws_uri = parsed._replace(scheme=ws_scheme)
-        return f'{ws_uri.geturl()}/task/service'
+        path = parsed.path.rstrip('/')
+        if not path.endswith('/task/service'):
+            path = f'{path}/task/service' if path else '/task/service'
+        ws_uri = parsed._replace(scheme=ws_scheme, path=path)
+        return ws_uri.geturl()
 
     def _set_uri(self, uri: str) -> None:
         """Update the server URI (internal)."""

packages/client-python/tests/test_connection_uri.py

@@ -0,0 +1,18 @@
+import pytest
+
+from rocketride.mixins.connection import ConnectionMixin
+
+
+@pytest.mark.parametrize(
+    ('input_uri', 'expected_uri'),
+    [
+        ('https://cloud.rocketride.ai', 'wss://cloud.rocketride.ai/task/service'),
+        ('https://cloud.rocketride.ai/', 'wss://cloud.rocketride.ai/task/service'),
+        ('wss://cloud.rocketride.ai/task/service', 'wss://cloud.rocketride.ai/task/service'),
+        ('ws://localhost:5565', 'ws://localhost:5565/task/service'),
+        ('ws://localhost:5565/', 'ws://localhost:5565/task/service'),
+        ('ws://localhost:5565/task/service', 'ws://localhost:5565/task/service'),
+    ],
+)
+def test_get_websocket_uri_normalizes_task_service_path(input_uri, expected_uri):
+    assert ConnectionMixin._get_websocket_uri(input_uri) == expected_uri