mirror of
https://github.com/andvikt/mega_hacs.git
synced 2025-12-12 17:44:28 +05:00
Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6c50b81bff | ||
|
|
c810693ba5 | ||
|
|
1fd321d4c1 | ||
|
|
6732e1b7a2 | ||
|
|
f784c1c261 | ||
|
|
ab572c4db5 | ||
|
|
e55184f565 | ||
|
|
3f74f9739c |
@@ -63,7 +63,7 @@ async def validate_input(hass: core.HomeAssistant, data):
|
|||||||
class ConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
|
class ConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
|
||||||
"""Handle a config flow for mega."""
|
"""Handle a config flow for mega."""
|
||||||
|
|
||||||
VERSION = 18
|
VERSION = 20
|
||||||
CONNECTION_CLASS = config_entries.CONN_CLASS_ASSUMED
|
CONNECTION_CLASS = config_entries.CONN_CLASS_ASSUMED
|
||||||
|
|
||||||
async def async_step_user(self, user_input=None):
|
async def async_step_user(self, user_input=None):
|
||||||
|
|||||||
@@ -530,9 +530,11 @@ class MegaD:
|
|||||||
:return:
|
:return:
|
||||||
"""
|
"""
|
||||||
_params = tuple(params.items())
|
_params = tuple(params.items())
|
||||||
return {
|
ret = {
|
||||||
_params: await self.request(**params)
|
_params: await self.request(**params)
|
||||||
}
|
}
|
||||||
|
self.lg.debug('i2c response: %s', ret)
|
||||||
|
return ret
|
||||||
|
|
||||||
async def get_config(self, nports=37):
|
async def get_config(self, nports=37):
|
||||||
ret = defaultdict(lambda: defaultdict(list))
|
ret = defaultdict(lambda: defaultdict(list))
|
||||||
@@ -588,8 +590,11 @@ class MegaD:
|
|||||||
page = await self.request(pt=port, cmd='scan')
|
page = await self.request(pt=port, cmd='scan')
|
||||||
req, parsed = parse_scan_page(page)
|
req, parsed = parse_scan_page(page)
|
||||||
self.lg.debug(f'scan results: %s', (req, parsed))
|
self.lg.debug(f'scan results: %s', (req, parsed))
|
||||||
ret['i2c'][port].append(parsed)
|
ret['i2c'][port].extend(parsed)
|
||||||
i2c_sensors.extend(req)
|
i2c_sensors.extend(req)
|
||||||
|
elif cfg.pty == '4' and cfg.m == '2':
|
||||||
|
# scl исключаем из сканирования
|
||||||
|
continue
|
||||||
elif cfg.pty in ('3', '2', '4'):
|
elif cfg.pty in ('3', '2', '4'):
|
||||||
http_cmd = 'get'
|
http_cmd = 'get'
|
||||||
if cfg.d == '5' and cfg.pty == '3':
|
if cfg.d == '5' and cfg.pty == '3':
|
||||||
|
|||||||
@@ -17,36 +17,37 @@ def parse_scan_page(page: str):
|
|||||||
if params is None:
|
if params is None:
|
||||||
continue
|
continue
|
||||||
params = dict(parse_qsl(urlparse(params).query))
|
params = dict(parse_qsl(urlparse(params).query))
|
||||||
if 'i2c_dev' in params:
|
dev = params.get('i2c_dev')
|
||||||
dev = params['i2c_dev']
|
if dev is None:
|
||||||
classes = i2c_classes.get(dev, [])
|
continue
|
||||||
for i, c in enumerate(classes):
|
classes = i2c_classes.get(dev, [])
|
||||||
if c is Skip:
|
for i, c in enumerate(classes):
|
||||||
continue
|
if c is Skip:
|
||||||
elif c is Request:
|
continue
|
||||||
req.append(params)
|
elif c is Request:
|
||||||
continue
|
|
||||||
elif isinstance(c, tuple):
|
|
||||||
suffix, c = c
|
|
||||||
elif isinstance(c, str):
|
|
||||||
suffix = c
|
|
||||||
else:
|
|
||||||
suffix = ''
|
|
||||||
if 'addr' in params:
|
|
||||||
suffix += f"_{params['addr']}" if suffix else str(params['addr'])
|
|
||||||
if suffix:
|
|
||||||
_dev = f'{dev}_{suffix}'
|
|
||||||
else:
|
|
||||||
_dev = dev
|
|
||||||
params = params.copy()
|
|
||||||
if i > 0:
|
|
||||||
params['i2c_par'] = i
|
|
||||||
ret.append({
|
|
||||||
'id_suffix': _dev,
|
|
||||||
'device_class': c,
|
|
||||||
'params': params,
|
|
||||||
})
|
|
||||||
req.append(params)
|
req.append(params)
|
||||||
|
continue
|
||||||
|
elif isinstance(c, tuple):
|
||||||
|
suffix, c = c
|
||||||
|
elif isinstance(c, str):
|
||||||
|
suffix = c
|
||||||
|
else:
|
||||||
|
suffix = ''
|
||||||
|
if 'addr' in params:
|
||||||
|
suffix += f"_{params['addr']}" if suffix else str(params['addr'])
|
||||||
|
if suffix:
|
||||||
|
_dev = f'{dev}_{suffix}'
|
||||||
|
else:
|
||||||
|
_dev = dev
|
||||||
|
params = params.copy()
|
||||||
|
if i > 0:
|
||||||
|
params['i2c_par'] = i
|
||||||
|
ret.append({
|
||||||
|
'id_suffix': _dev,
|
||||||
|
'device_class': c,
|
||||||
|
'params': params,
|
||||||
|
})
|
||||||
|
req.append(params)
|
||||||
return req, ret
|
return req, ret
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -109,8 +109,10 @@ class MegaI2C(MegaPushEntity):
|
|||||||
def device_class(self):
|
def device_class(self):
|
||||||
return self._device_class
|
return self._device_class
|
||||||
|
|
||||||
|
@property
|
||||||
def state(self):
|
def state(self):
|
||||||
return self.mega.values[self._params]
|
# self.lg.debug(f'get % all states: %', self._params, self.mega.values)
|
||||||
|
return self.mega.values.get(self._params)
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def device_class(self):
|
def device_class(self):
|
||||||
|
|||||||
@@ -57,7 +57,7 @@ class PriorityLock(asyncio.Lock):
|
|||||||
locked and returns True.
|
locked and returns True.
|
||||||
"""
|
"""
|
||||||
if (not self._locked and (self._waiters is None or
|
if (not self._locked and (self._waiters is None or
|
||||||
all(w.cancelled() for _, w in self._waiters))):
|
all(w.cancelled() for _, _, w in self._waiters))):
|
||||||
self._locked = True
|
self._locked = True
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|||||||
@@ -30,8 +30,8 @@
|
|||||||
выполнении предыдущей.
|
выполнении предыдущей.
|
||||||
- поддержка [ds2413](https://www.ab-log.ru/smart-house/ethernet/megad-2w) (начиная с версии 0.4.1)
|
- поддержка [ds2413](https://www.ab-log.ru/smart-house/ethernet/megad-2w) (начиная с версии 0.4.1)
|
||||||
- поддержка MCP23008/MCP23017/PCA9685 (начиная с версии 0.5.1)
|
- поддержка MCP23008/MCP23017/PCA9685 (начиная с версии 0.5.1)
|
||||||
- поддержка всех возможных датчиков в режиме I2C-ANY, полный список поддерживаемых датчиков датчиков
|
- поддержка всех возможных датчиков в режиме I2C-ANY, полный список поддерживаемых датчиков
|
||||||
[по ссылке](https://github.com/andvikt/mega_hacs/wiki/ш2с)
|
[по ссылке](https://github.com/andvikt/mega_hacs/wiki/i2c) (начиная с версии 0.6.1)
|
||||||
|
|
||||||
## Установка
|
## Установка
|
||||||
Рекомендованный способ с поддержкой обновлений - [HACS](https://hacs.xyz/docs/installation/installation):
|
Рекомендованный способ с поддержкой обновлений - [HACS](https://hacs.xyz/docs/installation/installation):
|
||||||
|
|||||||
Reference in New Issue
Block a user