From 9e8bea905a6038cc8179018a61abb77499ab1c51 Mon Sep 17 00:00:00 2001
From: Davide Casale <davidecasale2002@gmail.com>
Date: Mon, 28 Nov 2022 16:50:07 +0100
Subject: [PATCH] Rename .chanIds field in _BfxWebsocketBucket to
 .subscriptions.

---
 bfxapi/websocket/BfxWebsocketClient.py | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/bfxapi/websocket/BfxWebsocketClient.py b/bfxapi/websocket/BfxWebsocketClient.py
index 5800f72..14c3bb0 100644
--- a/bfxapi/websocket/BfxWebsocketClient.py
+++ b/bfxapi/websocket/BfxWebsocketClient.py
@@ -86,7 +86,7 @@ class BfxWebsocketClient(object):
         await self.websocket.send(json.dumps(data))
 
     async def subscribe(self, channel, **kwargs):
-        counters = [ len(bucket.pendings) + len(bucket.chanIds) for bucket in self.buckets ]
+        counters = [ len(bucket.pendings) + len(bucket.subscriptions) for bucket in self.buckets ]
 
         index = counters.index(min(counters))
 
@@ -94,7 +94,7 @@ class BfxWebsocketClient(object):
 
     async def unsubscribe(self, chanId):
         for bucket in self.buckets:
-            if chanId in bucket.chanIds.keys():
+            if chanId in bucket.subscriptions.keys():
                 await bucket._unsubscribe(chanId=chanId)
 
     async def close(self, code=1000, reason=str()):
@@ -149,7 +149,7 @@ class _BfxWebsocketBucket(object):
     def __init__(self, host, event_emitter, __bucket_open_signal):
         self.host, self.event_emitter, self.__bucket_open_signal = host, event_emitter, __bucket_open_signal
 
-        self.websocket, self.chanIds, self.pendings = None, dict(), list()
+        self.websocket, self.subscriptions, self.pendings = None, dict(), list()
 
         self.handler = PublicChannelsHandler(event_emitter=self.event_emitter)
 
@@ -168,21 +168,21 @@ class _BfxWebsocketBucket(object):
                             raise OutdatedClientVersion(f"Mismatch between the client version and the server version. Update the library to the latest version to continue (client version: {BfxWebsocketClient.VERSION}, server version: {message['version']}).")
                     elif isinstance(message, dict) and message["event"] == "subscribed" and (chanId := message["chanId"]):
                         self.pendings = [ pending for pending in self.pendings if pending["subId"] != message["subId"] ]
-                        self.chanIds[chanId] = message
+                        self.subscriptions[chanId] = message
                         self.event_emitter.emit("subscribed", message)
                     elif isinstance(message, dict) and message["event"] == "unsubscribed" and (chanId := message["chanId"]):
                         if message["status"] == "OK":
-                            del self.chanIds[chanId]
+                            del self.subscriptions[chanId]
                     elif isinstance(message, dict) and message["event"] == "error":
                         self.event_emitter.emit("wss-error", message["code"], message["msg"])
                     elif isinstance(message, list) and (chanId := message[0]) and message[1] != _HEARTBEAT:
-                        self.handler.handle(self.chanIds[chanId], *message[1:])
+                        self.handler.handle(self.subscriptions[chanId], *message[1:])
             except websockets.ConnectionClosedError: continue
             finally: await self.websocket.wait_closed(); break
 
     @_require_websocket_connection
     async def _subscribe(self, channel, subId=None, **kwargs):
-        if len(self.chanIds) + len(self.pendings) == _BfxWebsocketBucket.MAXIMUM_SUBSCRIPTIONS_AMOUNT:
+        if len(self.subscriptions) + len(self.pendings) == _BfxWebsocketBucket.MAXIMUM_SUBSCRIPTIONS_AMOUNT:
             raise TooManySubscriptions("The client has reached the maximum number of subscriptions.")
 
         subscription = {