mirror of
https://github.com/andvikt/mega_hacs.git
synced 2025-12-12 01:24:29 +05:00
Compare commits
49 Commits
v1.1.0b1
...
v1.0.10b17
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a80b9b4293 | ||
|
|
f6ae5a9f04 | ||
|
|
9eed9995fb | ||
|
|
40ff7cca2e | ||
|
|
86f58bbfd9 | ||
|
|
633d5e67bd | ||
|
|
79e3f33345 | ||
|
|
74235a39ad | ||
|
|
61bcbbd103 | ||
|
|
6411e6e5f9 | ||
|
|
2020a840a8 | ||
|
|
f6c2cd025e | ||
|
|
ab599cd59d | ||
|
|
a349cbd4a4 | ||
|
|
bd1ba0379f | ||
|
|
70016dd69d | ||
|
|
5617e7afa5 | ||
|
|
bcdec2d793 | ||
|
|
c4aae6b3ec | ||
|
|
58d243dcc3 | ||
|
|
3488d4593a | ||
|
|
76b8988b83 | ||
|
|
4145eebbdd | ||
|
|
d4dddc61fd | ||
|
|
bc34c1a0b3 | ||
|
|
2662b9c3bd | ||
|
|
8399bbd1de | ||
|
|
975b2e8a38 | ||
|
|
919f1ceb12 | ||
|
|
2c58f8e67e | ||
|
|
1c65c341b7 | ||
|
|
2ef0ebf702 | ||
|
|
b8ceec0386 | ||
|
|
496713cfec | ||
|
|
1512238763 | ||
|
|
ce1987d0c0 | ||
|
|
b4521a93bb | ||
|
|
9322f9cae1 | ||
|
|
52ace90600 | ||
|
|
8738a936fe | ||
|
|
2490e09748 | ||
|
|
e134a874fa | ||
|
|
6fc5391490 | ||
|
|
d37fa11ab3 | ||
|
|
1db5670cfd | ||
|
|
74b6e200a5 | ||
|
|
3737bf91a3 | ||
|
|
747b8e6c36 | ||
|
|
fec5cef05c |
21
.bumpversion.cfg
Normal file
21
.bumpversion.cfg
Normal file
@@ -0,0 +1,21 @@
|
||||
[bumpversion]
|
||||
current_version = 1.0.10b17
|
||||
parse = (?P<major>\d+)(\.(?P<minor>\d+))(\.(?P<patch>\d+))(?P<release>[bf]*)(?P<build>\d*)
|
||||
commit = True
|
||||
tag = True
|
||||
serialize =
|
||||
{major}.{minor}.{patch}{release}{build}
|
||||
{major}.{minor}.{patch}
|
||||
|
||||
[bumpversion:part:release]
|
||||
optional_value = f
|
||||
values =
|
||||
b
|
||||
f
|
||||
|
||||
[bumpversion:part:build]
|
||||
first_value = 0
|
||||
|
||||
[bumpversion:file:custom_components/mega/manifest.json]
|
||||
search = "version": "v{current_version}"
|
||||
replace = "version": "v{new_version}"
|
||||
@@ -16,7 +16,8 @@ from homeassistant.config_entries import ConfigEntry
|
||||
from .const import DOMAIN, CONF_INVERT, CONF_RELOAD, PLATFORMS, CONF_PORTS, CONF_CUSTOM, CONF_SKIP, CONF_PORT_TO_SCAN, \
|
||||
CONF_MQTT_INPUTS, CONF_HTTP, CONF_RESPONSE_TEMPLATE, CONF_ACTION, CONF_GET_VALUE, CONF_ALLOW_HOSTS, \
|
||||
CONF_CONV_TEMPLATE, CONF_ALL, CONF_FORCE_D, CONF_DEF_RESPONSE, CONF_FORCE_I2C_SCAN, CONF_HEX_TO_FLOAT, \
|
||||
RGB_COMBINATIONS, CONF_WS28XX, CONF_ORDER, CONF_SMOOTH, CONF_LED, CONF_WHITE_SEP, CONF_CHIP, CONF_RANGE
|
||||
RGB_COMBINATIONS, CONF_WS28XX, CONF_ORDER, CONF_SMOOTH, CONF_LED, CONF_WHITE_SEP, CONF_CHIP, CONF_RANGE, \
|
||||
CONF_FILTER_VALUES, CONF_FILTER_SCALE, CONF_FILTER_LOW, CONF_FILTER_HIGH, CONF_FILL_NA
|
||||
from .hub import MegaD
|
||||
from .config_flow import ConfigFlow
|
||||
from .http import MegaView
|
||||
@@ -51,6 +52,14 @@ LED_LIGHT = \
|
||||
|
||||
CUSTOMIZE_PORT = {
|
||||
vol.Optional(CONF_SKIP, description='исключить порт из сканирования', default=False): bool,
|
||||
vol.Optional(CONF_FILL_NA, default='last'): vol.Any(
|
||||
'last',
|
||||
'none'
|
||||
),
|
||||
vol.Optional(CONF_RANGE, description='диапазон диммирования'): [
|
||||
vol.Range(0, 255),
|
||||
vol.Range(0, 255),
|
||||
],
|
||||
vol.Optional(CONF_INVERT, default=False): bool,
|
||||
vol.Optional(CONF_NAME): vol.Any(str, {
|
||||
vol.Required(str): str
|
||||
@@ -74,6 +83,10 @@ CUSTOMIZE_PORT = {
|
||||
vol.Optional(CONF_VALUE_TEMPLATE): cv.template,
|
||||
vol.Optional(CONF_FORCE_I2C_SCAN): bool,
|
||||
vol.Optional(CONF_HEX_TO_FLOAT): bool,
|
||||
vol.Optional(CONF_FILTER_VALUES): [cv.positive_float],
|
||||
vol.Optional(CONF_FILTER_SCALE): cv.positive_float,
|
||||
vol.Optional(CONF_FILTER_LOW): cv.positive_float,
|
||||
vol.Optional(CONF_FILTER_HIGH): cv.positive_float,
|
||||
vol.Optional(CONF_SMOOTH): cv.time_period_seconds,
|
||||
# vol.Optional(CONF_RANGE): vol.ExactSequence([int, int]), TODO: сделать отбрасывание "плохих" значений
|
||||
vol.Optional(str): {
|
||||
@@ -99,6 +112,11 @@ CONFIG_SCHEMA = vol.Schema(
|
||||
{
|
||||
DOMAIN: {
|
||||
vol.Optional(CONF_ALLOW_HOSTS): [str],
|
||||
vol.Optional('entities'): {
|
||||
vol.Optional(str): vol.Any(
|
||||
CUSTOMIZE_PORT,
|
||||
CUSTOMIZE_DS2413
|
||||
)},
|
||||
vol.Optional(vol.Any(str, int), description='id меги из веб-интерфейса'): {
|
||||
vol.Optional(CONF_FORCE_D, description='Принудительно слать d после срабатывания входа', default=False): bool,
|
||||
vol.Optional(
|
||||
@@ -111,6 +129,10 @@ CONFIG_SCHEMA = vol.Schema(
|
||||
CUSTOMIZE_PORT,
|
||||
CUSTOMIZE_DS2413,
|
||||
),
|
||||
vol.Optional(CONF_FILTER_VALUES): [cv.positive_float],
|
||||
vol.Optional(CONF_FILTER_SCALE): cv.positive_float,
|
||||
vol.Optional(CONF_FILTER_LOW): cv.positive_float,
|
||||
vol.Optional(CONF_FILTER_HIGH): cv.positive_float,
|
||||
}
|
||||
}
|
||||
},
|
||||
@@ -210,7 +232,7 @@ async def async_remove_entry(hass: HomeAssistant, entry: ConfigEntry) -> None:
|
||||
id = entry.data.get('id', entry.entry_id)
|
||||
hub: MegaD = hass.data[DOMAIN].get(id)
|
||||
if hub is None:
|
||||
return
|
||||
return True
|
||||
_LOGGER.debug(f'remove {id}')
|
||||
_hubs.pop(id, None)
|
||||
hass.data[DOMAIN].pop(id, None)
|
||||
@@ -221,7 +243,7 @@ async def async_remove_entry(hass: HomeAssistant, entry: ConfigEntry) -> None:
|
||||
if task is not None:
|
||||
task.cancel()
|
||||
if hub is None:
|
||||
return
|
||||
return True
|
||||
await hub.stop()
|
||||
return True
|
||||
|
||||
|
||||
@@ -67,6 +67,7 @@ class MegaBinarySensor(BinarySensorEntity, MegaPushEntity):
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
super().__init__(*args, **kwargs)
|
||||
self.mega.binary_sensors.append(self.port)
|
||||
self._is_on = None
|
||||
self._attrs = None
|
||||
self._click_task = None
|
||||
|
||||
@@ -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 = 24
|
||||
VERSION = 25
|
||||
CONNECTION_CLASS = config_entries.CONN_CLASS_ASSUMED
|
||||
|
||||
async def async_step_user(self, user_input=None):
|
||||
|
||||
@@ -45,6 +45,11 @@ CONF_SMOOTH = 'smooth'
|
||||
CONF_WHITE_SEP = 'white_sep'
|
||||
CONF_CHIP = 'chip'
|
||||
CONF_RANGE = 'range'
|
||||
CONF_FILL_NA = 'fill_na'
|
||||
CONF_FILTER_VALUES = 'filter_values'
|
||||
CONF_FILTER_SCALE = 'filter_scale'
|
||||
CONF_FILTER_LOW = 'filter_low'
|
||||
CONF_FILTER_HIGH = 'filter_high'
|
||||
PLATFORMS = [
|
||||
"light",
|
||||
"switch",
|
||||
|
||||
@@ -12,7 +12,7 @@ from homeassistant.helpers.update_coordinator import CoordinatorEntity
|
||||
from homeassistant.helpers.restore_state import RestoreEntity
|
||||
from . import hub as h
|
||||
from .const import DOMAIN, CONF_CUSTOM, CONF_INVERT, EVENT_BINARY_SENSOR, LONG, \
|
||||
LONG_RELEASE, RELEASE, PRESS, SINGLE_CLICK, DOUBLE_CLICK, EVENT_BINARY, CONF_SMOOTH
|
||||
LONG_RELEASE, RELEASE, PRESS, SINGLE_CLICK, DOUBLE_CLICK, EVENT_BINARY, CONF_SMOOTH, CONF_RANGE
|
||||
|
||||
_events_on = False
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
@@ -54,7 +54,6 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
smooth=None,
|
||||
**kwargs,
|
||||
):
|
||||
super().__init__(mega.updater)
|
||||
self._smooth = smooth
|
||||
self.http_cmd = http_cmd
|
||||
self._state: State = None
|
||||
@@ -85,6 +84,8 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
self._can_smooth_hard = None
|
||||
if self.http_cmd == 'ds2413':
|
||||
self.mega.ds2413_ports |= {self.port}
|
||||
super().__init__(coordinator=mega.updater)
|
||||
|
||||
|
||||
@property
|
||||
def is_ws(self):
|
||||
@@ -126,15 +127,21 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
def customize(self):
|
||||
if self._customize is not None:
|
||||
return self._customize
|
||||
if self.hass is None:
|
||||
if self.hass is None or self.entity_id is None:
|
||||
return {}
|
||||
if self._customize is None:
|
||||
|
||||
c_entity_id = self.hass.data.get(DOMAIN, {}).get(CONF_CUSTOM).get('entities', {}).get(self.entity_id, {})
|
||||
self.lg.debug(
|
||||
'customize %s with %s', self.entity_id, c_entity_id
|
||||
)
|
||||
c = self.hass.data.get(DOMAIN, {}).get(CONF_CUSTOM) or {}
|
||||
c = c.get(self._mega_id) or {}
|
||||
c = c.get(self.port) or {}
|
||||
if self.addr is not None and self.index is not None and isinstance(c, dict):
|
||||
idx = self.addr.lower() + f'_a' if self.index == 0 else '_b'
|
||||
c = c.get(idx, {})
|
||||
c.update(c_entity_id)
|
||||
self._customize = c
|
||||
|
||||
return self._customize
|
||||
@@ -166,9 +173,9 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
|
||||
@property
|
||||
def lg(self) -> logging.Logger:
|
||||
if self._lg is None:
|
||||
self._lg = self.mega.lg.getChild(self._name or self.unique_id)
|
||||
return self._lg
|
||||
# if self._lg is None:
|
||||
# self._lg = self.mega.lg.getChild(self._name or self.unique_id)
|
||||
return _LOGGER
|
||||
|
||||
@property
|
||||
def available(self) -> bool:
|
||||
@@ -301,35 +308,43 @@ class MegaOutPort(MegaPushEntity):
|
||||
else:
|
||||
return 255
|
||||
|
||||
@property
|
||||
def range(self) -> typing.List[int]:
|
||||
return self.customize.get(CONF_RANGE, [0, 255])
|
||||
|
||||
@property
|
||||
def invert(self):
|
||||
return self.customize.get(CONF_INVERT, False)
|
||||
|
||||
@property
|
||||
def brightness(self):
|
||||
ret = None
|
||||
if not self.dimmer:
|
||||
return
|
||||
val = self.mega.values.get(self.port, {})
|
||||
if isinstance(val, dict) and len(val) == 0 and self._state is not None:
|
||||
return self._state.attributes.get("brightness")
|
||||
ret = safe_int(self._state.attributes.get("brightness"), def_on=self.max_dim, def_off=0, def_val=0)
|
||||
ret = self._calc_brightness(ret)
|
||||
elif isinstance(self.port, str) and 'e' in self.port:
|
||||
if isinstance(val, str):
|
||||
val = safe_int(val)
|
||||
val = safe_int(val, def_on=self.max_dim, def_off=0, def_val=0)
|
||||
else:
|
||||
val = 0
|
||||
if val == 0:
|
||||
return self._brightness
|
||||
ret = self._brightness
|
||||
elif isinstance(val, (int, float)):
|
||||
return int(val / self.dimmer_scale)
|
||||
ret = int(val / self.dimmer_scale)
|
||||
elif val is not None:
|
||||
val = val.get("value")
|
||||
if val is None:
|
||||
return
|
||||
try:
|
||||
val = int(val)
|
||||
return val
|
||||
ret = val
|
||||
except Exception:
|
||||
pass
|
||||
ret = self._cal_reverse_brightness(ret)
|
||||
return ret
|
||||
|
||||
@property
|
||||
def is_on(self) -> bool:
|
||||
@@ -415,6 +430,24 @@ class MegaOutPort(MegaPushEntity):
|
||||
updater=partial(self.update_from_smooth, update_state=update_state),
|
||||
))
|
||||
|
||||
def _calc_brightness(self, brightness):
|
||||
pct = brightness / 255
|
||||
pct = max((0, pct))
|
||||
pct = min((pct, 1))
|
||||
l, h = self.range
|
||||
d = h - l
|
||||
brightness = round(pct * d + l)
|
||||
return brightness
|
||||
|
||||
def _cal_reverse_brightness(self, brightness):
|
||||
l, h = self.range
|
||||
d = h - l
|
||||
pct = (brightness - l) / d
|
||||
pct = max((0, pct))
|
||||
pct = min((pct, 1))
|
||||
brightness = round(pct * 255)
|
||||
return brightness
|
||||
|
||||
async def async_turn_on(self, brightness=None, transition=None, **kwargs):
|
||||
if (time.time() - self._last_called) < 0.1:
|
||||
return
|
||||
@@ -424,6 +457,7 @@ class MegaOutPort(MegaPushEntity):
|
||||
if not self.is_on and (brightness is None or brightness == 0):
|
||||
brightness = self._restore_brightness
|
||||
brightness = brightness or self.brightness or 255
|
||||
brightness = self._calc_brightness(brightness)
|
||||
_prev = safe_int(self.brightness) or 0
|
||||
self._brightness = brightness
|
||||
if self.dimmer and brightness == 0:
|
||||
@@ -467,7 +501,7 @@ class MegaOutPort(MegaPushEntity):
|
||||
if (time.time() - self._last_called) < 0.1:
|
||||
return
|
||||
self._last_called = time.time()
|
||||
self._restore_brightness = safe_int(self._brightness)
|
||||
self._restore_brightness = self._cal_reverse_brightness(safe_int(self._brightness))
|
||||
if not self.dimmer:
|
||||
transition = None
|
||||
cmd = "0" if not self.invert else "1"
|
||||
@@ -503,12 +537,12 @@ class MegaOutPort(MegaPushEntity):
|
||||
|
||||
|
||||
|
||||
def safe_int(v):
|
||||
def safe_int(v, def_on=1, def_off=0, def_val=None):
|
||||
if v == 'ON':
|
||||
return 1
|
||||
return def_on
|
||||
elif v == 'OFF':
|
||||
return 0
|
||||
return def_off
|
||||
try:
|
||||
return int(v)
|
||||
except (ValueError, TypeError):
|
||||
return None
|
||||
return def_val
|
||||
@@ -134,7 +134,7 @@ class MegaView(HomeAssistantView):
|
||||
if ret == 'd' and act:
|
||||
await hub.request(cmd=act.replace(':3', f':{v}'))
|
||||
ret = 'd' if hub.force_d else ''
|
||||
else:
|
||||
elif port in hub.binary_sensors:
|
||||
hub.values[port] = data
|
||||
for cb in self.callbacks[hub.id][port]:
|
||||
cb(data)
|
||||
@@ -147,7 +147,7 @@ class MegaView(HomeAssistantView):
|
||||
_LOGGER.debug('response %s', ret)
|
||||
Response(body='' if hub.fake_response else ret, content_type='text/plain')
|
||||
|
||||
if hub.fake_response and 'value' not in data and 'pt' in data:
|
||||
if hub.fake_response and 'value' not in data and 'pt' in data and port in hub.binary_sensors:
|
||||
if 'd' in ret:
|
||||
await hub.request(pt=port, cmd=ret)
|
||||
else:
|
||||
|
||||
@@ -164,6 +164,7 @@ class MegaD:
|
||||
hass.data[DOMAIN][CONF_HTTP].protected = protected
|
||||
except Exception:
|
||||
self.lg.exception('while setting allowed hosts')
|
||||
self.binary_sensors = []
|
||||
|
||||
async def start(self):
|
||||
pass
|
||||
@@ -309,8 +310,8 @@ class MegaD:
|
||||
return ret
|
||||
except asyncio.TimeoutError:
|
||||
self.lg.warning(f'timeout while requesting {url}')
|
||||
raise
|
||||
# await asyncio.sleep(1)
|
||||
# raise
|
||||
await asyncio.sleep(1)
|
||||
raise asyncio.TimeoutError('after 3 tries')
|
||||
|
||||
async def save(self):
|
||||
@@ -426,7 +427,7 @@ class MegaD:
|
||||
def subscribe(self, port, callback):
|
||||
port = int_ignore(port)
|
||||
self.lg.debug(
|
||||
f'subscribe %s %s', port, callback
|
||||
f'subscribe %s %s', port, str(callback)
|
||||
)
|
||||
self.http.callbacks[self.id][port].append(callback)
|
||||
|
||||
@@ -566,6 +567,9 @@ class MegaD:
|
||||
elif cfg.pty == '4' and cfg.m == '2':
|
||||
# scl исключаем из сканирования
|
||||
continue
|
||||
elif cfg.pty is None and nports < 30:
|
||||
# вроде как это ADC на 328 меге
|
||||
ret['sensor'][port].append(dict())
|
||||
elif cfg.pty in ('3', '2', '4'):
|
||||
http_cmd = 'get'
|
||||
if cfg.d == '5' and cfg.pty == '3':
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
"""Platform for light integration."""
|
||||
import asyncio
|
||||
import logging
|
||||
import typing
|
||||
from datetime import timedelta, datetime
|
||||
from functools import partial
|
||||
|
||||
|
||||
@@ -15,5 +15,5 @@
|
||||
"@andvikt"
|
||||
],
|
||||
"issue_tracker": "https://github.com/andvikt/mega_hacs/issues",
|
||||
"version": "v1.0.9"
|
||||
"version": "v1.0.10b17"
|
||||
}
|
||||
@@ -20,7 +20,8 @@ from homeassistant.const import (
|
||||
from homeassistant.core import HomeAssistant
|
||||
from homeassistant.helpers.template import Template
|
||||
from .entities import MegaPushEntity
|
||||
from .const import CONF_KEY, TEMP, HUM, W1, W1BUS, CONF_CONV_TEMPLATE, CONF_HEX_TO_FLOAT, DOMAIN, CONF_CUSTOM, CONF_SKIP
|
||||
from .const import CONF_KEY, TEMP, HUM, W1, W1BUS, CONF_CONV_TEMPLATE, CONF_HEX_TO_FLOAT, DOMAIN, CONF_CUSTOM, \
|
||||
CONF_SKIP, CONF_FILTER_VALUES, CONF_FILTER_SCALE, CONF_FILTER_LOW, CONF_FILTER_HIGH, CONF_FILL_NA
|
||||
from .hub import MegaD
|
||||
import re
|
||||
|
||||
@@ -93,7 +94,7 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
|
||||
hub.skip_ports |= {port}
|
||||
continue
|
||||
for data in cfg:
|
||||
hub.lg.debug(f'add sensor on port %s with data %s', port, data)
|
||||
hub.lg.debug(f'add sensor on port %s with data %s, constructor: %s', port, data, _constructors[tp])
|
||||
sensor = _constructors[tp](
|
||||
mega=hub,
|
||||
port=port,
|
||||
@@ -107,7 +108,53 @@ async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, asyn
|
||||
async_add_devices(devices)
|
||||
|
||||
|
||||
class MegaI2C(MegaPushEntity):
|
||||
class FilterBadValues(MegaPushEntity):
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
self._prev_value = None
|
||||
super().__init__(*args, **kwargs)
|
||||
|
||||
def filter_value(self, value):
|
||||
if value \
|
||||
in self.filter_values \
|
||||
or (self.filter_low is not None and value < self.filter_low) \
|
||||
or (self.filter_high is not None and value > self.filter_high) \
|
||||
or (
|
||||
self._prev_value is not None
|
||||
and self.filter_scale is not None
|
||||
and (
|
||||
abs(value - self._prev_value) / self._prev_value > self.filter_scale
|
||||
)
|
||||
):
|
||||
if self.fill_na == 'last':
|
||||
value = self._prev_value
|
||||
else:
|
||||
value = None
|
||||
self._prev_value = value
|
||||
return value
|
||||
|
||||
@property
|
||||
def filter_values(self):
|
||||
return self.customize.get(CONF_FILTER_VALUES, self.mega.customize.get(CONF_FILTER_VALUES, []))
|
||||
|
||||
@property
|
||||
def filter_scale(self):
|
||||
return self.customize.get(CONF_FILTER_SCALE, self.mega.customize.get(CONF_FILTER_SCALE, None))
|
||||
|
||||
@property
|
||||
def filter_low(self):
|
||||
return self.customize.get(CONF_FILTER_LOW, self.mega.customize.get(CONF_FILTER_LOW, None))
|
||||
|
||||
@property
|
||||
def filter_high(self):
|
||||
return self.customize.get(CONF_FILTER_HIGH, self.mega.customize.get(CONF_FILTER_HIGH, None))
|
||||
|
||||
@property
|
||||
def fill_na(self):
|
||||
return self.customize.get(CONF_FILL_NA, 'last')
|
||||
|
||||
|
||||
class MegaI2C(FilterBadValues):
|
||||
|
||||
def __init__(
|
||||
self,
|
||||
@@ -126,6 +173,14 @@ class MegaI2C(MegaPushEntity):
|
||||
def customize(self):
|
||||
return super().customize.get(self.id_suffix, {}) or {}
|
||||
|
||||
@property
|
||||
def extra_state_attributes(self):
|
||||
attrs = super().extra_state_attributes or {}
|
||||
attrs.update({
|
||||
'i2c_id': self.id_suffix,
|
||||
})
|
||||
return attrs
|
||||
|
||||
@property
|
||||
def device_class(self):
|
||||
return self._device_class
|
||||
@@ -136,11 +191,10 @@ class MegaI2C(MegaPushEntity):
|
||||
|
||||
@property
|
||||
def state(self):
|
||||
# self.lg.debug(f'get % all states: %', self._params, self.mega.values)
|
||||
ret = self.mega.values.get(self._params)
|
||||
if self.customize.get(CONF_HEX_TO_FLOAT):
|
||||
try:
|
||||
ret = struct.unpack('!f', bytes.fromhex('41973333'))[0]
|
||||
ret = struct.unpack('!f', bytes.fromhex(ret))[0]
|
||||
except:
|
||||
self.lg.warning(f'could not convert {ret} form hex to float')
|
||||
tmpl: Template = self.customize.get(CONF_CONV_TEMPLATE, self.customize.get(CONF_VALUE_TEMPLATE))
|
||||
@@ -151,14 +205,16 @@ class MegaI2C(MegaPushEntity):
|
||||
ret = tmpl.async_render({'value': ret})
|
||||
except:
|
||||
ret = ret
|
||||
return str(ret)
|
||||
ret = self.filter_value(ret)
|
||||
if ret is not None:
|
||||
return str(ret)
|
||||
|
||||
@property
|
||||
def device_class(self):
|
||||
return self._device_class
|
||||
|
||||
|
||||
class Mega1WSensor(MegaPushEntity):
|
||||
class Mega1WSensor(FilterBadValues):
|
||||
|
||||
def __init__(
|
||||
self,
|
||||
@@ -175,11 +231,12 @@ class Mega1WSensor(MegaPushEntity):
|
||||
:param patt: pattern to extract value, must have at least one group that will contain parsed value
|
||||
"""
|
||||
super().__init__(*args, **kwargs)
|
||||
self._value = None
|
||||
self.key = key
|
||||
self._value = None
|
||||
self._device_class = device_class
|
||||
self._unit_of_measurement = unit_of_measurement
|
||||
self.mega.sensors.append(self)
|
||||
self.prev_value = None
|
||||
|
||||
@property
|
||||
def unit_of_measurement(self):
|
||||
@@ -198,7 +255,7 @@ class Mega1WSensor(MegaPushEntity):
|
||||
if self.key:
|
||||
return super().unique_id + f'_{self.key}'
|
||||
else:
|
||||
return super(Mega1WSensor, self).unique_id
|
||||
return super().unique_id
|
||||
|
||||
@property
|
||||
def device_class(self):
|
||||
@@ -215,6 +272,8 @@ class Mega1WSensor(MegaPushEntity):
|
||||
@property
|
||||
def state(self):
|
||||
ret = None
|
||||
if not hasattr(self, 'key'):
|
||||
return None
|
||||
if self.key:
|
||||
try:
|
||||
ret = self.mega.values.get(self.port, {})
|
||||
@@ -227,13 +286,16 @@ class Mega1WSensor(MegaPushEntity):
|
||||
return
|
||||
else:
|
||||
ret = self.mega.values.get(self.port, {}).get('value')
|
||||
if ret is None and self._state is not None:
|
||||
if ret is None and self.fill_na == 'fill_na' and self.prev_value is not None:
|
||||
ret = self.prev_value
|
||||
elif ret is None and self.fill_na == 'fill_na' and self._state is not None:
|
||||
ret = self._state.state
|
||||
try:
|
||||
ret = float(ret)
|
||||
ret = str(ret)
|
||||
except:
|
||||
ret = None
|
||||
self.lg.debug(f'could not convert to float "{ret}"')
|
||||
ret = self.prev_value
|
||||
if self.customize.get(CONF_HEX_TO_FLOAT):
|
||||
try:
|
||||
ret = struct.unpack('!f', bytes.fromhex(ret))[0]
|
||||
@@ -247,7 +309,10 @@ class Mega1WSensor(MegaPushEntity):
|
||||
ret = tmpl.async_render({'value': ret})
|
||||
except:
|
||||
pass
|
||||
return str(ret)
|
||||
ret = self.filter_value(ret)
|
||||
self.prev_value = ret
|
||||
if ret is not None:
|
||||
return str(ret)
|
||||
|
||||
@property
|
||||
def name(self):
|
||||
|
||||
@@ -57,7 +57,9 @@
|
||||
Информация об обновлениях приходит с некоторым интервалом, чтобы вручную проверить наличие обновлений
|
||||
нажмите три точки возле интеграции в меню HACS и нажмите `обновить информацию`
|
||||
|
||||
Чтобы включить возможность использования бета-версий, зайдите в HACS, найдите интеграцию MegaD, нажмите три точки,
|
||||
## Беты {: #beta }
|
||||
Иногда я буду выпускать бета-версии, в стабильности которых пока не уверен и не готов раскатывать на всех, поэтому в целях тестирвоания
|
||||
нужно принудительно включать поддержку бет, для этого зайдите в HACS, найдите интеграцию MegaD, нажмите три точки,
|
||||
там кнопка "переустановить" или reinstall, дальше нужно нажать галку "показывать бета-версии"
|
||||
|
||||
## Зависимости {: #deps }
|
||||
|
||||
38
docs/yaml.md
38
docs/yaml.md
@@ -62,7 +62,7 @@ mega:
|
||||
!!! note ""
|
||||
- **smooth** (float, 0): программное плавное диммирование. Это поле отвечает за кол-во секунд, за которое яркость
|
||||
диммера набирает от 0 до 100%
|
||||
- **limits** (list[int, int], [0, 255]), *начиная с версии 1.1.0*: границы диммирования в абсолютных единицах контроллера. При диммировании 1%
|
||||
- **range** (list[int, int], [0, 255]), *начиная с версии 1.1.0*: границы диммирования в абсолютных единицах 0..255. При диммировании 1%
|
||||
будет равен левой границе, 100% - правой.
|
||||
[Подробнее про плавное диммирование](smooth.md)
|
||||
### MegaD-16R-XT, MegaD-16PWM
|
||||
@@ -159,6 +159,14 @@ some_led2:
|
||||
- **value_template** (str): шаблон для конвертации, например `{{(value|float)/100}}`
|
||||
- **device_class** (str): класс устройства, [список доступных](https://developers.home-assistant.io/docs/core/entity/sensor#available-device-classes)
|
||||
- **hex_to_float** (bool, false): если ваш датчик возвращает float запакованный в HEX, интеграция его распакует (перед применением темплейта)
|
||||
- **filter_high** (float, none): верхняя граница значений, выше нее значения будут считаться ошибочными и отбрасываться. [Доступно так же глобальное значение](#filter_high)
|
||||
- **filter_low** (float, none): нижняя граница значений, ниже нее значения будут считаться ошибочными и отбрасываться. [Доступно так же глобальное значение](#filter_low)
|
||||
- **filter_values** ([float], none): список значений, которые считаются ошибочными. [Доступно так же глобальное значение](#filter_values)
|
||||
- **filter_scale** (float, none): значение отклонения от текущего значения, которое будет считаться выбросом и отфильтруется, например если
|
||||
установить 1, то это означает, что при росте показателя сенсора на 100% и больше или падении на 100% и больше, такое значение не будет отображаться.
|
||||
[Доступно так же глобальное значение](#filter_scale)
|
||||
- **fill_na** (str, last): чем заполнять пропуски, по-умолчанию last, что означает последнее значение, можно так же поставить none-тогда будут пропуски (разрывы на графике).
|
||||
|
||||
При этом есть так же особенности адресации, так для сенсора на одном порте с одним значением:
|
||||
```yaml
|
||||
36:
|
||||
@@ -183,10 +191,10 @@ some_led2:
|
||||
# конфиг
|
||||
```
|
||||
#### i2c {: #i2c}
|
||||
Для сенсоров i2c адресация конфига такая:
|
||||
Для сенсоров i2c нужно так же указать id сенсора, который можно посмотреть в атрибутах объекта на [странице разработчика](https://my.home-assistant.io/redirect/developer_states/).
|
||||
```yaml
|
||||
36:
|
||||
htu21d_humidity: # entity_id сенсора без приставки sensor., видно в интерфейсе HA
|
||||
htu21d_humidity: # i2c_id
|
||||
# конфиг
|
||||
```
|
||||
[Подробнее про i2c](i2c.md)
|
||||
@@ -213,5 +221,27 @@ mega:
|
||||
```yaml
|
||||
mega:
|
||||
allow_hosts:
|
||||
- 192.168.1.20
|
||||
- 192.168.1.20
|
||||
```
|
||||
|
||||
### filter_high {: #filter_high}
|
||||
Верхняя граница значений датчиков по-умолчанию, выше нее значения будут считаться ошибочными и отбрасываться
|
||||
|
||||
### filter_low {: #filter_low}
|
||||
Нижняя граница значений датчиков по-умолчанию, ниже нее значения будут считаться ошибочными и отбрасываться
|
||||
|
||||
### filter_values {: #filter_values }
|
||||
Список значений, которые считаются ошибочными, настройка по-умолчанию для всех датчиков. Удобно, если у вас много
|
||||
однотипных датчиков
|
||||
|
||||
```yaml
|
||||
mega:
|
||||
filter_values: [-82, - 150]
|
||||
```
|
||||
### filter_scale {: #filter_scale }
|
||||
Значение отклонения от текущего значения, которое будет считаться выбросом и отфильтруется, например если
|
||||
установить 1, то это означает, что при росте показателя сенсора на 100% и больше или падении на 100% и больше, такое значение не будет отображаться.
|
||||
```yaml
|
||||
mega:
|
||||
filter_scale: 1 # 100%
|
||||
```
|
||||
Reference in New Issue
Block a user