Add boiler plate to setup PowerDistributingActor to DataPipeline

This sets up a single-user PowerDistributingActor.  Multiple usecase
actors will be supported once PowerManager is implemented.

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

Author: shsms

src/frequenz/sdk/microgrid/_data_pipeline.py

@@ -12,8 +12,9 @@
 
 import typing
 from dataclasses import dataclass
+from datetime import timedelta
 
-from frequenz.channels import Broadcast, Sender
+from frequenz.channels import Bidirectional, Broadcast, Sender
 
 # A number of imports had to be done inside functions where they are used, to break
 # import cycles.
@@ -26,6 +27,12 @@
         DataSourcingActor,
         ResamplerConfig,
     )
+    from ..actor.power_distributing import (
+        BatteryStatus,
+        PowerDistributingActor,
+        Request,
+        Result,
+    )
     from ..timeseries.ev_charger_pool import EVChargerPool
     from ..timeseries.logical_meter import LogicalMeter
 
@@ -70,6 +77,13 @@ def __init__(
 
         self._data_sourcing_actor: _ActorInfo | None = None
         self._resampling_actor: _ActorInfo | None = None
+
+        self._power_distribution_channel = Bidirectional["Request", "Result"](
+            "Default", "Power Distributing Actor"
+        )
+
+        self._power_distributing_actor: "PowerDistributingActor" | None = None
+
         self._logical_meter: "LogicalMeter" | None = None
         self._ev_charger_pools: dict[frozenset[int], "EVChargerPool"] = {}
 
@@ -123,6 +137,32 @@ def ev_charger_pool(
             )
         return self._ev_charger_pools[key]
 
+    def power_distributing_handle(self) -> Bidirectional.Handle[Request, Result]:
+        """Return the handle to the power distributing actor.
+
+        Returns:
+            A Bidirectional handle to communicate with the power distributing actor.
+        """
+        if not self._power_distributing_actor:
+            self._start_power_distributing_actor()
+
+        return self._power_distribution_channel.client_handle
+
+    def _start_power_distributing_actor(self) -> None:
+        """Start the power distributing actor if it is not already running."""
+        if self._power_distributing_actor:
+            return
+
+        from ..actor.power_distributing import PowerDistributingActor
+
+        # The PowerDistributingActor is started with only a single default user channel.
+        # Until the PowerManager is implemented, support for multiple use-case actors
+        # will not be available in the high level interface.
+        self._power_distributing_actor = PowerDistributingActor(
+            users_channels={"default": self._power_distribution_channel.service_handle},
+            battery_status_sender=self._battery_status_channel.new_sender(),
+        )
+
     def _data_sourcing_request_sender(self) -> Sender[ComponentMetricRequest]:
         """Return a Sender for sending requests to the data sourcing actor.