feat: Check if url is a WS URL (#227)

* feat: Check if url is an WSS URL

* feat: Check if url is an WSS URL

* feat: Check if url is an WSS URL

* feat: Check if url is an WSS URL

* feat: Check if url is an WSS URL

realtime/_async/client.py

@@ -21,6 +21,7 @@
     T_ParamSpec,
     T_Retval,
 )
+from ..utils import is_ws_url
 from .channel import AsyncRealtimeChannel, RealtimeChannelOptions
 
 logger = logging.getLogger(__name__)
@@ -60,6 +61,8 @@ def __init__(
         :param max_retries: Maximum number of reconnection attempts. Defaults to 5.
         :param initial_backoff: Initial backoff time (in seconds) for reconnection attempts. Defaults to 1.0.
         """
+        if not is_ws_url(url):
+            ValueError("url must be a valid WebSocket URL or HTTP URL string")
         self.url = f"{re.sub(r'https://', 'wss://', re.sub(r'http://', 'ws://', url, flags=re.IGNORECASE), flags=re.IGNORECASE)}/websocket?apikey={token}"
         self.http_endpoint = http_endpoint_url(url)
         self.is_connected = False

realtime/utils.py

@@ -0,0 +1,5 @@
+from urllib.parse import urlparse
+
+
+def is_ws_url(url: str) -> bool:
+    return urlparse(url).scheme in {"wss", "ws", "http", "https"}