mirror of
https://github.com/andvikt/mega_hacs.git
synced 2025-12-13 01:54:27 +05:00
Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
42f44d3020 | ||
|
|
3108927f15 |
@@ -99,10 +99,10 @@ class MegaD:
|
||||
await self.get_port(self.port_to_scan)
|
||||
|
||||
await asyncio.sleep(1)
|
||||
if (datetime.now() - self.last_update).total_seconds() > self.poll_interval:
|
||||
if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10):
|
||||
await self.get_port(self.port_to_scan)
|
||||
await asyncio.sleep(1)
|
||||
if (datetime.now() - self.last_update).total_seconds() > self.poll_interval:
|
||||
if (datetime.now() - self.last_update).total_seconds() > (self.poll_interval + 10):
|
||||
self.lg.warning('mega is offline')
|
||||
self.hass.states.async_set(
|
||||
f'mega.{self.id}',
|
||||
@@ -168,7 +168,7 @@ class MegaD:
|
||||
ftr = asyncio.get_event_loop().create_future()
|
||||
|
||||
def cb(msg):
|
||||
|
||||
self.last_update = datetime.now()
|
||||
try:
|
||||
if '"value":NA' in msg.payload.decode():
|
||||
if not ftr.done():
|
||||
|
||||
Reference in New Issue
Block a user