From 4edbf5d44c94bcba99b92163c1beb9aa415dacfa Mon Sep 17 00:00:00 2001 From: Davide Casale Date: Thu, 20 Apr 2023 01:43:44 +0200 Subject: [PATCH] Change event trade_executed to trade_execution (and update references). --- bfxapi/websocket/handlers/authenticated_events_handler.py | 2 +- bfxapi/websocket/handlers/public_channels_handler.py | 8 ++++---- examples/websocket/public/trades.py | 4 ++-- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/bfxapi/websocket/handlers/authenticated_events_handler.py b/bfxapi/websocket/handlers/authenticated_events_handler.py index 289fe60..cf098a3 100644 --- a/bfxapi/websocket/handlers/authenticated_events_handler.py +++ b/bfxapi/websocket/handlers/authenticated_events_handler.py @@ -16,7 +16,7 @@ class AuthenticatedEventsHandler: "fon": "funding_offer_new", "fou": "funding_offer_update", "foc": "funding_offer_cancel", "fcn": "funding_credit_new", "fcu": "funding_credit_update", "fcc": "funding_credit_close", "fln": "funding_loan_new", "flu": "funding_loan_update", "flc": "funding_loan_close", - "te": "trade_executed", "tu": "trade_execution_update", "wu": "wallet_update", + "te": "trade_execution", "tu": "trade_execution_update", "wu": "wallet_update", "bu": "balance_update" } diff --git a/bfxapi/websocket/handlers/public_channels_handler.py b/bfxapi/websocket/handlers/public_channels_handler.py index 86c3376..e8cfaad 100644 --- a/bfxapi/websocket/handlers/public_channels_handler.py +++ b/bfxapi/websocket/handlers/public_channels_handler.py @@ -11,8 +11,8 @@ class PublicChannelsHandler: EVENTS = [ *ONCE_PER_SUBSCRIPTION_EVENTS, - "t_ticker_update", "f_ticker_update", "t_trade_executed", - "t_trade_execution_update", "f_trade_executed", "f_trade_execution_update", + "t_ticker_update", "f_ticker_update", "t_trade_execution", + "t_trade_execution_update", "f_trade_execution", "f_trade_execution_update", "t_book_update", "f_book_update", "t_raw_book_update", "f_raw_book_update", "candles_update", "derivatives_status_update" ] @@ -71,14 +71,14 @@ class PublicChannelsHandler: if (event := stream[0]) and event in [ "te", "tu", "fte", "ftu" ]: if subscription["symbol"].startswith("t"): return self.__emit( - { "te": "t_trade_executed", "tu": "t_trade_execution_update" }[event], + { "te": "t_trade_execution", "tu": "t_trade_execution_update" }[event], subscription, serializers.TradingPairTrade.parse(*stream[1]) ) if subscription["symbol"].startswith("f"): return self.__emit( - { "fte": "f_trade_executed", "ftu": "f_trade_execution_update" }[event], + { "fte": "f_trade_execution", "ftu": "f_trade_execution_update" }[event], subscription, serializers.FundingCurrencyTrade.parse(*stream[1]) ) diff --git a/examples/websocket/public/trades.py b/examples/websocket/public/trades.py index 0495ba0..1159ab4 100644 --- a/examples/websocket/public/trades.py +++ b/examples/websocket/public/trades.py @@ -12,8 +12,8 @@ bfx = Client(wss_host=PUB_WSS_HOST) def on_candles_update(_sub: subscriptions.Candles, candle: Candle): print(f"New candle: {candle}") -@bfx.wss.on("t_trade_executed") -def on_t_trade_executed(_sub: subscriptions.Trades, trade: TradingPairTrade): +@bfx.wss.on("t_trade_execution") +def on_t_trade_execution(_sub: subscriptions.Trades, trade: TradingPairTrade): print(f"New trade: {trade}") @bfx.wss.on("wss-error")