Added Async HTTP

CHANGELOG.md

@@ -5,6 +5,9 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [5.8.1] - 2024-08-19
+### Added
+- Async HTTP module: `bybit.asyncio`
 
 ## [5.8.0] - 2024-06-26
 ### Added

pybit/__init__.py

@@ -1 +1 @@
-VERSION = "5.8.0"
+VERSION = "5.8.1"

pybit/_helpers.py

@@ -72,4 +72,4 @@ def is_usdc_perpetual(symbol: str):
 
 def is_usdc_option(symbol: str):
     if re.search(r"[A-Z]{3}-.*-[PC]$", symbol):
-        return True
+        return True

pybit/_http_manager.py

@@ -361,7 +361,7 @@ def _submit_request(self, method=None, path=None, query=None, auth=False):
                         limit_reset_time = int(s.headers["X-Bapi-Limit-Reset-Timestamp"])
                         limit_reset_str = dt.fromtimestamp(limit_reset_time / 10**3).strftime(
                             "%H:%M:%S.%f")[:-3]
-                        delay_time = (int(limit_reset_time) - _helpers.generate_timestamp()) / 10**3
+                        delay_time = (int(limit_reset_time) - _helpers.generate_timestamp()) / 10 ** 3
                         error_msg = (
                             f"API rate limit will reset at {limit_reset_str}. "
                             f"Sleeping for {int(delay_time * 10**3)} milliseconds"

pybit/_websocket_stream.py

@@ -6,8 +6,7 @@
 import logging
 import copy
 from uuid import uuid4
-from . import _helpers
-
+from .asyncio import _helpers
 
 logger = logging.getLogger(__name__)
 

pybit/_websocket_trading.py

@@ -3,8 +3,7 @@
 import uuid
 import logging
 from ._websocket_stream import _WebSocketManager
-from . import _helpers
-
+from .asyncio import _helpers
 
 logger = logging.getLogger(__name__)