Remove msgpack for now

This commit is contained in:
Matthias 2022-09-20 06:55:22 +02:00
parent 4422ac7f45
commit 3274bb0751
4 changed files with 2 additions and 13 deletions

View File

@ -2,5 +2,5 @@
# isort: off # isort: off
from freqtrade.rpc.api_server.ws.types import WebSocketType from freqtrade.rpc.api_server.ws.types import WebSocketType
from freqtrade.rpc.api_server.ws.proxy import WebSocketProxy 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 from freqtrade.rpc.api_server.ws.channel import ChannelManager, WebSocketChannel

View File

@ -1,7 +1,6 @@
import logging import logging
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
import msgpack
import orjson import orjson
import rapidjson import rapidjson
from pandas import DataFrame from pandas import DataFrame
@ -46,14 +45,6 @@ class HybridJSONWebSocketSerializer(WebSocketSerializer):
return rapidjson.loads(data, object_hook=_json_object_hook) 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 # Support serializing pandas DataFrames
def _json_default(z): def _json_default(z):
if isinstance(z, DataFrame): if isinstance(z, DataFrame):

View File

@ -52,6 +52,5 @@ python-dateutil==2.8.2
schedule==1.1.0 schedule==1.1.0
#WS Messages #WS Messages
websockets~=10.3 websockets==10.3
msgpack~=1.0.4
janus==1.0.0 janus==1.0.0

View File

@ -81,7 +81,6 @@ setup(
'aiofiles', 'aiofiles',
'schedule', 'schedule',
'websockets', 'websockets',
'msgpack',
'janus' 'janus'
], ],
extras_require={ extras_require={