detect old attribute values

Author: dlashua

custom_components/pyscript/__init__.py

@@ -210,16 +210,49 @@ async def state_changed(event):
         else:
             new_val = event.data["new_state"].state
         old_val = event.data["old_state"].state if event.data["old_state"] else None
+
+        if old_val != new_val:
+            val_change = False
+        else:
+            val_change = True
+
         new_vars = {var_name: new_val, f"{var_name}.old": old_val}
         func_args = {
             "trigger_type": "state",
             "var_name": var_name,
             "value": new_val,
             "old_value": old_val,
+            "change": val_change,
             "context": event.context,
         }
         await State.update(new_vars, func_args)
 
+        if "new_state" not in event.data or event.data["new_state"] is None:
+            return
+
+        for attribute in event.data["new_state"].attributes:
+            new_val = event.data["new_state"].attributes[attribute]
+            if "old_state" in event.data and attribute in event.data["old_state"].attributes:
+                old_val = event.data["old_state"].attributes[attribute]
+            else:
+                old_val = None
+
+            if old_val != new_val:
+                val_change = False
+            else:
+                val_change = True
+
+            new_vars = {f"{var_name}.{attribute}": new_val, f"{var_name}.old.{attribute}": old_val}
+            func_args = {
+                "trigger_type": "state",
+                "var_name": f"{var_name}.{attribute}",
+                "value": new_val,
+                "old_value": old_val,
+                "change": val_change,
+                "context": event.context,
+            }
+            await State.update(new_vars, func_args)
+
     async def hass_started(event):
         _LOGGER.debug("adding state changed listener and starting global contexts")
         await State.get_service_params()

custom_components/pyscript/state.py

@@ -77,9 +77,13 @@ async def notify_add(cls, var_names, queue):
 
         for var_name in var_names if isinstance(var_names, set) else {var_names}:
             parts = var_name.split(".")
-            if len(parts) != 2 and len(parts) != 3:
+            if len(parts) == 2:
+                state_var_name = f"{parts[0]}.{parts[1]}"
+            elif len(parts) == 3:
+                state_var_name = f"{parts[0]}.{parts[1]}.{parts[2]}"
+            else:
                 continue
-            state_var_name = f"{parts[0]}.{parts[1]}"
+
             if state_var_name not in cls.notify:
                 cls.notify[state_var_name] = {}
             cls.notify[state_var_name][queue] = var_names

custom_components/pyscript/trigger.py

@@ -22,7 +22,7 @@
 _LOGGER = logging.getLogger(LOGGER_PATH + ".trigger")
 
 
-STATE_RE = re.compile(r"[a-zA-Z]\w*\.[a-zA-Z]\w*$")
+STATE_RE = re.compile(r"[a-zA-Z]\w*\.[a-zA-Z]\w*(\.[a-zA-Z]\w*)?$")
 
 
 def dt_now():