diff --git a/freqtrade/rpc/api_server/ws/__init__.py b/freqtrade/rpc/api_server/ws/__init__.py index c00d29e22..055b20a9d 100644 --- a/freqtrade/rpc/api_server/ws/__init__.py +++ b/freqtrade/rpc/api_server/ws/__init__.py @@ -2,5 +2,5 @@ # isort: off from freqtrade.rpc.api_server.ws.types import WebSocketType from freqtrade.rpc.api_server.ws.proxy import WebSocketProxy -from freqtrade.rpc.api_server.ws.serializer import HybridJSONWebSocketSerializer, MsgPackWebSocketSerializer +from freqtrade.rpc.api_server.ws.serializer import HybridJSONWebSocketSerializer from freqtrade.rpc.api_server.ws.channel import ChannelManager, WebSocketChannel diff --git a/freqtrade/rpc/api_server/ws/serializer.py b/freqtrade/rpc/api_server/ws/serializer.py index 22d177f85..6c402a100 100644 --- a/freqtrade/rpc/api_server/ws/serializer.py +++ b/freqtrade/rpc/api_server/ws/serializer.py @@ -1,7 +1,6 @@ import logging from abc import ABC, abstractmethod -import msgpack import orjson import rapidjson from pandas import DataFrame @@ -46,14 +45,6 @@ class HybridJSONWebSocketSerializer(WebSocketSerializer): return rapidjson.loads(data, object_hook=_json_object_hook) -class MsgPackWebSocketSerializer(WebSocketSerializer): - def _serialize(self, data): - return msgpack.packb(data, use_bin_type=True) - - def _deserialize(self, data): - return msgpack.unpackb(data, raw=False) - - # Support serializing pandas DataFrames def _json_default(z): if isinstance(z, DataFrame): diff --git a/requirements.txt b/requirements.txt index 1ace139ee..1579ef55c 100644 --- a/requirements.txt +++ b/requirements.txt @@ -52,6 +52,5 @@ python-dateutil==2.8.2 schedule==1.1.0 #WS Messages -websockets~=10.3 -msgpack~=1.0.4 +websockets==10.3 janus==1.0.0 diff --git a/setup.py b/setup.py index c7b1f1c7c..2e6e354b0 100644 --- a/setup.py +++ b/setup.py @@ -81,7 +81,6 @@ setup( 'aiofiles', 'schedule', 'websockets', - 'msgpack', 'janus' ], extras_require={