Expose exec service call result as event

custom_components/openwrt/__init__.py

@@ -59,7 +59,8 @@ async def async_exec(call):
                 await device.do_file_exec(
                     parts[0],
                     parts[1:],
-                    call.data.get("environment", {})
+                    call.data.get("environment", {}),
+                    call.data.get("extra", {})
                 )
 
     hass.services.async_register(DOMAIN, "reboot", async_reboot)

custom_components/openwrt/coordinator.py

@@ -160,7 +160,7 @@ async def do_reboot(self):
             dict()
         )
 
-    async def do_file_exec(self, command: str, params, env: dict):
+    async def do_file_exec(self, command: str, params, env: dict, extra: dict):
         _LOGGER.debug(
             f"Executing command: {self._id}: {command} with {params} env={env}")
         result = await self._ubus.api_call(
@@ -169,6 +169,17 @@ async def do_file_exec(self, command: str, params, env: dict):
             dict(command=command, params=params, env=env)
         )
         _LOGGER.debug(f"Execute result: {self._id}: {result}")
+        self._coordinator.hass.bus.async_fire(
+            "openwrt_exec_result", 
+            {
+                "address": self._config.get("address"),
+                "id": self._config.get("id"),
+                "command": command, 
+                "code": result.get("code", 1), 
+                "stdout": result.get("stdout", ""),
+                **extra,
+            },
+        )
 
     async def update_ap(self, configs) -> dict:
         result = dict()

custom_components/openwrt/services.yaml

@@ -20,5 +20,11 @@ exec:
       name: Environment variables
       description: Map of Environment variables names with values
       required: false
+      selector:
+        object: {}
+    extra:
+      name: Extra event fields
+      description: Arbitrary object added to the execute result event
+      required: false
       selector:
         object: {}