From 7f47405fa36b092cb5be040ed0f4cce4c6c8b57d Mon Sep 17 00:00:00 2001
From: itsdeka <dario.moceri@bitfinex.com>
Date: Mon, 20 Dec 2021 12:17:27 +0100
Subject: [PATCH] Fixed socket.send() issue (IndexError: deque index out of
 range)

---
 CHANGELOG                          |  3 +++
 bfxapi/utils/decorators.py         | 12 ++++++++++++
 bfxapi/version.py                  |  2 +-
 bfxapi/websockets/bfx_websocket.py |  4 ++++
 setup.py                           |  2 +-
 5 files changed, 21 insertions(+), 2 deletions(-)
 create mode 100644 bfxapi/utils/decorators.py

diff --git a/CHANGELOG b/CHANGELOG
index d983ec4..5f5e657 100644
--- a/CHANGELOG
+++ b/CHANGELOG
@@ -1,3 +1,6 @@
+1.3.3
+-) Fixed socket.send() issue (IndexError: deque index out of range)
+
 1.3.2
 -) Implemented Merchants endpoints (REST)
 
diff --git a/bfxapi/utils/decorators.py b/bfxapi/utils/decorators.py
new file mode 100644
index 0000000..b226edc
--- /dev/null
+++ b/bfxapi/utils/decorators.py
@@ -0,0 +1,12 @@
+from ..utils.custom_logger import CustomLogger
+
+
+def handle_failure(func):
+    def inner_function(*args, **kwargs):
+        logger = CustomLogger('BfxWebsocket', logLevel="DEBUG")
+        try:
+            func(*args, **kwargs)
+        except Exception as exception_message:
+            logger.error(exception_message)
+
+    return inner_function
diff --git a/bfxapi/version.py b/bfxapi/version.py
index 51534a7..85f1fa2 100644
--- a/bfxapi/version.py
+++ b/bfxapi/version.py
@@ -2,4 +2,4 @@
 This module contains the current version of the bfxapi lib
 """
 
-__version__ = '1.3.2'
+__version__ = '1.3.3'
diff --git a/bfxapi/websockets/bfx_websocket.py b/bfxapi/websockets/bfx_websocket.py
index 49febc5..ce5660e 100644
--- a/bfxapi/websockets/bfx_websocket.py
+++ b/bfxapi/websockets/bfx_websocket.py
@@ -12,6 +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 ..utils.decorators import handle_failure
 from ..models import Order, Trade, OrderBook, Ticker, FundingTicker
 
 
@@ -481,6 +482,7 @@ class BfxWebsocket(GenericWebsocket):
         else:
             self.logger.warn('Unknown (socketId={}) websocket response: {}'.format(socketId, msg))
 
+    @handle_failure
     async def _ws_authenticate_socket(self, socketId):
         socket = self.sockets[socketId]
         socket.set_authenticated()
@@ -507,6 +509,7 @@ class BfxWebsocket(GenericWebsocket):
         # re-subscribe to existing channels
         await self.subscriptionManager.resubscribe_by_socket(socket_id)
 
+    @handle_failure
     async def _send_auth_command(self, channel_name, data):
         payload = [0, channel_name, None, data]
         socket = self.get_authenticated_socket()
@@ -538,6 +541,7 @@ class BfxWebsocket(GenericWebsocket):
             total += self.get_socket_capacity(socketId)
         return total
 
+    @handle_failure
     async def enable_flag(self, flag):
         """
         Enable flag on websocket connection
diff --git a/setup.py b/setup.py
index 3444a25..32fad42 100644
--- a/setup.py
+++ b/setup.py
@@ -11,7 +11,7 @@ from os import path
 here = path.abspath(path.dirname(__file__))
 setup(
     name='bitfinex-api-py',
-    version='1.3.2',
+    version='1.3.3',
     description='Official Bitfinex Python API',
     long_description='A Python reference implementation of the Bitfinex API for both REST and websocket interaction',
     long_description_content_type='text/markdown',