Hot fix 0.14.1

examples/deribit/check_is_connected.py

@@ -0,0 +1,26 @@
+import asyncio
+import json
+from ssc2ce import Deribit
+
+conn = Deribit()
+
+print("Is connected after init", conn.is_connected())
+
+
+def close():
+    print("Check connection  before closing", conn.is_connected())
+    asyncio.ensure_future(conn.stop())
+
+
+loop = asyncio.get_event_loop()
+
+
+loop.call_later(1, close)
+
+try:
+    loop.run_until_complete(conn.run_receiver())
+except KeyboardInterrupt:
+    print("Application closed by KeyboardInterrupt.")
+
+
+print("Is connected before exit", conn.is_connected())

examples/deribit/deribit_private.py

@@ -98,7 +98,7 @@ async def do_something_after_login(self):
     async def printer(self, **kwargs):
         self.logger.info(f"{repr(kwargs)}")
 
-    @ staticmethod
+    @staticmethod
     def resolve_route(value, routes):
         key, handler = None, None
         for key, handler in routes:

setup.py

@@ -7,7 +7,7 @@
 
 setuptools.setup(
     name='ssc2ce',
-    version="0.14.0",
+    version="0.14.1",
     author='Oleg Nedbaylo',
     author_email='olned64@gmail.com',
     description='A Set of Simple Connectors for access To Cryptocurrency Exchanges',

ssc2ce/common/session.py

@@ -181,3 +181,9 @@ async def public_get(self, request_path, params=None):
     async def stop(self):
         await self.ws.close()
         await self._session.close()
+
+    def is_connected(self) -> bool:
+        if self.ws is None:
+            return False
+
+        return not self.ws.closed

ssc2ce/deribit/deribit.py

@@ -92,12 +92,6 @@ def __init__(self,
     def close(self):
         super()._close()
 
-    async def stop(self):
-        """
-        Close connection and break the receiver loop
-        :return:
-        """
-        await self.ws.close()
 
     async def send_public(self, request: dict, callback=None, logging_it: bool = True) -> int:
         """