Use MockMicrogridClient instead of a MockMicrogridServer in LogicalMeter tests (#180)

Closes #177

Author: sahas-subramanian-frequenz

src/frequenz/sdk/timeseries/logical_meter/_formula_engine.py

@@ -91,19 +91,20 @@ async def _synchronize_metric_timestamps(
             name = metric.get_name()
             if result is None:
                 raise RuntimeError(f"Stream closed for component: {name}")
-            metrics_by_ts[result.timestamp] = name
+            metrics_by_ts.setdefault(result.timestamp, []).append(name)
         latest_ts = max(metrics_by_ts)
 
         # fetch the metrics with non-latest timestamps again until we have the values
         # for the same ts for all metrics.
-        for metric_ts, name in metrics_by_ts.items():
+        for metric_ts, names in metrics_by_ts.items():
             if metric_ts == latest_ts:
                 continue
-            fetcher = self._metric_fetchers[name]
             while metric_ts < latest_ts:
-                next_val = await fetcher.fetch_next()
-                assert next_val is not None
-                metric_ts = next_val.timestamp
+                for name in names:
+                    fetcher = self._metric_fetchers[name]
+                    next_val = await fetcher.fetch_next()
+                    assert next_val is not None
+                    metric_ts = next_val.timestamp
             if metric_ts > latest_ts:
                 raise RuntimeError(
                     "Unable to synchronize resampled metric timestamps, "

tests/actor/test_power_distributing.py

@@ -84,7 +84,7 @@ async def test_constructor(self, mocker: MockerFixture) -> None:
         """Test if gets all necessary data."""
         components, connections = self.component_graph()
         mock_microgrid = MockMicrogridClient(components, connections)
-        await mock_microgrid.initialize(mocker)
+        mock_microgrid.initialize(mocker)
 
         channel = Bidirectional[Request, Result]("user1", "power_distributor")
         distributor = PowerDistributingActor({"user1": channel.service_handle})
@@ -101,7 +101,7 @@ async def init_mock_microgrid(self, mocker: MockerFixture) -> MockMicrogridClien
         """
         components, connections = self.component_graph()
         microgrid = MockMicrogridClient(components, connections)
-        await microgrid.initialize(mocker)
+        microgrid.initialize(mocker)
 
         graph = microgrid.component_graph
         for battery in graph.components(component_category={ComponentCategory.BATTERY}):