Skip to content

Commit

Permalink
fix: async track events
Browse files Browse the repository at this point in the history
Develop
  • Loading branch information
danobot authored May 4, 2024
2 parents 29e9af5 + 5259d98 commit 4421ed2
Showing 1 changed file with 16 additions and 7 deletions.
23 changes: 16 additions & 7 deletions custom_components/entity_controller/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -596,8 +596,11 @@ def finalize(self):
# =====================================================

@callback
def sensor_state_change(self, entity, old, new):
def sensor_state_change(self, event):
""" State change callback for sensor entities """
entity = event.data["entity_id"]
old = event.data["old_state"]
new = event.data["new_state"]
self.log.debug("sensor_state_change :: %10s Sensor state change to: %s" % ( pprint.pformat(entity), new.state))
self.log.debug("sensor_state_change :: state: " + pprint.pformat(self.state))

Expand Down Expand Up @@ -637,8 +640,11 @@ def sensor_state_change(self, entity, old, new):
self.log.debug("sensor_state_change :: CONF_SENSOR_RESETS_TIMER - normal")

@callback
def override_state_change(self, entity, old, new):
def override_state_change(self, event):
""" State change callback for override entities """
entity = event.data["entity_id"]
old = event.data["old_state"]
new = event.data["new_state"]
self.log.debug("override_state_change :: Override state change entity=%s, old=%s, new=%s" % ( entity, old, new))
if self.matches(new.state, self.OVERRIDE_ON_STATE) and (
self.is_active()
Expand All @@ -659,7 +665,10 @@ def override_state_change(self, entity, old, new):
self.enable()

@callback
def state_entity_state_change(self, entity, old, new):
def state_entity_state_change(self, event):
entity = event.data["entity_id"]
old = event.data["old_state"]
new = event.data["new_state"]
""" State change callback for state entities. This can be called with either a state change or an attribute change. """
self.log.debug(
"state_entity_state_change :: [ Entity: %s, Context: %s ]\n\tOld state: %s\n\tNew State: %s",
Expand Down Expand Up @@ -982,7 +991,7 @@ def config_state_entities(self, config):
self.log.info(
"State Entities (explicitly defined - I hope you know what you are doing): " + str(self.stateEntities)
)
event.async_track_state_change(
event.async_track_state_change_event(
self.hass, self.stateEntities, self.state_entity_state_change
)

Expand All @@ -992,7 +1001,7 @@ def config_state_entities(self, config):
self.log.debug(
"Added Control Entities as state entities (default): " + str(self.stateEntities)
)
event.async_track_state_change(
event.async_track_state_change_event(
self.hass, self.stateEntities, self.state_entity_state_change
)

Expand Down Expand Up @@ -1021,7 +1030,7 @@ def config_sensor_entities(self, config):

self.log.debug("Sensor Entities: " + pprint.pformat(self.sensorEntities))

event.async_track_state_change(
event.async_track_state_change_event(
self.hass, self.sensorEntities, self.sensor_state_change
)

Expand Down Expand Up @@ -1164,7 +1173,7 @@ def config_override_entities(self, config):

if len(self.overrideEntities) > 0:
self.log.debug("Override Entities: " + pprint.pformat(self.overrideEntities))
event.async_track_state_change(
event.async_track_state_change_event(
self.hass, self.overrideEntities, self.override_state_change
)

Expand Down

0 comments on commit 4421ed2

Please sign in to comment.