Add a config parameter to MessageSource::add_sink

Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>

Author: didier-wenzek

crates/core/tedge_actors/src/builders.rs

@@ -187,8 +187,8 @@ pub trait MessageSource<M: Message, Config> {
     fn register_peer(&mut self, config: Config, sender: DynSender<M>);
 
     /// Connect a peer actor that will consume the message produced by this actor
-    fn add_sink(&mut self, peer: &impl MessageSink<M, Config>) {
-        self.register_peer(peer.get_config(), peer.get_sender());
+    fn add_sink<C>(&mut self, config: Config, peer: &impl MessageSink<M, C>) {
+        self.register_peer(config, peer.get_sender());
     }
 }
 

crates/core/tedge_actors/src/converter.rs

@@ -220,7 +220,7 @@ impl<C: Converter> ConvertingActor<C> {
 ///     converter_builder.add_input(converter_builder.get_config(), &mut mqtt_builder);
 ///
 ///     // Connect the same mqtt actor as a sink of this actor, to send output messages to it
-///     converter_builder.add_sink(&mut mqtt_builder);
+///     converter_builder.add_sink(NoConfig, &mut mqtt_builder);
 ///
 ///     // Finally build the actor
 ///     converter_builder.build()

crates/core/tedge_agent/src/agent.rs

@@ -29,6 +29,7 @@ use tedge_actors::ConvertingActor;
 use tedge_actors::ConvertingActorBuilder;
 use tedge_actors::MessageSink;
 use tedge_actors::MessageSource;
+use tedge_actors::NoConfig;
 use tedge_actors::Runtime;
 use tedge_actors::ServerActorBuilder;
 use tedge_api::mqtt_topics::DeviceTopicId;
@@ -440,7 +441,7 @@ pub fn create_tedge_to_te_converter(
         );
 
     tedge_converter_actor.add_input(subscriptions, mqtt_actor_builder);
-    tedge_converter_actor.add_sink(mqtt_actor_builder);
+    tedge_converter_actor.add_sink(NoConfig, mqtt_actor_builder);
 
     Ok(tedge_converter_actor)
 }

crates/extensions/c8y_mapper_ext/src/compatibility_adapter.rs

@@ -47,7 +47,7 @@ impl OldAgentAdapter {
             old_and_new_command_topics(),
         );
         builder.add_input(builder.get_config(), mqtt);
-        builder.add_sink(mqtt);
+        builder.add_sink(NoConfig, mqtt);
         builder
     }
 }

crates/extensions/tedge_signal_ext/src/lib.rs

@@ -58,7 +58,7 @@ pub struct SignalActor {
 impl SignalActor {
     pub fn builder(runtime: &impl MessageSink<RuntimeAction, NoConfig>) -> SignalActorBuilder {
         let mut box_builder = SimpleMessageBoxBuilder::new("Signal-Handler", 1);
-        box_builder.add_sink(runtime);
+        box_builder.add_sink(NoConfig, runtime);
         SignalActorBuilder { box_builder }
     }
 }