added option to set polling interval
This commit is contained in:
1 parent
6361e661c0
commit
ed10127a90
6 files changed
+26
-7
No files matched your search
@@ -12,7 +12,7 @@ from homeassistant.core import HomeAssistant
|
|||||||
from homeassistant.helpers.entity import DeviceInfo
|
from homeassistant.helpers.entity import DeviceInfo
|
||||||
from homeassistant.exceptions import ConfigEntryNotReady
|
from homeassistant.exceptions import ConfigEntryNotReady
|
||||||
|
|
||||||
from .const import DATA_COORDINATOR, DOMAIN, MANUFACTURER, CONF_USE_CONTROLS, DATA_POLLING_RUNNING
|
from .const import CONF_POLLING_INTERVAL, DATA_COORDINATOR, DOMAIN, MANUFACTURER, CONF_USE_CONTROLS, DATA_POLLING_RUNNING
|
||||||
from .coordinator import PollingCoordinator
|
from .coordinator import PollingCoordinator
|
||||||
|
|
||||||
PLATFORMS: [Platform] = [Platform.BINARY_SENSOR, Platform.SENSOR]
|
PLATFORMS: [Platform] = [Platform.BINARY_SENSOR, Platform.SENSOR]
|
||||||
@@ -25,6 +25,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
|
|||||||
address = entry.data.get(CONF_ADDRESS)
|
address = entry.data.get(CONF_ADDRESS)
|
||||||
device_name = entry.data.get(CONF_NAME)
|
device_name = entry.data.get(CONF_NAME)
|
||||||
use_controls = entry.data.get(CONF_USE_CONTROLS)
|
use_controls = entry.data.get(CONF_USE_CONTROLS)
|
||||||
|
polling_interval = entry.data.get(CONF_POLLING_INTERVAL, 20)
|
||||||
|
|
||||||
if address is None:
|
if address is None:
|
||||||
return False
|
return False
|
||||||
@@ -38,7 +39,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
|
|||||||
hass.data[DOMAIN][entry.entry_id].setdefault(DATA_POLLING_RUNNING, False)
|
hass.data[DOMAIN][entry.entry_id].setdefault(DATA_POLLING_RUNNING, False)
|
||||||
|
|
||||||
# Create coordinator for polling
|
# Create coordinator for polling
|
||||||
coordinator = PollingCoordinator(hass, address, device_name)
|
coordinator = PollingCoordinator(hass, address, device_name, polling_interval)
|
||||||
await coordinator.async_config_entry_first_refresh()
|
await coordinator.async_config_entry_first_refresh()
|
||||||
hass.data[DOMAIN][entry.entry_id].setdefault(DATA_COORDINATOR, coordinator)
|
hass.data[DOMAIN][entry.entry_id].setdefault(DATA_COORDINATOR, coordinator)
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ from homeassistant.data_entry_flow import FlowResult
|
|||||||
from homeassistant.helpers import selector
|
from homeassistant.helpers import selector
|
||||||
|
|
||||||
from . import get_type_by_bt_name
|
from . import get_type_by_bt_name
|
||||||
from .const import DOMAIN, CONF_USE_CONTROLS
|
from .const import CONF_PERSISTANT_CONN, CONF_POLLING_INTERVAL, DOMAIN, CONF_USE_CONTROLS
|
||||||
|
|
||||||
_LOGGER = logging.getLogger(__name__)
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
@@ -114,6 +114,8 @@ class OptionsFlowHandler(config_entries.OptionsFlow):
|
|||||||
**self.config_entry.data,
|
**self.config_entry.data,
|
||||||
**{
|
**{
|
||||||
CONF_USE_CONTROLS: user_input[CONF_USE_CONTROLS],
|
CONF_USE_CONTROLS: user_input[CONF_USE_CONTROLS],
|
||||||
|
CONF_PERSISTANT_CONN: user_input[CONF_PERSISTANT_CONN],
|
||||||
|
CONF_POLLING_INTERVAL: user_input[CONF_POLLING_INTERVAL],
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
@@ -126,6 +128,8 @@ class OptionsFlowHandler(config_entries.OptionsFlow):
|
|||||||
title="",
|
title="",
|
||||||
data={
|
data={
|
||||||
CONF_USE_CONTROLS: user_input[CONF_USE_CONTROLS],
|
CONF_USE_CONTROLS: user_input[CONF_USE_CONTROLS],
|
||||||
|
CONF_PERSISTANT_CONN: user_input[CONF_PERSISTANT_CONN],
|
||||||
|
CONF_POLLING_INTERVAL: user_input[CONF_POLLING_INTERVAL],
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -137,6 +141,14 @@ class OptionsFlowHandler(config_entries.OptionsFlow):
|
|||||||
CONF_USE_CONTROLS,
|
CONF_USE_CONTROLS,
|
||||||
default=self.config_entry.data.get(CONF_USE_CONTROLS, False),
|
default=self.config_entry.data.get(CONF_USE_CONTROLS, False),
|
||||||
): selector.BooleanSelector(),
|
): selector.BooleanSelector(),
|
||||||
|
vol.Required(
|
||||||
|
CONF_PERSISTANT_CONN,
|
||||||
|
default=self.config_entry.data.get(CONF_PERSISTANT_CONN, False),
|
||||||
|
): selector.BooleanSelector(),
|
||||||
|
vol.Required(
|
||||||
|
CONF_POLLING_INTERVAL,
|
||||||
|
default=self.config_entry.data.get(CONF_POLLING_INTERVAL, 20),
|
||||||
|
): int,
|
||||||
}
|
}
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
@@ -7,6 +7,8 @@ MANUFACTURER = "Bluetti"
|
|||||||
|
|
||||||
CONF_OPTIONS = "options"
|
CONF_OPTIONS = "options"
|
||||||
CONF_USE_CONTROLS = "use_controls"
|
CONF_USE_CONTROLS = "use_controls"
|
||||||
|
CONF_PERSISTANT_CONN = "persistant_conn"
|
||||||
|
CONF_POLLING_INTERVAL = "polling_interval"
|
||||||
|
|
||||||
DATA_COORDINATOR = "coordinator"
|
DATA_COORDINATOR = "coordinator"
|
||||||
DATA_POLLING_RUNNING = "polling_running"
|
DATA_POLLING_RUNNING = "polling_running"
|
||||||
|
|||||||
@@ -129,13 +129,13 @@ class DummyDevice(BluettiDevice):
|
|||||||
class PollingCoordinator(DataUpdateCoordinator):
|
class PollingCoordinator(DataUpdateCoordinator):
|
||||||
"""Polling coordinator."""
|
"""Polling coordinator."""
|
||||||
|
|
||||||
def __init__(self, hass: HomeAssistant, address, device_name: str):
|
def __init__(self, hass: HomeAssistant, address, device_name: str, polling_interval: int):
|
||||||
"""Initialize coordinator."""
|
"""Initialize coordinator."""
|
||||||
super().__init__(
|
super().__init__(
|
||||||
hass,
|
hass,
|
||||||
_LOGGER,
|
_LOGGER,
|
||||||
name="Bluetti polling coordinator",
|
name="Bluetti polling coordinator",
|
||||||
update_interval=timedelta(seconds=20),
|
update_interval=timedelta(seconds=polling_interval),
|
||||||
)
|
)
|
||||||
self._address = address
|
self._address = address
|
||||||
self.notify_future = None
|
self.notify_future = None
|
||||||
|
|||||||
@@ -3,7 +3,9 @@
|
|||||||
"step": {
|
"step": {
|
||||||
"init": {
|
"init": {
|
||||||
"data": {
|
"data": {
|
||||||
"use_controls": "Steuerung aktivieren (auf eigenes Risiko)"
|
"use_controls": "Steuerung aktivieren (auf eigenes Risiko)",
|
||||||
|
"persistant_conn": "Dauerhafte Verbindung",
|
||||||
|
"polling_interval": "Datenabruf-Intervall"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,7 +3,9 @@
|
|||||||
"step": {
|
"step": {
|
||||||
"init": {
|
"init": {
|
||||||
"data": {
|
"data": {
|
||||||
"use_controls": "Use controls (use at own risk)"
|
"use_controls": "Use controls (use at own risk)",
|
||||||
|
"persistant_conn": "Persistant connection",
|
||||||
|
"polling_interval": "Polling interval"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in new issue
Block a user