fix errors

custom_components/mega/binary_sensor.py

@@ -67,6 +67,10 @@ class MegaBinarySensor(BinarySensorEntity, MegaPushEntity):
         super().__init__(*args, **kwargs)
         self._is_on = None
         self._attrs = None
+        self._click_task = None
+
+    async def _click(self):
+        await self.customize.get
 
     @property
     def state_attributes(self):

custom_components/mega/config_flow.py

@@ -63,7 +63,7 @@ async def validate_input(hass: core.HomeAssistant, data):
 class ConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
     """Handle a config flow for mega."""
 
-    VERSION = 13
+    VERSION = 17
     CONNECTION_CLASS = config_entries.CONN_CLASS_ASSUMED
 
     async def async_step_user(self, user_input=None):
@@ -118,7 +118,7 @@ class OptionsFlowHandler(config_entries.OptionsFlow):
             reload = user_input.pop(CONF_RELOAD)
             cfg = dict(self.config_entry.data)
             cfg.update(user_input)
-            hub = await get_hub(self.hass, self.config_entry.data)
+            hub = await get_hub(self.hass, cfg)
             if reload:
                 await hub.start()
                 new = await hub.get_config(nports=user_input.get(CONF_NPORTS, 37))

custom_components/mega/config_parser.py

@@ -1,6 +1,19 @@
 from dataclasses import dataclass, field
 from bs4 import BeautifulSoup
 
+inputs = [
+    'eact',
+    'inta',
+    'misc',
+]
+selectors = [
+    'pty',
+    'm',
+    'gr',
+    'd',
+    'ety',
+]
+
 
 @dataclass(frozen=True, eq=True)
 class Config:
@@ -8,21 +21,16 @@ class Config:
     m: str = None
     gr: str = None
     d: str = None
-    inta: str = field(compare=False, hash=False, default=None)
     ety: str = None
+    inta: str = field(compare=False, hash=False, default=None)
     misc: str = field(compare=False, hash=False, default=None)
+    eact: str = field(compare=False, hash=False, default=None)
 
 
 def parse_config(page: str):
     page = BeautifulSoup(page, features="lxml")
     ret = {}
-    for x in [
+    for x in selectors:
-        'pty',
-        'm',
-        'gr',
-        'd',
-        'ety',
-    ]:
         v = page.find('select', attrs={'name': x})
         if v is None:
             continue
@@ -31,12 +39,10 @@ def parse_config(page: str):
             if v:
                 v = v['value']
                 ret[x] = v
-    v = page.find('input', attrs={'name': 'inta'})
+    for x in inputs:
-    if v:
+        v = page.find('input', attrs={'name': x})
-        ret['inta'] = v['value']
+        if v:
-    v = page.find('input', attrs={'name': 'misc'})
+            ret[x] = v['value']
-    if v:
-        ret['misc'] = v.get('checked', False)
     return Config(**ret)
 
 

custom_components/mega/const.py

@@ -32,6 +32,8 @@ CONF_POLL_OUTS = 'poll_outs'
 CONF_FORCE_D = 'force_d'
 CONF_DEF_RESPONSE = 'def_response'
 CONF_RESTORE_ON_RESTART = 'restore_on_restart'
+CONF_CLICK_TIME = 'click_time'
+CONF_LONG_TIME = 'long_time'
 PLATFORMS = [
     "light",
     "switch",

custom_components/mega/http.py

@@ -100,24 +100,36 @@ class MegaView(HomeAssistantView):
         ret = 'd' if hub.force_d else ''
         if port is not None:
             if is_ext(data):
-                ret = ''  # пока ответ всегда пустой, неясно какая будет реакция на непустой ответ
+                # ret = ''  # пока ответ всегда пустой, неясно какая будет реакция на непустой ответ
                 if port in hub.extenders:
                     pt_orig = port
                 else:
-                    pt_orig = hub.ext_in.get(port)
+                    pt_orig = hub.ext_in.get(port, hub.ext_in.get(str(port)))
                 if pt_orig is None:
-                    hub.lg.warning(f'can not find extender for int port {port}')
+                    hub.lg.warning(f'can not find extender for int port {port}, '
+                                   f'have ext_int: {hub.ext_in}, ext: {hub.extenders}')
                     return Response(status=200)
                 for e, v in data.items():
-                    if e.startswith('ext') in data:
+                    _data = data.copy()
-                        idx = e[-1]
+                    if e.startswith('ext'):
+                        idx = e[3:]
                         pt = f'{pt_orig}e{idx}'
-                        data['pt_orig'] = pt_orig
+                        _data['pt_orig'] = pt_orig
-                        data['value'] = 'ON' if v == '1' else 'OFF'
+                        _data['value'] = 'ON' if v == '1' else 'OFF'
-                        data['m'] = 1 if data[e] == '0' else 0  # имитация поведения обычного входа, чтобы события обрабатывались аналогично
+                        _data['m'] = 1 if _data[e] == '0' else 0  # имитация поведения обычного входа, чтобы события обрабатывались аналогично
-                        hub.values[pt] = data
+                        hub.values[pt] = _data
                         for cb in self.callbacks[hub.id][pt]:
-                            cb(data)
+                            cb(_data)
+                        act = hub.ext_act.get(pt)
+                        hub.lg.debug(f'act on port {pt}: {act}, all acts are: {hub.ext_act}')
+                        template: Template = self.templates.get(hub.id, {}).get(port, hub.def_response)
+                        if template is not None:
+                            template.hass = hass
+                            ret = template.async_render(_data)
+                        hub.lg.debug(f'response={ret}, template={template}')
+                        if ret == 'd' and act:
+                            await hub.request(cmd=act)
+                        ret = 'd' if hub.force_d else ''
             else:
                 hub.values[port] = data
                 for cb in self.callbacks[hub.id][port]:

custom_components/mega/hub.py

@@ -82,6 +82,7 @@ class MegaD:
             restore_on_restart=False,
             extenders=None,
             ext_in=None,
+            ext_acts=None,
             **kwargs,
     ):
         """Initialize."""
@@ -98,6 +99,7 @@ class MegaD:
             self.http = None
         self.extenders = extenders or []
         self.ext_in = ext_in or {}
+        self.ext_act = ext_acts or {}
         self.poll_outs = poll_outs
         self.update_all = update_all if update_all is not None else True
         self.nports = nports
@@ -517,6 +519,7 @@ class MegaD:
         ret['mqtt_id'] = await self.get_mqtt_id()
         ret['extenders'] = extenders = []
         ret['ext_in'] = ext_int = {}
+        ret['ext_acts'] = ext_acts = {}
         async for port, cfg in self.scan_ports(nports):
             if cfg.pty == "0":
                 ret['binary_sensor'][port].append({})
@@ -536,16 +539,20 @@ class MegaD:
                     ])
             elif cfg == MCP230:
                 extenders.append(port)
-                ext_int[int(cfg.inta)] = port
+                if cfg.inta:
+                    ext_int[int_ignore(cfg.inta)] = port
                 values = await self.request(pt=port, cmd='get')
                 values = values.split(';')
                 for n in range(len(values)):
                     ext_page = await self.request(pt=port, ext=n)
                     ext_cfg = parse_config(ext_page)
+                    pt = f'{port}e{n}'
                     if ext_cfg.ety == '1':
-                        ret['light'][f'{port}e{n}'].append({})
+                        ret['light'][pt].append({})
                     elif ext_cfg.ety == '0':
-                        ret['binary_sensor'][f'{port}e{n}'].append({})
+                        if ext_cfg.eact:
+                            ext_acts[pt] = ext_cfg.eact
+                        ret['binary_sensor'][pt].append({})
             elif cfg == PCA9685:
                 extenders.append(port)
                 values = await self.request(pt=port, cmd='get')