Merge branch '55-allow-unsecured-connections-for-expir'

auraxium/_rest.py

@@ -48,12 +48,13 @@ class RequestClient:
     """The REST request handler for Auraxium."""
 
     def __init__(self, loop: Optional[asyncio.AbstractEventLoop] = None,
-                 service_id: str = 's:example', profiling: bool = False
-                 ) -> None:
+                 service_id: str = 's:example', profiling: bool = False,
+                 no_ssl_certs: bool = False) -> None:
         self.loop = loop or asyncio.get_event_loop()
         self.profiling = profiling
         self.service_id = service_id
         self.session = aiohttp.ClientSession()
+        self._no_ssl_certs = no_ssl_certs
         self._timing_cache: List[float] = []
 
     async def __aenter__(self: _T) -> _T:

auraxium/event/_client.py

@@ -2,6 +2,7 @@
 import contextlib
 import json
 import logging
+import ssl
 from typing import (Any, Callable, Coroutine, Dict, Iterator, List, Optional, Type, TypeVar, Union,
                     cast, overload)
 
@@ -264,7 +265,11 @@ async def _connection_handler(self) -> None:
         """
         _log.info('Connecting to WebSocket endpoint...')
         url = f'{_ESS_ENDPOINT}?environment=ps2&service-id={self.service_id}'
-        async with ws_client.connect(url) as websocket:
+        if self._no_ssl_certs:
+            ssl_ctx = ssl.SSLContext()
+        else:
+            ssl_ctx = None
+        async with ws_client.connect(url, ssl=ssl_ctx) as websocket:
             self.websocket = websocket
             _log.info('Connected to %s?environment=ps2&service-id=XXX',
                       _ESS_ENDPOINT)

tests/event_test.py

@@ -29,7 +29,8 @@ async def asyncSetUp(self) -> None:
         """Reset the event streaming client before every test."""
         if self._client is not None:
             await self._client.close()
-        self._client = auraxium.event.EventClient(service_id=SERVICE_ID)
+        self._client = auraxium.event.EventClient(
+            service_id=SERVICE_ID, no_ssl_certs=True)
 
     async def asyncTearDown(self) -> None:
         """Close the event streaming client after every test."""