added led device and brightness control

Author: johnneerdael

custom_components/hyperhdr_control/__init__.py

@@ -26,7 +26,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
         manufacturer="HyperHDR",
         name=f"HyperHDR ({entry.data[CONF_HOST]})",
         model="HyperHDR LED Controller",
-        sw_version="1.2.0",
+        sw_version="1.3.0",
     )
 
     await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)

custom_components/hyperhdr_control/button.py

@@ -53,7 +53,7 @@ def device_info(self) -> DeviceInfo:
             manufacturer="HyperHDR",
             name=f"HyperHDR ({self._host})",
             model="HyperHDR LED Controller",
-            sw_version="1.2.0",
+            sw_version="1.3.0",
         )
 
     async def async_press(self) -> None:

custom_components/hyperhdr_control/manifest.json

@@ -6,7 +6,7 @@
   "codeowners": [],
   "requirements": ["aiohttp", "zeroconf"],
   "iot_class": "local_polling",
-  "version": "1.1.0",
+  "version": "1.3.0",
   "config_flow": true,
   "zeroconf": ["_hyperhdr-http._tcp.local."],
   "logo": "https://raw.githubusercontent.com/johnneerdael/hyperhdr_control/main/hyperhdr_control-logo.png"

custom_components/hyperhdr_control/number.py

@@ -4,6 +4,8 @@
 import json
 import logging
 from typing import Any
+import asyncio
+from datetime import datetime, timedelta
 
 import aiohttp
 import async_timeout
@@ -18,6 +20,8 @@
 
 _LOGGER = logging.getLogger(__name__)
 
+THROTTLE_DELAY = 1.0  # Delay in seconds between API calls
+
 async def async_setup_entry(
     hass: HomeAssistant,
     entry: ConfigEntry,
@@ -46,6 +50,10 @@ def __init__(self, entry_id: str, host: str, port: int) -> None:
         self._attr_native_step = 1
         self._attr_mode = NumberMode.SLIDER
         self._attr_native_unit_of_measurement = PERCENTAGE
+        self._last_update = datetime.min
+        self._pending_value = None
+        self._update_lock = asyncio.Lock()
+        self._update_task = None
 
     @property
     def device_info(self) -> DeviceInfo:
@@ -55,11 +63,38 @@ def device_info(self) -> DeviceInfo:
             manufacturer="HyperHDR",
             name=f"HyperHDR ({self._host})",
             model="HyperHDR LED Controller",
-            sw_version="1.2.0",
+            sw_version="1.3.0",
         )
 
+    async def _delayed_update(self) -> None:
+        """Handle the delayed update of the brightness value."""
+        try:
+            while True:
+                async with self._update_lock:
+                    if self._pending_value is None:
+                        self._update_task = None
+                        return
+                    
+                    value = self._pending_value
+                    self._pending_value = None
+                
+                await self._set_brightness(value)
+                await asyncio.sleep(THROTTLE_DELAY)
+        except Exception as error:
+            _LOGGER.error("Error in delayed update: %s", error)
+            self._update_task = None
+
     async def async_set_native_value(self, value: float) -> None:
-        """Set the brightness value."""
+        """Set the brightness value with throttling."""
+        async with self._update_lock:
+            self._pending_value = value
+            self._attr_native_value = value
+            
+            if self._update_task is None:
+                self._update_task = asyncio.create_task(self._delayed_update())
+
+    async def _set_brightness(self, value: float) -> None:
+        """Send the brightness value to HyperHDR."""
         request_data = {
             "command": "adjustment",
             "adjustment": {
@@ -73,9 +108,7 @@ async def async_set_native_value(self, value: float) -> None:
                 url = f"http://{self._host}:{self._port}/json-rpc"
                 async with async_timeout.timeout(10):
                     async with session.get(url, params={"request": json.dumps(request_data)}) as response:
-                        if response.status == 200:
-                            self._attr_native_value = value
-                        else:
+                        if response.status != 200:
                             _LOGGER.error("Failed to set brightness: %s", response.status)
         except (aiohttp.ClientError, TimeoutError) as error:
             _LOGGER.error("Error setting brightness: %s", error)

custom_components/hyperhdr_control/switch.py

@@ -18,6 +18,10 @@
 
 _LOGGER = logging.getLogger(__name__)
 
+# Define component names as constants
+COMP_VIDEOGRABBER = "VIDEOGRABBER"
+COMP_LEDDEVICE = "LEDDEVICE"
+
 async def async_setup_entry(
     hass: HomeAssistant,
     entry: ConfigEntry,
@@ -28,8 +32,8 @@ async def async_setup_entry(
     port = entry.data[CONF_PORT]
 
     async_add_entities([
-        HyperHDRSwitch(entry.entry_id, host, port, "VIDEOGRABBER", "USB Capture"),
-        HyperHDRSwitch(entry.entry_id, host, port, "LEDDEVICE", "LED Output")
+        HyperHDRSwitch(entry.entry_id, host, port, COMP_VIDEOGRABBER, "USB Capture"),
+        HyperHDRSwitch(entry.entry_id, host, port, COMP_LEDDEVICE, "LED Output")
     ], True)
 
 class HyperHDRSwitch(SwitchEntity):
@@ -53,7 +57,7 @@ def device_info(self) -> DeviceInfo:
             manufacturer="HyperHDR",
             name=f"HyperHDR ({self._host})",
             model="HyperHDR LED Controller",
-            sw_version="1.2.0",
+            sw_version="1.3.0",
         )
 
     async def async_turn_on(self, **kwargs: Any) -> None:
@@ -77,14 +81,18 @@ async def _set_state(self, state: bool) -> None:
         try:
             async with aiohttp.ClientSession() as session:
                 url = f"http://{self._host}:{self._port}/json-rpc"
+                _LOGGER.debug("Sending request to %s: %s", url, json.dumps(request_data))
                 async with async_timeout.timeout(10):
                     async with session.get(url, params={"request": json.dumps(request_data)}) as response:
                         if response.status == 200:
                             self._attr_is_on = state
+                            _LOGGER.debug("Successfully set %s state to %s", self._component, state)
                         else:
-                            _LOGGER.error("Failed to set state: %s", response.status)
+                            _LOGGER.error("Failed to set state for %s: %s", self._component, response.status)
+                            response_text = await response.text()
+                            _LOGGER.error("Response: %s", response_text)
         except (aiohttp.ClientError, TimeoutError) as error:
-            _LOGGER.error("Error setting state: %s", error)
+            _LOGGER.error("Error setting state for %s: %s", self._component, error)
 
     async def async_update(self) -> None:
         """Update the state of the switch."""