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

do not continue update after disconnect, wait for next update run

Browse source
This commit is contained in:
tomaae 2020-04-13 07:50:06 +02:00
parent 19e7174446
commit 8a3af96fee
1 changed files with 50 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

72
custom_components/mikrotik_router/mikrotik_controller.py
View file

@ -249,15 +249,25 @@ class MikrotikControllerData:
except: except:
return return
_LOGGER.warning("Running async_hwinfo_update")
await self.hass.async_add_executor_job(self.get_capabilities) await self.hass.async_add_executor_job(self.get_capabilities)
await self.hass.async_add_executor_job(self.get_system_routerboard) if self.api.connected():
await self.hass.async_add_executor_job(self.get_system_resource) await self.hass.async_add_executor_job(self.get_system_routerboard)
await self.hass.async_add_executor_job(self.get_script)
await self.hass.async_add_executor_job(self.get_dhcp_network) if self.api.connected():
await self.hass.async_add_executor_job(self.get_dns) await self.hass.async_add_executor_job(self.get_system_resource)
await self.hass.async_add_executor_job(self.get_queue)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_script)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_dhcp_network)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_dns)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_queue)
self.lock.release() self.lock.release()
# --------------------------- # ---------------------------
@ -353,28 +363,46 @@ class MikrotikControllerData:
except: except:
return return
if "available" not in self.data["fw-update"]: await self.hass.async_add_executor_job(self.get_interface)
if self.api.connected() and "available" not in self.data["fw-update"]:
await self.async_fwupdate_check() await self.async_fwupdate_check()
if not self.data["host_hass"]: if self.api.connected() and not self.data["host_hass"]:
await self.async_get_host_hass() await self.async_get_host_hass()
if self.support_capsman: if self.api.connected() and self.support_capsman:
await self.hass.async_add_executor_job(self.get_capsman_hosts) await self.hass.async_add_executor_job(self.get_capsman_hosts)
if self.support_wireless: if self.api.connected() and self.support_wireless:
await self.hass.async_add_executor_job(self.get_wireless_hosts) await self.hass.async_add_executor_job(self.get_wireless_hosts)
await self.hass.async_add_executor_job(self.get_interface) if self.api.connected():
await self.hass.async_add_executor_job(self.get_bridge) await self.hass.async_add_executor_job(self.get_bridge)
await self.hass.async_add_executor_job(self.get_arp)
await self.hass.async_add_executor_job(self.get_dhcp) if self.api.connected():
await self.async_process_host() await self.hass.async_add_executor_job(self.get_arp)
await self.hass.async_add_executor_job(self.get_interface_traffic)
await self.hass.async_add_executor_job(self.process_interface_client) if self.api.connected():
await self.hass.async_add_executor_job(self.get_nat) await self.hass.async_add_executor_job(self.get_dhcp)
await self.hass.async_add_executor_job(self.get_system_resource)
await self.hass.async_add_executor_job(self.process_accounting) if self.api.connected():
await self.async_process_host()
if self.api.connected():
await self.hass.async_add_executor_job(self.get_interface_traffic)
if self.api.connected():
await self.hass.async_add_executor_job(self.process_interface_client)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_nat)
if self.api.connected():
await self.hass.async_add_executor_job(self.get_system_resource)
if self.api.connected():
await self.hass.async_add_executor_job(self.process_accounting)
async_dispatcher_send(self.hass, self.signal_update) async_dispatcher_send(self.hass, self.signal_update)
self.lock.release() self.lock.release()