Support Websockets API #8
Conversation
* Support sandbox mode * Add DEMO BASE Url * Add DEMO BASE wss Url
|
Wow! That's amazing. @radovsky1 I am so thankful to you. I wanted to add this functionality for so long but was pretty busy with full time job. I am so inspired by your PR. Will review it shortly |
| @@ -18,13 +19,13 @@ def test_not_called(self): | |||
| def test_get_server_time(self, monkeypatch): | |||
| self.client.get_server_time() | |||
| self.mock_requests.assert_called_once_with( | |||
| CurrencyComConstants.SERVER_TIME_ENDPOINT | |||
There was a problem hiding this comment.
Tests do not pass. You should pass constants as an object not a class.
It would be better to replace CurrencyComConstants with self.client.constants
| class NewOrderResponseType(Enum): | ||
| ACK = 'ACK' | ||
| RESULT = 'RESULT' | ||
| FULL = 'FULL' | ||
|
|
||
|
|
||
| class Client(object): | ||
| class CurrencycomClient: |
There was a problem hiding this comment.
To avoid breaking anyone who works with this API I would add Client inherited by CurrencycomClient with deprication warning
|
|
||
| def _get_reconnect_wait(self, attempts): | ||
| expo = 2 ** attempts | ||
| return round(random() * min(self.MAX_RECONNECT_SECONDS, expo - 1) + 1) |
| self._conn = None | ||
| self._connect_id = None | ||
| self._socket = None | ||
| self._request = { |
There was a problem hiding this comment.
Let's move this var to send_message as it shouldn't be stored across the object
| @@ -0,0 +1,241 @@ | |||
| import asyncio | |||
There was a problem hiding this comment.
Let's avoid adding packages with the same name as default asyncio package
After using the library for a long time, I came to the conclusion that Websocket support is needed to ensure updating of market data, depth market data, OHLC data and so on.
Implemented CurrencycomHybridClient to support REST API as well as Websockets subscribtions.