Improve examples (#85)

Make a few minor improvements in channel names and other coding style
and rename the files because the current names are pretty redundant and
in some cases not very representative about what the example is about.

Author: llucax

examples/sdk_usage_example.py examples/power_distribution.pyexamples/sdk_usage_example.py renamed to examples/power_distribution.py

@@ -195,7 +195,9 @@ async def run() -> None:
     )
 
     # Channel to communicate between actors.
-    request_channel = Broadcast[List[float]]("RequestChannel", resend_latest=True)
+    power_dist_req_chan = Broadcast[List[float]](
+        "power-distribing-req", resend_latest=True
+    )
 
     # You should get components from ComponentGraph, not from the api.
     # It is faster and and non blocking approach.
@@ -205,15 +207,15 @@ async def run() -> None:
     )
 
     service_actor = DecisionMakingActor(
-        power_channel=request_channel.new_receiver(),
+        power_channel=power_dist_req_chan.new_receiver(),
         power_distributor_handle=power_distributor_channels[
             sending_actor_id
         ].client_handle,
         batteries={battery.component_id for battery in batteries},
     )
 
     client_actor = DataCollectingActor(
-        request_channel=request_channel.new_sender(),
+        request_channel=power_dist_req_chan.new_sender(),
         active_power_data=microgrid_data_channels[
             "batteries_active_power"
         ].new_receiver(name="DecisionMakingActor"),

examples/sdk_resampling_example.py examples/resampling.pyexamples/sdk_resampling_example.py renamed to examples/resampling.py

@@ -25,18 +25,14 @@ async def run() -> None:  # pylint: disable=too-many-locals
     """Run main functions that initializes and creates everything."""
     await microgrid.initialize(HOST, PORT)
 
-    channel_registry = ChannelRegistry(name="Microgrid Channel Registry")
+    channel_registry = ChannelRegistry(name="data-registry")
 
     # Create a channels for sending/receiving subscription requests
-    data_source_request_channel = Broadcast[ComponentMetricRequest](
-        "Data Source Request Channel"
-    )
+    data_source_request_channel = Broadcast[ComponentMetricRequest]("data-source")
     data_source_request_sender = data_source_request_channel.new_sender()
     data_source_request_receiver = data_source_request_channel.new_receiver()
 
-    resampling_actor_request_channel = Broadcast[ComponentMetricRequest](
-        "Resampling Actor Request Channel"
-    )
+    resampling_actor_request_channel = Broadcast[ComponentMetricRequest]("resample")
     resampling_actor_request_sender = resampling_actor_request_channel.new_sender()
     resampling_actor_request_receiver = resampling_actor_request_channel.new_receiver()
 
@@ -63,7 +59,7 @@ async def run() -> None:  # pylint: disable=too-many-locals
     # Create subscription requests for each time series id
     subscription_requests = [
         ComponentMetricRequest(
-            namespace="Resampling",
+            namespace="resampling",
             component_id=component_id,
             metric_id=ComponentMetricId.SOC,
             start_time=None,
@@ -79,18 +75,18 @@ async def run() -> None:  # pylint: disable=too-many-locals
         ]
     )
 
-    # Store sample receivers for each subscription
-    sample_receiver = MergeNamed(
+    # Merge sample receivers for each subscription into one receiver
+    merged_receiver = MergeNamed(
         **{
-            channel_name: channel_registry.new_receiver(channel_name)
-            for channel_name in map(
-                lambda req: req.get_channel_name(), subscription_requests
+            req.get_channel_name(): channel_registry.new_receiver(
+                req.get_channel_name()
             )
+            for req in subscription_requests
         }
     )
 
-    async for channel_name, msg in sample_receiver:
-        print(msg)
+    async for channel_name, msg in merged_receiver:
+        print(f"{channel_name}: {msg}")
 
 
 asyncio.run(run())