Update inverter component data to extract AC current values

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

src/frequenz/sdk/microgrid/component/_component_data.py

@@ -231,6 +231,12 @@ class InverterData(ComponentData):
             -ve current means supply into the grid.
     """
 
+    current_per_phase: tuple[float, float, float]
+    """AC current in Amperes (A) for phase/line 1,2 and 3 respectively.
+            +ve current means consumption, away from the grid.
+            -ve current means supply into the grid.
+    """
+
     # pylint: disable=line-too-long
     active_power_inclusion_lower_bound: float
     """Lower inclusion bound for inverter power in watts.
@@ -301,6 +307,11 @@ def from_proto(cls, raw: microgrid_pb.ComponentData) -> InverterData:
             component_id=raw.id,
             timestamp=raw.ts.ToDatetime(tzinfo=timezone.utc),
             active_power=raw.inverter.data.ac.power_active.value,
+            current_per_phase=(
+                raw.meter.data.ac.phase_1.current.value,
+                raw.meter.data.ac.phase_2.current.value,
+                raw.meter.data.ac.phase_3.current.value,
+            ),
             active_power_inclusion_lower_bound=raw_power.system_inclusion_bounds.lower,
             active_power_exclusion_lower_bound=raw_power.system_exclusion_bounds.lower,
             active_power_inclusion_upper_bound=raw_power.system_inclusion_bounds.upper,

tests/utils/component_data_wrapper.py

@@ -101,6 +101,7 @@ def __init__(  # pylint: disable=too-many-arguments
         component_id: int,
         timestamp: datetime,
         active_power: float = math.nan,
+        current_per_phase: tuple[float, float, float] | None = None,
         active_power_inclusion_lower_bound: float = math.nan,
         active_power_exclusion_lower_bound: float = math.nan,
         active_power_inclusion_upper_bound: float = math.nan,
@@ -120,6 +121,11 @@ def __init__(  # pylint: disable=too-many-arguments
             component_id=component_id,
             timestamp=timestamp,
             active_power=active_power,
+            current_per_phase=(
+                current_per_phase
+                if current_per_phase
+                else (math.nan, math.nan, math.nan)
+            ),
             active_power_inclusion_lower_bound=active_power_inclusion_lower_bound,
             active_power_exclusion_lower_bound=active_power_exclusion_lower_bound,
             active_power_inclusion_upper_bound=active_power_inclusion_upper_bound,