mirror.MikroTik/tomaae.homeassistant-mikrotik_router
1
0
Fork 0
mirror of https://github.com/tomaae/homeassistant-mikrotik_router.git synced 2025-07-09 17:04:29 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

api, limit reconnect attempts to once per minute #7

Browse source
This commit is contained in:
tomaae 2019-12-21 07:57:20 +01:00
parent 26d523c035
commit 9c144d7ade
1 changed files with 16 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

16
custom_components/mikrotik_router/mikrotikapi.py
View file

@ -4,6 +4,7 @@ import ssl
import logging import logging
import os import os
import sys import sys
import time
import importlib import importlib
from threading import Lock from threading import Lock
from .exceptions import ApiEntryNotFound from .exceptions import ApiEntryNotFound
@ -42,6 +43,8 @@ class MikrotikAPI:
self._connection = None self._connection = None
self._connected = False self._connected = False
self._connection_epoch = 0
self._connection_retry_sec = 58
self.error = None self.error = None
# Default ports # Default ports
@ -55,6 +58,7 @@ class MikrotikAPI:
"""Connect to Mikrotik device.""" """Connect to Mikrotik device."""
self.error = "" self.error = ""
self._connected = None self._connected = None
self._connection_epoch = time.time()
kwargs = { kwargs = {
"encoding": self._encoding, "encoding": self._encoding,
@ -124,6 +128,9 @@ class MikrotikAPI:
def path(self, path) -> list: def path(self, path) -> list:
"""Retrieve data from Mikrotik API.""" """Retrieve data from Mikrotik API."""
if not self._connected or not self._connection: if not self._connected or not self._connection:
if self._connection_epoch > time.time() - self._connection_retry_sec:
return None
if not self.connect(): if not self.connect():
return None return None
@ -167,6 +174,9 @@ class MikrotikAPI:
"""Modify a parameter""" """Modify a parameter"""
entry_found = False entry_found = False
if not self._connected or not self._connection: if not self._connected or not self._connection:
if self._connection_epoch > time.time() - self._connection_retry_sec:
return None
if not self.connect(): if not self.connect():
return False return False
@ -229,6 +239,9 @@ class MikrotikAPI:
"""Run script""" """Run script"""
entry_found = False entry_found = False
if not self._connected or not self._connection: if not self._connected or not self._connection:
if self._connection_epoch > time.time() - self._connection_retry_sec:
return None
if not self.connect(): if not self.connect():
return False return False
@ -287,6 +300,9 @@ class MikrotikAPI:
"""Get traffic stats""" """Get traffic stats"""
traffic = None traffic = None
if not self._connected or not self._connection: if not self._connected or not self._connection:
if self._connection_epoch > time.time() - self._connection_retry_sec:
return None
if not self.connect(): if not self.connect():
return None return None