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

Change wss_timeout type from int to float.

Browse Source
This commit is contained in:
Davide Casale
2023-04-19 03:29:45 +02:00
parent e15b52eabd
commit 986aa525d7
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bfxapi/client.py
View File

@@ -13,7 +13,7 @@ class Client:
*,
rest_host: str = REST_HOST,
wss_host: str = WSS_HOST,
wss_timeout: int = 60 * 15,
wss_timeout: float = 60 * 15,
log_filename: Optional[str] = None,
log_level: str = "INFO"
):

14
bfxapi/websocket/client/bfx_websocket_client.py
View File

@@ -103,15 +103,15 @@ class BfxWebsocketClient:
async def __connect(self):
Reconnection = namedtuple("Reconnection", ["status", "attempts", "timestamp"])
reconnection = Reconnection(status=False, attempts=0, timestamp=None)
delay, timer, tasks = None, None, []
delay = _Delay(backoff_factor=1.618)
timer, tasks, on_timeout_event = None, [], asyncio.locks.Event()
on_timeout_event = asyncio.locks.Event()
def _on_timeout():
def _on_wss_timeout():
on_timeout_event.set()
raise ReconnectionTimeoutError("Connection has been offline for too long " \
f"without being able to reconnect (wss_timeout is set to {self.wss_timeout}s).")
f"without being able to reconnect (wss_timeout: {self.wss_timeout}s).")
async def _connection():
nonlocal reconnection, timer, tasks
@@ -191,8 +191,8 @@ class BfxWebsocketClient:
task.cancel()
reconnection = Reconnection(status=True, attempts=1, timestamp=datetime.now())
timer = asyncio.get_event_loop().call_later(self.wss_timeout, _on_timeout)
delay = _Delay(backoff_factor=1.618)
timer = asyncio.get_event_loop().call_later(self.wss_timeout, _on_wss_timeout)
elif isinstance(error, socket.gaierror) and reconnection.status:
self.logger.warning(f"Reconnection attempt no.{reconnection.attempts} has failed. " \
f"Next reconnection attempt in ~{round(delay.peek()):.1f} seconds. (at the moment " \