1.4.5

CHANGELOG.md

@@ -1,3 +1,11 @@
+## v1.4.5 2024-01-05
+### Fix
+* `exch_client.py` init error
+
+### Update
+* replacing json with ujson to improve performance
+* Dependency: Up requirements for crypto-ws-api==2.0.6
+
 ## v1.4.4 2023-12-13
 ### Update
 * Before send cancel order result checking if it was be executed and generating trade event

exchanges_wrapper/__init__.py

@@ -12,7 +12,7 @@
 __contact__ = "https://github.com/DogsTailFarmer"
 __email__ = "jerry.fedorenko@yahoo.com"
 __credits__ = ["https://github.com/DanyaSWorlD"]
-__version__ = "1.4.4"
+__version__ = "1.4.5"
 
 from pathlib import Path
 import shutil

exchanges_wrapper/exch_srv.py

@@ -7,7 +7,7 @@
 import traceback
 import asyncio
 import functools
-import json
+import ujson as json
 import logging.handlers
 import toml
 # noinspection PyPackageRequirements
@@ -579,20 +579,21 @@ async def OnKlinesUpdate(self, request: api_pb2.FetchKlinesRequest,
                 # logger.info(f"OnKlinesUpdate.event: {exchange}:{_event.symbol}:{_event.kline_interval}")
                 response.symbol = _event.symbol
                 response.interval = _event.kline_interval
-                candle = [_event.kline_start_time,
-                          _event.kline_open_price,
-                          _event.kline_high_price,
-                          _event.kline_low_price,
-                          _event.kline_close_price,
-                          _event.kline_base_asset_volume,
-                          _event.kline_close_time,
-                          _event.kline_quote_asset_volume,
-                          _event.kline_trades_number,
-                          _event.kline_taker_buy_base_asset_volume,
-                          _event.kline_taker_buy_quote_asset_volume,
-                          _event.kline_ignore
-                          ]
-                response.candle = json.dumps(candle)
+                response.candle = json.dumps(
+                    [_event.kline_start_time,
+                     _event.kline_open_price,
+                     _event.kline_high_price,
+                     _event.kline_low_price,
+                     _event.kline_close_price,
+                     _event.kline_base_asset_volume,
+                     _event.kline_close_time,
+                     _event.kline_quote_asset_volume,
+                     _event.kline_trades_number,
+                     _event.kline_taker_buy_base_asset_volume,
+                     _event.kline_taker_buy_quote_asset_volume,
+                     _event.kline_ignore
+                     ]
+                )
                 yield response
                 _queue.task_done()
 

exchanges_wrapper/http_client.py

@@ -1,5 +1,5 @@
 import asyncio
-import json
+import ujson as json
 from urllib.parse import urlencode, urlparse
 
 import aiohttp

exchanges_wrapper/web_sockets.py

@@ -1,6 +1,6 @@
 import sys
 import asyncio
-import json
+import ujson as json
 import logging
 import time
 from decimal import Decimal

pyproject.toml

@@ -17,7 +17,7 @@ dynamic = ["version", "description"]
 requires-python = ">=3.8"
 
 dependencies = [
-    "crypto-ws-api==2.0.5.post3",
+    "crypto-ws-api==2.0.6",
     "grpcio==1.48.2",
     "grpcio-tools==1.48.2",
     "idna==3.4",
@@ -26,7 +26,8 @@ dependencies = [
     "aiohttp==3.9.0",
     "Pympler~=1.0.1",
     "websockets~=12.0",
-    "expiringdict~=1.2.2"
+    "expiringdict~=1.2.2",
+    "ujson~=5.9.0"
 ]
 
 [tool.flit.module]

requirements.txt

@@ -1,4 +1,4 @@
-crypto-ws-api==2.0.5.post3
+crypto-ws-api==2.0.6
 grpcio==1.48.2
 grpcio-tools==1.48.2
 idna==3.4
@@ -8,4 +8,5 @@ toml~=0.10.2
 aiohttp==3.9.0
 Pympler~=1.0.1
 websockets==12.0
-expiringdict~=1.2.2
+expiringdict~=1.2.2
+ujson~=5.9.0