Add device LED support in trigger and websocket handling

- Introduced RULE_TYPE_DEVICES to manage device LED changes in trigger.py.
- Enhanced logging for LED state changes in websocket.py, including detection of LED overrides.
- Updated translation files to include device LED terminology for better user experience.

Author: sirkirby

custom_components/unifi_network_rules/translations/en.json

@@ -40,7 +40,8 @@
       "vpn_servers": "VPN Server",
       "legacy_firewall_rules": "Legacy Firewall Rule",
       "traffic_rules": "Traffic Rule",
-      "wlans": "WLAN"
+      "wlans": "WLAN",
+      "devices": "Device LED"
     }
   },
   "triggers": {

custom_components/unifi_network_rules/trigger.py

@@ -22,6 +22,7 @@
 RULE_TYPE_LEGACY_FIREWALL_RULE = "legacy_firewall_rules"
 RULE_TYPE_TRAFFIC_RULE = "traffic_rules"
 RULE_TYPE_WLAN = "wlans"
+RULE_TYPE_DEVICES = "devices"
 
 # Trigger types
 TRIGGER_RULE_ENABLED = "rule_enabled"
@@ -51,6 +52,7 @@
     RULE_TYPE_LEGACY_FIREWALL_RULE: ["firewallrule", "legacy", "accept", "reject"],
     RULE_TYPE_TRAFFIC_RULE: ["trafficrule", "traffic_rule"],
     RULE_TYPE_WLAN: ["wlan", "wireless", "wifi", "ssid"],
+    RULE_TYPE_DEVICES: ["device", "led", "led_override", "access_point", "uap"],
 }
 
 # Configuration schema for platform triggers
@@ -74,6 +76,7 @@
             RULE_TYPE_LEGACY_FIREWALL_RULE,
             RULE_TYPE_TRAFFIC_RULE,
             RULE_TYPE_WLAN,
+            RULE_TYPE_DEVICES,
         ]),
         vol.Optional("name_filter"): cv.string,
     }
@@ -131,6 +134,15 @@ def get_rule_name_from_data(rule_data: Dict[str, Any], rule_id: str, rule_type:
         if "ssid" in rule_data:
             return f"WLAN: {rule_data['ssid']}"
 
+    elif rule_type == RULE_TYPE_DEVICES:
+        # For device LED changes, construct a meaningful name
+        device_name = rule_data.get('name', rule_data.get('device_id', 'Unknown'))
+        device_model = rule_data.get('model', '')
+        if device_model:
+            return f"{device_name} LED ({device_model})"
+        else:
+            return f"{device_name} LED"
+    
     # For device configuration changes (cfgversion events), extract device info
     if rule_id.startswith("device_config_"):
         device_part = rule_id.replace("device_config_", "")
@@ -250,11 +262,16 @@ def _handle_websocket_msg(msg: Dict[str, Any]) -> None:
                     elif isinstance(msg_data, dict):
                         LOGGER.info("📋 RULE DATA: keys=%s", list(msg_data.keys()))
                     LOGGER.info("📄 RULE CONTENT: %s", str(msg)[:300] + "..." if len(str(msg)) > 300 else str(msg))
-                elif msg_type == "device:update" and isinstance(msg_data, list):
+                elif msg_type in ["device:update", "device:sync"] and isinstance(msg_data, list):
                     # Very limited logging for device updates to avoid spam
                     first_item = msg_data[0] if msg_data else {}
                     if isinstance(first_item, dict) and "cfgversion" in first_item:
                         LOGGER.debug("📱 CFGVERSION UPDATE: %s", first_item.get("cfgversion"))
+                    # Check for LED changes in device:sync messages
+                    elif isinstance(first_item, dict) and any(led_field in first_item for led_field in ["led_override", "led_override_color", "led_override_color_brightness"]):
+                        led_state = first_item.get("led_override", "unknown")
+                        device_mac = first_item.get("mac", msg.get("meta", {}).get("mac", "unknown"))
+                        LOGGER.info("🔴 TRIGGER LED DETECTION: %s led=%s, device=%s", msg_type, led_state, device_mac)
             try:
                 # Extract message type and data from UniFi OS websocket structure
                 meta = msg.get("meta", {})
@@ -283,7 +300,7 @@ def _handle_websocket_msg(msg: Dict[str, Any]) -> None:
                 # Check for cfgversion changes (but only refresh if we have active rule triggers)
                 has_cfgversion_change = False
                 cfgversion = None
-                if msg_type == "device:update" and isinstance(msg_data, list):
+                if msg_type in ["device:update", "device:sync"] and isinstance(msg_data, list):
                     for item in msg_data:
                         if isinstance(item, dict) and "cfgversion" in item:
                             cfgversion = item.get("cfgversion")
@@ -344,6 +361,9 @@ def _handle_websocket_msg(msg: Dict[str, Any]) -> None:
                     detected_rule_type = RULE_TYPE_TRAFFIC_ROUTE
                 elif "ssid" in rule_data:
                     detected_rule_type = RULE_TYPE_WLAN
+                elif "led_override" in rule_data or ("type" in rule_data and rule_data.get("type") == "uap") or "mac" in rule_data:
+                    # Device LED detection - check for LED override field, UAP device type, or MAC address (device identifier)
+                    detected_rule_type = RULE_TYPE_DEVICES
 
                 # Fallback: Keyword matching with SPECIFIC order (most specific first)
                 if not detected_rule_type:
@@ -365,6 +385,8 @@ def _handle_websocket_msg(msg: Dict[str, Any]) -> None:
                         detected_rule_type = RULE_TYPE_TRAFFIC_ROUTE
                     elif any(keyword in rule_data_str for keyword in ["wlan", "ssid"]):
                         detected_rule_type = RULE_TYPE_WLAN
+                    elif any(keyword in rule_data_str for keyword in ["led_override", "device", "access_point", "uap"]):
+                        detected_rule_type = RULE_TYPE_DEVICES
 
                 if not detected_rule_type:
                     if LOG_TRIGGERS:

custom_components/unifi_network_rules/websocket.py

@@ -293,7 +293,7 @@ def _handle_message(self, message: dict[str, Any]) -> None:
         rule_keywords = [
             "firewall", "rule", "policy", "network", "port", "route", "forward",
             "nat", "security", "update", "change", "cfgversion", "provision",
-            "qos", "quality", "service", "vpn"  # Add QoS-related keywords
+            "qos", "quality", "service", "vpn", "device", "led"  # Add QoS and device LED keywords
         ]
 
         # Extract message type for filtering
@@ -317,25 +317,33 @@ def _handle_message(self, message: dict[str, Any]) -> None:
         # Check if message type is rule-related
         is_rule_related = any(keyword in msg_type_lower for keyword in rule_keywords)
 
-        # Special case for device:update messages - IMPORTANT for rule changes
-        if msg_type_lower == "device:update":
+        # Special case for device messages - IMPORTANT for rule and LED changes
+        if msg_type_lower in ["device:update", "device:sync"]:
             data_list = message.get("data", [])
             if isinstance(data_list, list):
                 for item in data_list:
-                    # Any device:update with cfgversion is almost always rule-related
-                    if isinstance(item, dict) and "cfgversion" in item:
+                    # Check for LED changes FIRST (more specific than cfgversion)
+                    if isinstance(item, dict) and any(led_field in item for led_field in ["led_override", "led_override_color", "led_override_color_brightness"]):
                         is_rule_related = True
-                        log_websocket("Detected config version change in device:update: %s", item.get("cfgversion", ""))
+                        led_state = item.get("led_override", "unknown")
+                        device_mac = item.get("mac", message.get("meta", {}).get("mac", "unknown"))
+                        LOGGER.info("🔴 LED CHANGE DETECTED: %s led=%s, device=%s", msg_type_lower, led_state, device_mac)
+                        log_websocket("Detected LED change in %s: led=%s, device=%s", msg_type_lower, led_state, device_mac)
+                        break
+                    # Any device:update with cfgversion is almost always rule-related (but check LED first)
+                    elif isinstance(item, dict) and "cfgversion" in item:
+                        is_rule_related = True
+                        log_websocket("Detected config version change in %s: %s", msg_type_lower, item.get("cfgversion", ""))
                         break
                     # Provisioning events also indicate rule changes
                     elif isinstance(item, dict) and "provisioned" in str(item).lower():
                         is_rule_related = True
-                        log_websocket("Detected provisioning event in device:update")
+                        log_websocket("Detected provisioning event in %s", msg_type_lower)
                         break
                     # State changes can indicate rule application
                     elif isinstance(item, dict) and "state" in item:
                         is_rule_related = True
-                        log_websocket("Detected state change in device:update: %s", item.get("state", ""))
+                        log_websocket("Detected state change in %s: %s", msg_type_lower, item.get("state", ""))
                         break
 
         # If not found in message type, check data payload for UniFi OS rule identifiers