aljaz/bitfinex-api-py
1
0
Fork 0
mirror of https://github.com/aljazceru/bitfinex-api-py.git synced 2025-12-20 07:14:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

bfxapi: add ticker event updates

Browse Source
This commit is contained in:
JacobPlaster
2020-04-14 16:05:02 +01:00
committed by Jacob Plaster
parent 41407d4668
commit 4273a9e7f9
5 changed files with 199 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
bfxapi/websockets/bfx_websocket.py
View File

@@ -12,7 +12,7 @@ from .subscription_manager import SubscriptionManager
from .wallet_manager import WalletManager
from .order_manager import OrderManager
from ..utils.auth import generate_auth_payload
from ..models import Order, Trade, OrderBook
from ..models import Order, Trade, OrderBook, Ticker, FundingTicker
class Flags:
@@ -218,6 +218,8 @@ class BfxWebsocket(GenericWebsocket):
await self._trade_handler(data)
if subscription.channel_name == 'status':
await self._status_handler(data)
if subscription.channel_name == 'ticker':
await self._ticker_handler(data)
else:
self.logger.warn(
"Unknown data event: '{}' {}".format(dataEvent, data))
@@ -356,6 +358,17 @@ class BfxWebsocket(GenericWebsocket):
else:
self.logger.warn('Unknown status data type: {}'.format(data))
async def _ticker_handler(self, data):
symbol = self.subscriptionManager.get(data[0]).symbol
if type(data[1]) is list:
raw_ticker = data[1]
t = None
if len(raw_ticker) == 10:
t = Ticker.from_raw_ticker(raw_ticker, symbol)
else:
t = FundingTicker.from_raw_ticker(raw_ticker, symbol)
self._emit('new_ticker', t)
async def _trade_handler(self, data):
symbol = self.subscriptionManager.get(data[0]).symbol
if type(data[1]) is list: