jeka/mega_hacs
1
0
Fork 0
mirror of https://github.com/andvikt/mega_hacs.git synced 2025-12-11 17:14:28 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fix offline bugs

Browse Source
This commit is contained in:
andvikt
2021-01-20 23:33:53 +03:00
committed by GitHub
parent 3108927f15
commit 42f44d3020
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
custom_components/mega/hub.py
View File

@@ -98,10 +98,10 @@ class MegaD:
else: else:
await self.get_port(self.port_to_scan) await self.get_port(self.port_to_scan)
await asyncio.sleep(5) await asyncio.sleep(1)
if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10): if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10):
await self.get_port(self.port_to_scan) await self.get_port(self.port_to_scan)
await asyncio.sleep(5) await asyncio.sleep(1)
if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10): if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10):
self.lg.warning('mega is offline') self.lg.warning('mega is offline')
self.hass.states.async_set( self.hass.states.async_set(
@@ -168,7 +168,7 @@ class MegaD:
ftr = asyncio.get_event_loop().create_future() ftr = asyncio.get_event_loop().create_future()
def cb(msg): def cb(msg):
self.last_update = datetime.now()
try: try:
if '"value":NA' in msg.payload.decode(): if '"value":NA' in msg.payload.decode():
if not ftr.done(): if not ftr.done():