add currents for json inverter

Author: benderl

packages/modules/devices/generic/json/config.py

@@ -83,9 +83,15 @@ def __init__(self,
 
 
 class JsonInverterConfiguration:
-    def __init__(self, jq_power: str = "", jq_exported: Optional[str] = None):
+    def __init__(self,
+                 jq_power: str = "",
+                 jq_exported: Optional[str] = None,
+                 jq_current_l1: Optional[str] = None,
+                 jq_current_l2: Optional[str] = None,
+                 jq_current_l3: Optional[str] = None):
         self.jq_power = jq_power
         self.jq_exported = jq_exported
+        self.jq_currents = (jq_current_l1, jq_current_l2, jq_current_l3)
 
 
 class JsonInverterSetup(ComponentSetup[JsonInverterConfiguration]):

packages/modules/devices/generic/json/inverter.py

@@ -24,6 +24,7 @@ def _compile_jq_filters(self) -> None:
         config = self.component_config.configuration
         self.jq_power = jq.compile(config.jq_power)
         self.jq_exported = jq.compile(config.jq_exported) if config.jq_exported else None
+        self.jq_currents = [jq.compile(c) for c in config.jq_currents] if all(config.jq_currents) else None
 
     def initialize(self) -> None:
         self.__device_id: int = self.kwargs['device_id']
@@ -37,14 +38,20 @@ def update(self, response) -> None:
         if power >= 0:
             power = power * -1
 
+        currents = (
+            [float(j.input(response).first()) for j in self.jq_currents]
+            if self.jq_currents is not None else None
+        )
+
         if self.jq_exported is None:
             _, exported = self.sim_counter.sim_count(power)
         else:
             exported = float(self.jq_exported.input(response).first())
 
         inverter_state = InverterState(
             power=power,
-            exported=exported
+            exported=exported,
+            currents=currents
         )
         self.store.set(inverter_state)