WebSocket TLS verification and HTTP redirect handling

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Changelog
 
+## 0.9.23 (2025-10-24)
+
+### Changes
+
+- Handle TLS verification checks for the websocket connection based on the `tlsSkipVerify` option.
+- Handle HTTP to HTTPS upgrades in websocket initialization.
+
 ## 0.9.22 (2025-10-23)
 
 ### Changes

python/mujinwebstackclient/controllerwebclientraw.py

@@ -15,6 +15,7 @@
 import asyncio
 import base64
 import os
+import ssl
 import requests
 import threading
 import traceback
@@ -461,12 +462,26 @@ async def _OpenWebSocketConnection(self):
         authorization = self._session.auth.GetAuthorizationHeader()
 
         # URL to http GraphQL endpoint on Mujin controller
-        graphEndpoint = '%s/api/v2/graphql' % self._baseurl
-        parsedUrl = urlparse(graphEndpoint)
+        path = '/api/v2/graphql'
+        try:
+            # make a test call to check for http to https upgrades, if there is any
+            response = self.Request('HEAD', path)
+            parsedUrl = urlparse(response.url)
+        except Exception as e:
+            log.exception('failed to query graphql endpoint: %s', e)
+            # fall back to original URL
+            parsedUrl = urlparse(self._baseurl + path)
+
         # parse url and handle different scheme
+        sslContext = None
         webSocketScheme = ''
         if parsedUrl.scheme == 'https':
             webSocketScheme = 'wss'
+            # re-use the current requests session settings for validating TLS certificates
+            if self._session.verify:
+                sslContext = ssl.create_default_context()
+            else:
+                sslContext = ssl._create_unverified_context()
         elif parsedUrl.scheme == 'http':
             webSocketScheme = 'ws'
         uri = '%s://%s%s' % (webSocketScheme, parsedUrl.netloc, parsedUrl.path)
@@ -485,12 +500,14 @@ async def _OpenWebSocketConnection(self):
                 uri=uri,
                 subprotocols=subprotocols,
                 additional_headers=headers,
+                ssl=sslContext,
             )
         else:
             self._webSocket = await websockets.connect(
                 uri=uri,
                 subprotocols=subprotocols,
                 additional_headers=headers,
+                ssl=sslContext,
             )
 
         await self._webSocket.send(

python/mujinwebstackclient/version.py

@@ -1,3 +1,3 @@
-__version__ = '0.9.22'
+__version__ = '0.9.23'
 
 # Do not forget to update CHANGELOG.md