hotfix

custom_components/mega/__init__.py

@@ -133,7 +133,7 @@ async def async_remove_entry(hass, entry) -> None:
 
 
 async def _save_service(hass: HomeAssistant, call: ServiceCall):
-    mega_id = call.data['mega_id']
+    mega_id = call.data.get('mega_id')
     if mega_id:
         hub: MegaD = hass.data[DOMAIN][mega_id]
         await hub.save()
@@ -144,8 +144,8 @@ async def _save_service(hass: HomeAssistant, call: ServiceCall):
 
 @bind_hass
 async def _get_port(hass: HomeAssistant, call: ServiceCall):
-    port = call.data['port']
+    port = call.data.get('port')
-    mega_id = call.data['mega_id']
+    mega_id = call.data.get('mega_id')
     if mega_id:
         hub: MegaD = hass.data[DOMAIN][mega_id]
         if port is None:
@@ -162,9 +162,9 @@ async def _get_port(hass: HomeAssistant, call: ServiceCall):
 
 @bind_hass
 async def _run_cmd(hass: HomeAssistant, call: ServiceCall):
-    port = call.data['port']
+    port = call.data.get('port')
-    mega_id = call.data['mega_id']
+    mega_id = call.data.get('mega_id')
-    cmd = call.data['cmd']
+    cmd = call.data.get('cmd')
     if mega_id:
         hub: MegaD = hass.data[DOMAIN][mega_id]
         await hub.send_command(port=port, cmd=cmd)

custom_components/mega/binary_sensor.py

@@ -1,5 +1,6 @@
 """Platform for light integration."""
 import logging
+import asyncio
 
 import voluptuous as vol
 
@@ -60,6 +61,8 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
     mid = config_entry.data[CONF_ID]
     hub: MegaD = hass.data['mega'][mid]
     devices = []
+
+    async def scan():
         async for port, pty, m in hub.scan_ports():
             if pty == "0":
                 sensor = MegaBinarySensor(mega_id=mid, port=port)
@@ -67,6 +70,8 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
 
         async_add_devices(devices)
 
+    asyncio.create_task(scan())
+
 
 class MegaBinarySensor(BinarySensorEntity, BaseMegaEntity):
 

custom_components/mega/hub.py

@@ -140,36 +140,45 @@ class MegaD:
     async def save(self):
         await self.send_command(cmd='s')
 
-    async def get_port(self, port, get_value=False):
+    async def get_port(self, port):
-        if get_value:
+        """
+        Опрашивает порт с помощью mqtt. Ждет ответ, возвращает ответ.
+
+        :param port:
+        :return:
+        """
         ftr = asyncio.get_event_loop().create_future()
 
         def cb(msg):
+
             try:
-                    ftr.set_result(json.loads(msg.payload).get('value'))
+                if '"value":NA' in msg.payload.decode():
-                except Exception as exc:
-                    self.lg.warning(f'could not parse {msg.payload}: {exc}')
                     ftr.set_result(None)
+                    return
+                ret = json.loads(msg.payload).get('value')
+                ftr.set_result(ret)
+            except Exception as exc:
+                ret = None
+                self.lg.exception(f'while parsing response from port {port}: {msg.payload}')
+                ftr.set_result(None)
+
+            self.lg.debug(
+                f'port: %s response: %s', port, ret
+            )
+
+        async with self.lck:
+            try:
                 unsub = await self.mqtt.async_subscribe(
                     topic=f'{self.mqtt_id}/{port}',
                     msg_callback=cb,
                     qos=1,
                 )
-
-        self.lg.debug(
-            f'get port: %s', port
-        )
-        async with self.lck:
                 await self.mqtt.async_publish(
                     topic=f'{self.mqtt_id}/cmd',
                     payload=f'get:{port}',
-                qos=0,
+                    qos=1,
                     retain=False,
                 )
-            await asyncio.sleep(0.1)
-
-        if get_value:
-            try:
                 return await asyncio.wait_for(ftr, timeout=2)
             except asyncio.TimeoutError:
                 self.lg.warning(f'timeout on port {port}')

custom_components/mega/light.py

@@ -1,6 +1,6 @@
 """Platform for light integration."""
 import logging
-
+import asyncio
 import voluptuous as vol
 
 from homeassistant.components.light import (
@@ -77,12 +77,16 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
     mid = config_entry.data[CONF_ID]
     hub: MegaD = hass.data['mega'][mid]
     devices = []
+
+    async def scan_ports():
         async for port, pty, m in hub.scan_ports():
             if pty == "1" and m in ['0', '1']:
                 light = MegaLight(mega_id=mid, port=port, dimmer=m == '1')
                 devices.append(light)
         async_add_devices(devices)
 
+    asyncio.create_task(scan_ports())
+
 
 class MegaLight(LightEntity, BaseMegaEntity):
 

custom_components/mega/sensor.py

@@ -1,4 +1,5 @@
 """Platform for light integration."""
+import asyncio
 import logging
 import voluptuous as vol
 
@@ -85,9 +86,11 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
     mid = config_entry.data[CONF_ID]
     hub: MegaD = hass.data['mega'][mid]
     devices = []
+
+    async def scan():
         async for port, pty, m in hub.scan_ports():
             if pty == "3":
-            values = await hub.get_port(port, get_value=True)
+                values = await hub.get_port(port)
                 lg.debug(f'values: %s', values)
                 if values is None:
                     continue
@@ -109,6 +112,8 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
 
         async_add_devices(devices)
 
+    asyncio.create_task(scan())
+
 
 class Mega1WSensor(BaseMegaEntity):
 

readme.md

@@ -1,4 +1,4 @@
-# MegaD HomeAssistant custom component
+# MegaD HomeAssistant integration
 
 Интеграция с [MegaD-2561](https://www.ab-log.ru/smart-house/ethernet/megad-2561)
 
@@ -11,40 +11,39 @@
 - Команды выполняются друг за другом без конкурентного доступа к ресурсам megad
 - Поддержка температурных датчиков в режиме шины
 
-## Устройства
+## Зависимости
-Поддерживаются устройства: light, switch, binary_sensor, sensor. light может работать как диммер
+**Важно!!** Перед использованием необходимо настроить интеграцию mqtt в HomeAssistant
+
+Для максимальной совместимости необходимо обновить ваш контроллер до последней версии, тк были важные обновления в части
+mqtt
 
 ## Установка
-Рекомендованнй способ - через [HACS](https://hacs.xyz/docs/installation/installation).
+Рекомендованнй способ с поддержкой обновлений - через [HACS](https://hacs.xyz/docs/installation/installation).
-После установки HACS, нужно перейти в меню hacs -> integrations, далее в верхнем правом углу
+После установки перейти в меню HACS - Integrations - Explore, в поиске ищем MegaD
-нажать три точки, где будет `Custom repositories`, открыть, нажать add и добавить `https://github.com/andvikt/mega_hacs.git`
 
 Альтернативный способ установки:
 ```shell
 # из папки с конфигом
 wget -q -O - https://raw.githubusercontent.com/andvikt/mega_hacs/master/install.sh | bash -
 ```
-Перезагрузить HA
+Не забываем перезагрузить HA
-
+## Устройства
-Для обновления повторить
+Поддерживаются устройства: light, switch, binary_sensor, sensor. light может работать как диммер
-
-## Зависимости
-Перед использованием необходимо настроить интеграцию mqtt в HomeAssistant
 
 ## Настройка из веб-интерфейса
 `Настройки` -> `Интеграции` -> `Добавить интеграцию` в поиске ищем mega
 
 ## Сервисы
+Все сервисы доступны в меню разработчика с описанием и примерами использования
 ```yaml
-save:
+mega.save:
   description: Сохраняет текущее состояние портов (?cmd=s)
   fields:
-
     mega_id:
       description: ID меги, можно оставить пустым, тогда будут сохранены все зарегистрированные меги
       example: "mega"
 
-get_port:
+mega.get_port:
   description: Запросить текущий статус порта (или всех)
   fields:
     mega_id:
@@ -54,10 +53,9 @@ get_port:
       description: Номер порта (если не заполнять, будут запрошены все порты сразу)
       example: 1
 
-run_cmd:
+mega.run_cmd:
   description: Выполнить любую произвольную команду
   fields:
-
     mega_id:
       description: ID меги
       example: "mega"
@@ -71,7 +69,9 @@ run_cmd:
 ```
 
 ## Отладка
-Если возникают проблемы, можно включить детальный лог, для этого в конфиг добавить:
+Интеграция находится в активной разработке, при возникновении проблем [заводите issue](https://github.com/andvikt/mega_hacs/issues/new/choose)
+
+Просьба прикладывать детальный лог, который можно включить в конфиге так:
 ```yaml
 logger:
   default: info