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

Remove wss-event event from BfxWebSocketClient and BfxWebSocketBucket.

Browse Source
This commit is contained in:
Davide Casale
2023-10-13 17:38:25 +02:00
parent 374b632c6c
commit e5ec94b757
9 changed files with 13 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
bfxapi/websocket/_client/bfx_websocket_bucket.py
View File

@@ -64,9 +64,6 @@ class BfxWebSocketBucket(Connection):
chan_id = cast(int, message["chan_id"]) chan_id = cast(int, message["chan_id"])
del self.__subscriptions[chan_id] del self.__subscriptions[chan_id]
elif message["event"] == "error":
self.__event_emitter.emit("wss-error", \
message["code"], message["msg"])
if isinstance(message, list): if isinstance(message, list):
if (chan_id := cast(int, message[0])) and \ if (chan_id := cast(int, message[0])) and \

3
bfxapi/websocket/_client/bfx_websocket_client.py
View File

@@ -240,9 +240,6 @@ class BfxWebSocketClient(Connection):
self.__event_emitter.emit("authenticated", message) self.__event_emitter.emit("authenticated", message)
self._authentication = True self._authentication = True
elif message["event"] == "error":
self.__event_emitter.emit("wss-error", \
message["code"], message["msg"])
if isinstance(message, list) and \ if isinstance(message, list) and \
message[0] == 0 and message[1] != Connection._HEARTBEAT: message[0] == 0 and message[1] != Connection._HEARTBEAT:

27
bfxapi/websocket/_event_emitter/bfx_event_emitter.py
View File

@@ -21,20 +21,19 @@ _ONCE_PER_SUBSCRIPTION = [
] ]
_COMMON = [ _COMMON = [
"error", "wss-error", "disconnected", "error", "disconnected", "t_ticker_update",
"t_ticker_update", "f_ticker_update", "t_trade_execution", "f_ticker_update", "t_trade_execution", "t_trade_execution_update",
"t_trade_execution_update", "f_trade_execution", "f_trade_execution_update", "f_trade_execution", "f_trade_execution_update", "t_book_update",
"t_book_update", "f_book_update", "t_raw_book_update", "f_book_update", "t_raw_book_update", "f_raw_book_update",
"f_raw_book_update", "candles_update", "derivatives_status_update", "candles_update", "derivatives_status_update", "liquidation_feed_update",
"liquidation_feed_update", "order_new", "order_update", "order_new", "order_update", "order_cancel",
"order_cancel", "position_new", "position_update", "position_new", "position_update", "position_close",
"position_close", "funding_offer_new", "funding_offer_update", "funding_offer_new", "funding_offer_update", "funding_offer_cancel",
"funding_offer_cancel", "funding_credit_new", "funding_credit_update", "funding_credit_new", "funding_credit_update", "funding_credit_close",
"funding_credit_close", "funding_loan_new", "funding_loan_update", "funding_loan_new", "funding_loan_update", "funding_loan_close",
"funding_loan_close", "trade_execution", "trade_execution_update", "trade_execution", "trade_execution_update", "wallet_update",
"wallet_update", "notification", "on-req-notification", "notification", "on-req-notification", "ou-req-notification",
"ou-req-notification", "oc-req-notification", "fon-req-notification", "oc-req-notification", "fon-req-notification", "foc-req-notification"
"foc-req-notification"
] ]
class BfxEventEmitter(AsyncIOEventEmitter): class BfxEventEmitter(AsyncIOEventEmitter):

4
examples/websocket/auth/submit_order.py
View File

@@ -12,10 +12,6 @@ bfx = Client(
api_secret=os.getenv("BFX_API_SECRET") api_secret=os.getenv("BFX_API_SECRET")
) )
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("authenticated") @bfx.wss.on("authenticated")
async def on_authenticated(event): async def on_authenticated(event):
print(f"Authentication: {event}") print(f"Authentication: {event}")

4
examples/websocket/auth/wallets.py
View File

@@ -14,10 +14,6 @@ bfx = Client(
filters=["wallet"] filters=["wallet"]
) )
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("wallet_snapshot") @bfx.wss.on("wallet_snapshot")
def on_wallet_snapshot(wallets: List[Wallet]): def on_wallet_snapshot(wallets: List[Wallet]):
for wallet in wallets: for wallet in wallets:

4
examples/websocket/public/derivatives_status.py
View File

@@ -12,10 +12,6 @@ bfx = Client(wss_host=PUB_WSS_HOST)
def on_derivatives_status_update(subscription: Status, data: DerivativesStatus): def on_derivatives_status_update(subscription: Status, data: DerivativesStatus):
print(f"{subscription}:", data) print(f"{subscription}:", data)
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("open") @bfx.wss.on("open")
async def on_open(): async def on_open():
await bfx.wss.subscribe(Channel.STATUS, key="deriv:tBTCF0:USTF0") await bfx.wss.subscribe(Channel.STATUS, key="deriv:tBTCF0:USTF0")

4
examples/websocket/public/order_book.py
View File

@@ -70,10 +70,6 @@ order_book = OrderBook(symbols=SYMBOLS)
bfx = Client(wss_host=PUB_WSS_HOST) bfx = Client(wss_host=PUB_WSS_HOST)
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("open") @bfx.wss.on("open")
async def on_open(): async def on_open():
for symbol in SYMBOLS: for symbol in SYMBOLS:

4
examples/websocket/public/raw_order_book.py
View File

@@ -70,10 +70,6 @@ raw_order_book = RawOrderBook(symbols=SYMBOLS)
bfx = Client(wss_host=PUB_WSS_HOST) bfx = Client(wss_host=PUB_WSS_HOST)
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("open") @bfx.wss.on("open")
async def on_open(): async def on_open():
for symbol in SYMBOLS: for symbol in SYMBOLS:

4
examples/websocket/public/trades.py
View File

@@ -16,10 +16,6 @@ def on_candles_update(_sub: Candles, candle: Candle):
def on_t_trade_execution(_sub: Trades, trade: TradingPairTrade): def on_t_trade_execution(_sub: Trades, trade: TradingPairTrade):
print(f"New trade: {trade}") print(f"New trade: {trade}")
@bfx.wss.on("wss-error")
def on_wss_error(code: Error, msg: str):
print(code, msg)
@bfx.wss.on("open") @bfx.wss.on("open")
async def on_open(): async def on_open():
await bfx.wss.subscribe(Channel.CANDLES, key="trade:1m:tBTCUSD") await bfx.wss.subscribe(Channel.CANDLES, key="trade:1m:tBTCUSD")