hotfix

custom_components/mega/binary_sensor.py

@@ -72,6 +72,7 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
 
     asyncio.create_task(scan())
 
+
 class MegaBinarySensor(BinarySensorEntity, BaseMegaEntity):
 
     def __init__(self, *args, **kwargs):

custom_components/mega/hub.py

@@ -153,9 +153,11 @@ class MegaD:
 
             try:
                 if '"value":NA' in msg.payload.decode():
+                    if not ftr.done():
                         ftr.set_result(None)
                     return
                 ret = json.loads(msg.payload).get('value')
+                if not ftr.done():
                     ftr.set_result(ret)
             except Exception as exc:
                 ret = None
@@ -167,12 +169,12 @@ class MegaD:
             )
 
         async with self.lck:
-            try:
             unsub = await self.mqtt.async_subscribe(
                 topic=f'{self.mqtt_id}/{port}',
                 msg_callback=cb,
                 qos=1,
             )
+            try:
                 await self.mqtt.async_publish(
                     topic=f'{self.mqtt_id}/cmd',
                     payload=f'get:{port}',
@@ -268,7 +270,6 @@ class MegaD:
             return pty, m
 
     async def scan_ports(self,):
-        async with self.lck:
         for x in range(38):
             ret = await self.scan_port(x)
             if ret: