2.1.34

🔧 fix(exchanges_wrapper): adjust return types for several functions to use 'list' and 'dict' annotations
🔧 fix(exchanges_wrapper): ensure consistent return types in 'fetch_server_time' and 'get_symbols' functions
🔧 fix(parsers): update 'orders', 'klines', and 'candle' functions in various parsers to use 'list' and 'dict' annotations

✨ feat(client.py): Update `UserEventsDataStream` to use new API endpoint and remove deprecated methods
✨ feat(lib.py): Remove redundant check for `binance_us` exchange
✨ fix(web_sockets.py): Adjust `ping_interval` for `binance` and `huobi`
✨ fix(web_sockets.py): Refactor message handling for `binance` events
✨ fix(requirements.txt): Upgrade `crypto-ws-api` to version 2.0.20
📝 docs(README.md): Update documentation regarding `Ed25519` API key for `Binance`
✨ chore(toml): Update `exch_srv_cfg.toml.template` with new API key requirements

Author: DogsTailFarmer

CHANGELOG.md

@@ -1,3 +1,15 @@
+## 2.1.34 2025-04-24
+🔧 fix(exchanges_wrapper): adjust return types for several functions to use 'list' and 'dict' annotations
+🔧 fix(exchanges_wrapper): ensure consistent return types in 'fetch_server_time' and 'get_symbols' functions
+🔧 fix(parsers): update 'orders', 'klines', and 'candle' functions in various parsers to use 'list' and 'dict' annotations
+✨ feat(client.py): Update `UserEventsDataStream` to use new API endpoint and remove deprecated methods  
+✨ feat(lib.py): Remove redundant check for `binance_us` exchange  
+✨ fix(web_sockets.py): Adjust `ping_interval` for `binance` and `huobi`  
+✨ fix(web_sockets.py): Refactor message handling for `binance` events  
+✨ fix(requirements.txt): Upgrade `crypto-ws-api` to version 2.0.20  
+📝 docs(README.md): Update documentation regarding `Ed25519` API key for `Binance`  
+✨ chore(toml): Update `exch_srv_cfg.toml.template` with new API key requirements  
+
 ## 2.1.33 2025-03-28
 ### Update
 * ✨ feat(requirements.txt): Update crypto-ws-api and aiohttp to latest versions.

README.md

@@ -12,7 +12,8 @@
 <a href="https://sonarcloud.io/summary/new_code?id=DogsTailFarmer_exchanges-wrapper" target="_blank"><img alt="sonarcloud" title="sonarcloud" src="https://sonarcloud.io/api/project_badges/measure?project=DogsTailFarmer_exchanges-wrapper&metric=alert_status"/></a>
 <a href="https://pepy.tech/project/exchanges-wrapper" target="_blank"><img alt="Downloads" title="Downloads" src="https://static.pepy.tech/badge/exchanges-wrapper/month"/></a>
 ***
-From `2.1.21` must be updated `exch_srv_cfg.toml` from `exchanges_wrapper/exch_srv_cfg.toml.template`
+On `Binance`: now API key type [Ed25519](https://www.binance.com/en/support/faq/detail/6b9a63f1e3384cf48a2eedb82767a69a) is used instead of `HMAC`
+From `2.1.34` must be updated `exch_srv_cfg.toml` from `exchanges_wrapper/exch_srv_cfg.toml.template`
 ***
 
 ## exchanges-wrapper vs [binance.py](https://github.com/Th0rgal/binance.py)
@@ -52,11 +53,13 @@ at real bidding. First, run applications on the [Binance Spot Test Network](http
 
 ## Get started
 ### Prepare exchange account
-* Create account on [Binance](https://accounts.binance.com/en/register?ref=FXQ6HY5O) and get 10% discount on all trading fee
-* Create account on [Bitfinex](https://www.bitfinex.com/sign-up?refcode=v_4az2nCP) and get 6% rebate fee
-* Create account on [HUOBI](https://www.huobi.com/en-us/topic/double-reward/?invite_code=9uaw3223) and get 10% cashback on all trading fee
-* Create account on [OKX](https://www.okx.com/join/2607649) and get Mystery Boxes worth up to $10,000
-* Create account on [Bybit](https://www.bybit.com/invite?ref=9KEW1K) and get exclusive referral rewards
+Create account on [Binance](https://accounts.binance.com/en/register?ref=FXQ6HY5O) and get 10% discount on all trading fee
+Create account on [HTX](https://www.htx.com/invite/en-us/1f?invite_code=9uaw3223) From every invitee, win a Mystery Box (up to 1,500 USDT) and 30% of their trading fees.
+Create account on [Bitfinex](https://www.bitfinex.com/sign-up?refcode=v_4az2nCP) and get 6% rebate fee
+Create account on [OKX](https://okx.com/join/2607649) and will be in for the chance to earn up to 100 USDT
+Create account on [Bybit](https://www.bybit.com/invite?ref=9KEW1K) and get exclusive referral rewards
+
+Also, you can start strategy on [Hetzner](https://hetzner.cloud/?ref=uFdrF8nsdGMc) cloud VPS only for 4.75 € per month
 
 * For test purpose log in at [Binance Spot Test Network](https://testnet.binance.vision/)
 * Create API Key

exchanges_wrapper/__init__.py

@@ -12,7 +12,7 @@
 __contact__ = "https://github.com/DogsTailFarmer"
 __email__ = "[email protected]"
 __credits__ = ["https://github.com/DanyaSWorlD"]
-__version__ = "2.1.33"
+__version__ = "2.1.34"
 
 from pathlib import Path
 import shutil

exchanges_wrapper/client.py

@@ -30,7 +30,6 @@
 logger = logging.getLogger(__name__)
 
 STATUS_TIMEOUT = 5  # sec, also use for lifetime limit for inactive order (Bitfinex) as 60 * STATUS_TIMEOUT
-USER_DATA_STREAM = "/api/v3/userDataStream"
 ORDER_ENDPOINT = "/api/v3/order"
 
 def fallback_warning(exchange, symbol=None):
@@ -161,7 +160,7 @@ async def start_user_events_listener(self, _trade_id, symbol):
         logger.info(f"Start '{self.exchange}' user events listener for {_trade_id}")
         user_data_stream = None
         if self.exchange == 'binance':
-            user_data_stream = await UserEventsDataStream(self, self.endpoint_ws_auth, self.exchange, _trade_id)
+            user_data_stream = UserEventsDataStream(self, self.endpoint_ws_api, self.exchange, _trade_id)
         elif self.exchange == 'bitfinex':
             user_data_stream = BfxPrivateEventsDataStream(self, self.endpoint_ws_auth, self.exchange, _trade_id)
         elif self.exchange == 'huobi':
@@ -185,7 +184,7 @@ async def start_user_events_listener(self, _trade_id, symbol):
                 if not timeout:
                     logger.warning(f"{self.exchange} user WSS start timeout reached for {_trade_id}")
                     break
-                await asyncio.sleep(0.05)
+                await asyncio.sleep(0.1)
 
     async def start_market_events_listener(self, _trade_id):
         _events = self.events.registered_streams.get(self.exchange, {}).get(_trade_id, set())
@@ -525,6 +524,7 @@ async def fetch_ledgers(self, symbol, limit=25):
                         self.ledgers_id.pop(0)
                     balances.append(i[_id])
             return balances
+        return None
 
     # https://github.com/binance/binance-spot-api-docs/blob/master/rest-api.md#recent-trades-list
     async def fetch_recent_trades_list(self, symbol, limit=500):
@@ -773,6 +773,7 @@ async def one_click_arrival_deposit(self, tx_id):
                 params=params,
                 signed=True,
             )
+        return None
 
     async def fetch_api_info(self):
         res, _ = await self.http.send_api_call("/v5/user/query-api", signed=True)
@@ -816,7 +817,6 @@ async def create_order(
                 trade_id,
                 "order.place",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -947,7 +947,6 @@ async def fetch_order(  # lgtm [py/similar-function]
                         trade_id,
                         "order.status",
                         _params=params,
-                        send_api_key=True,
                         _signed=True,
                     )
             if b_res is None:
@@ -1050,7 +1049,6 @@ async def cancel_order(  # lgtm [py/similar-function]
                 trade_id,
                 "order.cancel",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -1152,7 +1150,6 @@ async def cancel_all_orders(self, trade_id, symbol, receive_window=None):
                 trade_id,
                 "openOrders.cancelAll",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -1275,7 +1272,6 @@ async def fetch_open_orders(self, trade_id, symbol, receive_window=None, respons
                 trade_id,
                 "openOrders.status",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -1522,7 +1518,6 @@ async def fetch_account_information(self, trade_id, receive_window=None):
                 trade_id,
                 "account.status",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -1744,7 +1739,6 @@ async def fetch_account_trade_list(
                 trade_id,
                 "myTrades",
                 _params=params,
-                send_api_key=True,
                 _signed=True
             )
             if binance_res is None:
@@ -1839,25 +1833,3 @@ async def fetch_order_trade_list(self, trade_id, symbol, order_id):
         return b_res
 
     # endregion
-
-    # USER DATA STREAM ENDPOINTS
-
-    # https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md#create-a-listenkey
-    async def create_listen_key(self):
-        return await self.http.send_api_call(USER_DATA_STREAM, "POST")
-
-    # https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md#close-a-listenkey
-    async def keep_alive_listen_key(self, listen_key):
-        if not listen_key:
-            raise ValueError("This query requires a listen_key.")
-        return await self.http.send_api_call(
-            USER_DATA_STREAM, "PUT", params={"listenKey": listen_key}
-        )
-
-    # https://github.com/binance-exchange/binance-official-api-docs/blob/master/user-data-stream.md#close-a-listenkey
-    async def close_listen_key(self, listen_key):
-        if not listen_key:
-            raise ValueError("This query requires a listen_key.")
-        return await self.http.send_api_call(
-            USER_DATA_STREAM, "DELETE", params={"listenKey": listen_key}
-        )

exchanges_wrapper/exch_srv.py

@@ -12,6 +12,7 @@
 import traceback
 import asyncio
 import functools
+# noinspection PyPackageRequirements
 import ujson as json
 import logging.handlers
 from decimal import Decimal

exchanges_wrapper/exch_srv_cfg.toml.template

@@ -1,28 +1,17 @@
 # Parameters for exchanges-wrapper REST API Server exch_srv.py
 # Copyright © 2021-2025 Jerry Fedorenko aka VM
-# __version__ = "2.1.29"
+# __version__ = "2.1.34"
+
 # region endpoint
 [endpoint]
     [endpoint.binance]
         api_public = 'https://api.binance.com'
         api_auth = 'https://api.binance.com'
         ws_public = 'wss://stream.binance.com:9443'
-        ws_auth = 'wss://stream.binance.com:9443'
         api_test = 'https://testnet.binance.vision'
-        ws_test = 'wss://testnet.binance.vision/ws'
         ws_api = 'wss://ws-api.binance.com:443/ws-api/v3'
         ws_api_test = 'wss://testnet.binance.vision/ws-api/v3'
 
-    [endpoint.binance_us]
-        api_public = 'https://api.binance.us'
-        api_auth = 'https://api.binance.us'
-        ws_public = 'wss://stream.binance.us:9443'
-        ws_auth = 'wss://stream.binance.us:9443'
-        api_test = 'https://testnet.binance.vision'
-        ws_test = 'wss://testnet.binance.vision/ws'
-        ws_api = 'wss://ws-api.binance.us:443/ws-api/v3'
-        ws_api_test = 'wss://testnet.binance.vision/ws-api/v3'
-
     [endpoint.bitfinex]
         api_public = 'https://api-pub.bitfinex.com'
         api_auth = 'https://api.bitfinex.com'
@@ -58,35 +47,42 @@
 # endregion
 
 # region Binance.com accounts
+# How to Generate an Ed25519 Key Pair and Register then on Binance:
+# https://www.binance.com/en/support/faq/detail/6b9a63f1e3384cf48a2eedb82767a69a
 [[accounts]]
     exchange = 'binance'
     name = 'Demo - Binance'
-    api_key = '*********** Place API key there ************'
-    api_secret = '*********** Place secret API key there ************'
+    api_key = '*********** Place Ed25519 API key there ************'
+    api_secret = """
+-----BEGIN PRIVATE KEY-----
+*********** Place PRIVATE API key there ************
+-----END PRIVATE KEY-----
+"""
     test_net = true
 
 [[accounts]]
     exchange = 'binance'
     name = 'BinanceSub1'
-    api_key = '*********** Place API key there ************'
-    api_secret = '*********** Place secret API key there ************'
+    api_key = '*********** Place Ed25519 API key there ************'
+    api_secret = """
+-----BEGIN PRIVATE KEY-----
+*********** Place PRIVATE API key there ************
+-----END PRIVATE KEY-----
+"""
     test_net = false
 
 [[accounts]]
     exchange = 'binance'
     name = 'BinanceSub2'
-    api_key = '*********** Place API key there ************'
-    api_secret = '*********** Place secret API key there ************'
+    api_key = '*********** Place Ed25519 API key there ************'
+    api_secret = """
+-----BEGIN PRIVATE KEY-----
+*********** Place PRIVATE API key there ************
+-----END PRIVATE KEY-----
+"""
     master_email = '[email protected]'  # If set, 'BinanceSub1' use for collecting assets instead of Main
     test_net = false
 
-# Binance.us accounts
-[[accounts]]
-    exchange = 'binance_us'
-    name = 'Binance US'
-    api_key = '*********** Place API key there ************'
-    api_secret = '*********** Place secret API key there ************'
-    test_net = false
 # endregion
 
 # region Bitfinex accounts

exchanges_wrapper/http_client.py

@@ -45,7 +45,6 @@ def __init__(self, params: dict):
         self.rate_limit_handler = RateLimitHandler() if self.exchange == 'bybit' else None
 
     def declare_exchanges_implementation(self):
-        # noinspection PyTypeChecker
         self.ex_imps = {
         'binance': self._binance_request,
         'bitfinex': self._bitfinex_request,

exchanges_wrapper/lib.py

@@ -77,9 +77,6 @@ def get_account(account_name: str) -> dict:
             ws_public = get_ws_public(endpoint, exchange, test_net)
             ws_api, ws_auth = get_ws_api_auth(endpoint, exchange, test_net)
 
-            if exchange == 'binance_us':
-                exchange = 'binance'
-
             return {
                 'exchange': exchange,
                 'sub_account': sub_account,
@@ -96,7 +93,7 @@ def get_account(account_name: str) -> dict:
                 'master_name': master_name,
                 'two_fa': account.get('two_fa'),
                 'ws_api': ws_api,
-            }
+           }
     return {}
 
 def get_ws_add_on(endpoint, exchange):
@@ -118,7 +115,7 @@ def get_ws_api_auth(endpoint, exchange, test_net):
     if exchange == 'bitfinex':
         ws_api = ws_auth = endpoint['ws_auth']
     else:
-        ws_auth = endpoint['ws_test'] if test_net else endpoint['ws_auth']
+        ws_auth = endpoint.get('ws_test') if test_net else endpoint.get('ws_auth')
         ws_api = endpoint.get('ws_api_test') if test_net else endpoint.get('ws_api')
         if exchange == 'okx':
             ws_api = ws_auth