Compare commits

..
10 Commits
7 changed files with 73 additions and 24 deletions
+1
View File
@@ -46,5 +46,6 @@ STATE_ACTIVE = "active"
STATE_OFF = "off" STATE_OFF = "off"
STATE_MANUAL_ON = "manual_on" STATE_MANUAL_ON = "manual_on"
STATE_MANUAL_OFF_COOLDOWN = "manual_off_cooldown" STATE_MANUAL_OFF_COOLDOWN = "manual_off_cooldown"
STATE_FORCE_STOPPED = "force_stopped"
STATE_ERROR = "error" STATE_ERROR = "error"
STATE_DISABLED = "disabled" STATE_DISABLED = "disabled"
+66 -22
View File
@@ -28,6 +28,7 @@ from .const import (
STATE_OFF, STATE_OFF,
STATE_MANUAL_ON, STATE_MANUAL_ON,
STATE_MANUAL_OFF_COOLDOWN, STATE_MANUAL_OFF_COOLDOWN,
STATE_FORCE_STOPPED,
STATE_ERROR, STATE_ERROR,
STATE_DISABLED, STATE_DISABLED,
) )
@@ -110,6 +111,9 @@ class MotionLightCoordinator(DataUpdateCoordinator):
attrs["main_sensors"] = self.main_sensors attrs["main_sensors"] = self.main_sensors
attrs["extend_sensors"] = self.extend_sensors attrs["extend_sensors"] = self.extend_sensors
attrs["lux_sensor"] = self.lux_sensor attrs["lux_sensor"] = self.lux_sensor
attrs["force_stop_sensor"] = self.force_stop_sensor
attrs["force_stop_state"] = self.force_stop_state
attrs["force_stop_active"] = self._state == STATE_FORCE_STOPPED
attrs["active_main_sensors"] = self._get_active_main_sensors() attrs["active_main_sensors"] = self._get_active_main_sensors()
attrs["active_extend_sensors"] = self._get_active_extend_sensors() attrs["active_extend_sensors"] = self._get_active_extend_sensors()
attrs["lux_value"] = self._get_current_lux() attrs["lux_value"] = self._get_current_lux()
@@ -154,8 +158,6 @@ class MotionLightCoordinator(DataUpdateCoordinator):
def set_manual_idle_timeout(self, value: float) -> None: def set_manual_idle_timeout(self, value: float) -> None:
self.manual_idle_timeout = int(value) self.manual_idle_timeout = int(value)
self.logger.info("Manual idle timeout set to %d sec", self.manual_idle_timeout) self.logger.info("Manual idle timeout set to %d sec", self.manual_idle_timeout)
# Если таймер уже тикает, а мы изменили значение на 0, нужно его отменить
if self.manual_idle_timeout <= 0 and self._manual_idle_timer: if self.manual_idle_timeout <= 0 and self._manual_idle_timer:
self.logger.info("Manual idle timeout set to 0, cancelling active timer") self.logger.info("Manual idle timeout set to 0, cancelling active timer")
self._manual_idle_timer() self._manual_idle_timer()
@@ -175,6 +177,15 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self.logger.info("Switches: %s, Main sensors: %s, Extend sensors: %s, Lux: %s", self.logger.info("Switches: %s, Main sensors: %s, Extend sensors: %s, Lux: %s",
self.switch_entities, self.main_sensors, self.extend_sensors, self.lux_sensor) self.switch_entities, self.main_sensors, self.extend_sensors, self.lux_sensor)
# Проверяем состояние force_stop_sensor при старте
if self.force_stop_sensor:
force_stop_state_obj = self.hass.states.get(self.force_stop_sensor)
if force_stop_state_obj and force_stop_state_obj.state == self.force_stop_state:
self.logger.info("Force stop sensor is already in stop state at startup")
await self._update_state(STATE_FORCE_STOPPED)
await self._start_listening()
return
any_on = any( any_on = any(
self.hass.states.get(s) and self.hass.states.get(s).state == "on" self.hass.states.get(s) and self.hass.states.get(s).state == "on"
for s in self.switch_entities for s in self.switch_entities
@@ -294,6 +305,11 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self.logger.debug("Integration disabled, ignoring") self.logger.debug("Integration disabled, ignoring")
return return
# БЛОКИРОВЩИК: Игнорируем движение, если активна принудительная остановка
if self._state == STATE_FORCE_STOPPED:
self.logger.debug("Ignoring during force_stopped")
return
self.logger.debug("Main sensor ON by %s, current state: %s", triggered_by, self._state) self.logger.debug("Main sensor ON by %s, current state: %s", triggered_by, self._state)
if self._state == STATE_MANUAL_OFF_COOLDOWN: if self._state == STATE_MANUAL_OFF_COOLDOWN:
@@ -302,7 +318,6 @@ class MotionLightCoordinator(DataUpdateCoordinator):
if self._state == STATE_MANUAL_ON: if self._state == STATE_MANUAL_ON:
self.logger.debug("During manual_on, resetting idle timer") self.logger.debug("During manual_on, resetting idle timer")
# ИЗМЕНЕНИЕ: Сбрасываем таймер только если он включен (>0)
if self.manual_idle_timeout > 0: if self.manual_idle_timeout > 0:
self._reset_manual_idle_timer() self._reset_manual_idle_timer()
return return
@@ -394,6 +409,11 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self.logger.debug("Integration disabled, ignoring") self.logger.debug("Integration disabled, ignoring")
return return
# БЛОКИРОВЩИК: Игнорируем движение, если активна принудительная остановка
if self._state == STATE_FORCE_STOPPED:
self.logger.debug("Ignoring during force_stopped")
return
self.logger.debug("Extend sensor ON by %s, current state: %s", triggered_by, self._state) self.logger.debug("Extend sensor ON by %s, current state: %s", triggered_by, self._state)
if self._state == STATE_IDLE: if self._state == STATE_IDLE:
@@ -406,7 +426,6 @@ class MotionLightCoordinator(DataUpdateCoordinator):
if self._state == STATE_MANUAL_ON: if self._state == STATE_MANUAL_ON:
self.logger.debug("During manual_on, resetting idle timer") self.logger.debug("During manual_on, resetting idle timer")
# ИЗМЕНЕНИЕ: Сбрасываем таймер только если он включен (>0)
if self.manual_idle_timeout > 0: if self.manual_idle_timeout > 0:
self._reset_manual_idle_timer() self._reset_manual_idle_timer()
return return
@@ -440,6 +459,11 @@ class MotionLightCoordinator(DataUpdateCoordinator):
if not self.respect_manual: if not self.respect_manual:
return return
# БЛОКИРОВЩИК: Игнорируем ручные переключения, если активна принудительная остановка
if self._state == STATE_FORCE_STOPPED:
self.logger.debug("Ignoring manual change during force_stopped")
return
new_state = event.data.get("new_state") new_state = event.data.get("new_state")
old_state = event.data.get("old_state") old_state = event.data.get("old_state")
if not new_state or not old_state: if not new_state or not old_state:
@@ -485,9 +509,27 @@ class MotionLightCoordinator(DataUpdateCoordinator):
if not new_state: if not new_state:
return return
# Если датчик перешел в блокирующее состояние
if new_state.state == self.force_stop_state: if new_state.state == self.force_stop_state:
self.logger.info("Force stop triggered by %s", event.data.get("entity_id")) self.logger.info("Force stop triggered by %s", event.data.get("entity_id"))
self.hass.async_create_task(self._force_stop()) self.hass.async_create_task(self._enter_force_stop())
# Если датчик вышел из блокирующего состояния
else:
self.logger.info("Force stop released by %s", event.data.get("entity_id"))
self.hass.async_create_task(self._exit_force_stop())
async def _enter_force_stop(self):
"""Enter force_stopped state."""
self.logger.info("Entering force_stopped state")
self._cancel_all_timers()
if self._state in (STATE_ON, STATE_DELAYING, STATE_ACTIVE, STATE_MANUAL_ON):
await self._turn_off_switches()
await self._update_state(STATE_FORCE_STOPPED)
async def _exit_force_stop(self):
"""Exit force_stopped state to idle."""
self.logger.info("Exiting force_stopped state")
await self._update_state(STATE_IDLE)
def _is_any_main_sensor_active(self) -> bool: def _is_any_main_sensor_active(self) -> bool:
"""Check if any main sensor is currently in 'on' state.""" """Check if any main sensor is currently in 'on' state."""
@@ -562,13 +604,21 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self._check_lux_periodically, self._check_lux_periodically,
) )
self.async_set_updated_data({
"state": self._state,
"attributes": self.attributes,
})
def _stop_lux_check_timer(self): def _stop_lux_check_timer(self):
"""Stop periodic lux check timer.""" """Stop periodic lux check timer."""
if self._lux_check_timer: if self._lux_check_timer:
self.logger.debug("Stopping lux check timer") self.logger.debug("Stopping lux check timer")
self._lux_check_timer() self._lux_check_timer()
self._lux_check_timer = None self._lux_check_timer = None
self.async_set_updated_data({
"state": self._state,
"attributes": self.attributes,
})
@callback @callback
def _check_lux_periodically(self, _=None): def _check_lux_periodically(self, _=None):
"""Check lux periodically.""" """Check lux periodically."""
@@ -658,11 +708,11 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self.hass.async_create_task(self._update_state(STATE_IDLE)) self.hass.async_create_task(self._update_state(STATE_IDLE))
async def _turn_on_switches(self) -> None: async def _turn_on_switches(self) -> None:
"""Turn on switches with our context.""" """Turn on switches/lights with our context."""
ctx = Context( ctx = Context(
id=f"motion_light_{self.entry.entry_id}_{dt_util.utcnow().timestamp()}" id=f"motion_light_{self.entry.entry_id}_{dt_util.utcnow().timestamp()}"
) )
self.logger.info("Turning ON switches: %s", self.switch_entities) self.logger.info("Turning ON entities: %s", self.switch_entities)
await self.hass.services.async_call( await self.hass.services.async_call(
"homeassistant", "homeassistant",
"turn_on", "turn_on",
@@ -671,11 +721,11 @@ class MotionLightCoordinator(DataUpdateCoordinator):
) )
async def _turn_off_switches(self) -> None: async def _turn_off_switches(self) -> None:
"""Turn off switches with our context.""" """Turn off switches/lights with our context."""
ctx = Context( ctx = Context(
id=f"motion_light_{self.entry.entry_id}_{dt_util.utcnow().timestamp()}" id=f"motion_light_{self.entry.entry_id}_{dt_util.utcnow().timestamp()}"
) )
self.logger.info("Turning OFF switches: %s", self.switch_entities) self.logger.info("Turning OFF entities: %s", self.switch_entities)
await self.hass.services.async_call( await self.hass.services.async_call(
"homeassistant", "homeassistant",
"turn_off", "turn_off",
@@ -686,7 +736,6 @@ class MotionLightCoordinator(DataUpdateCoordinator):
async def _enter_manual_on(self): async def _enter_manual_on(self):
"""Enter manual_on state.""" """Enter manual_on state."""
await self._update_state(STATE_MANUAL_ON) await self._update_state(STATE_MANUAL_ON)
# ИЗМЕНЕНИЕ: Запускаем таймер только если он не отключен (не равен 0)
if self.manual_idle_timeout > 0: if self.manual_idle_timeout > 0:
self._reset_manual_idle_timer() self._reset_manual_idle_timer()
else: else:
@@ -694,7 +743,6 @@ class MotionLightCoordinator(DataUpdateCoordinator):
def _reset_manual_idle_timer(self): def _reset_manual_idle_timer(self):
"""Reset manual idle timer.""" """Reset manual idle timer."""
# ИЗМЕНЕНИЕ: Защита от создания таймера при значении 0
if self.manual_idle_timeout <= 0: if self.manual_idle_timeout <= 0:
return return
@@ -715,8 +763,8 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self.hass.async_create_task(self._turn_off_switches_manual()) self.hass.async_create_task(self._turn_off_switches_manual())
async def _turn_off_switches_manual(self): async def _turn_off_switches_manual(self):
"""Turn off switches in manual mode.""" """Turn off switches/lights in manual mode."""
self.logger.info("Turning OFF switches (manual timeout): %s", self.switch_entities) self.logger.info("Turning OFF entities (manual timeout): %s", self.switch_entities)
await self.hass.services.async_call( await self.hass.services.async_call(
"homeassistant", "homeassistant",
"turn_off", "turn_off",
@@ -755,14 +803,10 @@ class MotionLightCoordinator(DataUpdateCoordinator):
self._lux_cooldown_active = False self._lux_cooldown_active = False
self._lux_cooldown_timer = None self._lux_cooldown_timer = None
self.logger.info("Lux cooldown expired") self.logger.info("Lux cooldown expired")
self.async_set_updated_data({
async def _force_stop(self): "state": self._state,
"""Force stop — turn off switches.""" "attributes": self.attributes,
self.logger.info("Force stop called") })
self._cancel_all_timers()
await self._turn_off_switches()
await self._update_state(STATE_OFF)
async_call_later(self.hass, 1, self._transition_to_idle)
def _cancel_all_timers(self): def _cancel_all_timers(self):
"""Cancel all timers.""" """Cancel all timers."""
+1 -1
View File
@@ -1,7 +1,7 @@
{ {
"domain": "motion_light", "domain": "motion_light",
"name": "Motion Light", "name": "Motion Light",
"version": "1.0.1", "version": "1.0.4",
"documentation": "https://github.com/sirmrak/motion_light", "documentation": "https://github.com/sirmrak/motion_light",
"issue_tracker": "https://github.com/sirmrak/motion_light/issues", "issue_tracker": "https://github.com/sirmrak/motion_light/issues",
"dependencies": [], "dependencies": [],
+1
View File
@@ -10,6 +10,7 @@ from homeassistant.helpers.restore_state import RestoreEntity
from homeassistant.helpers.device_registry import DeviceInfo from homeassistant.helpers.device_registry import DeviceInfo
from .const import ( from .const import (
DOMAIN, DOMAIN,
CONF_LUX_SENSOR,
ENTITY_MOTION_FILTER, ENTITY_MOTION_FILTER,
ENTITY_OFF_DELAY, ENTITY_OFF_DELAY,
ENTITY_LUX_THRESHOLD, ENTITY_LUX_THRESHOLD,
+1
View File
@@ -45,6 +45,7 @@ class MotionLightStatusSensor(CoordinatorEntity, SensorEntity):
"off": "mdi:lightbulb-off-outline", "off": "mdi:lightbulb-off-outline",
"manual_on": "mdi:hand-back-left", "manual_on": "mdi:hand-back-left",
"manual_off_cooldown": "mdi:timer-pause", "manual_off_cooldown": "mdi:timer-pause",
"force_stopped": "mdi:stop-circle-outline",
"error": "mdi:alert-circle", "error": "mdi:alert-circle",
"disabled": "mdi:lightbulb-off", "disabled": "mdi:lightbulb-off",
} }
@@ -55,6 +55,7 @@
"off": "Off", "off": "Off",
"manual_on": "Manual on", "manual_on": "Manual on",
"manual_off_cooldown": "Manual off cooldown", "manual_off_cooldown": "Manual off cooldown",
"force_stopped": "Force stopped",
"error": "Error", "error": "Error",
"disabled": "Disabled" "disabled": "Disabled"
} }
@@ -55,6 +55,7 @@
"off": "Выключено", "off": "Выключено",
"manual_on": "Ручное включение", "manual_on": "Ручное включение",
"manual_off_cooldown": "Пауза после ручного выкл.", "manual_off_cooldown": "Пауза после ручного выкл.",
"force_stopped": "Принудительная остановка",
"error": "Ошибка", "error": "Ошибка",
"disabled": "Отключено" "disabled": "Отключено"
} }