Integrate moneo mapper plugin in tedge-cli

Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>

4 files changed, 48 insertions, 0 deletions

diff --git a/Cargo.lock b/Cargo.lock
index 5a13076d..7c8019e6 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3312,6 +3312,7 @@ dependencies = [
  "plugin_inotify",
  "plugin_log",
  "plugin_measurement_filter",
+ "plugin_moneo_mapper",
  "plugin_mqtt",
  "plugin_mqtt_measurement_bridge",
  "plugin_sysstat",
diff --git a/tedge/Cargo.toml b/tedge/Cargo.toml
index c951e7ca..bc6f0064 100644
--- a/tedge/Cargo.toml
+++ b/tedge/Cargo.toml
@@ -30,6 +30,7 @@ plugin_httpstop = { path = "../plugins/plugin_httpstop", optional = true }
 plugin_measurement_filter = { path = "../plugins/plugin_measurement_filter", optional = true }
 plugin_mqtt = { path = "../plugins/plugin_mqtt", optional = true }
 plugin_mqtt_measurement_bridge = { path = "../plugins/plugin_mqtt_measurement_bridge", optional = true }
+plugin_moneo_mapper = { path = "../plugins/plugin_moneo_mapper", optional = true }
 
 
 [features]
@@ -51,6 +52,8 @@ builtin_plugin_sysstat = ["plugin_sysstat"]
 builtin_plugin_inotify = ["plugin_inotify"]
 builtin_plugin_httpstop = ["plugin_httpstop"]
 builtin_plugin_measurement_filter = ["plugin_measurement_filter"]
+builtin_plugin_moneo_mapper  = ["plugin_moneo_mapper"]
 
 mqtt = ["plugin_mqtt", "plugin_mqtt_measurement_bridge"]
+moneo = ["plugin_moneo_mapper"]
 
diff --git a/tedge/example-moneo.toml b/tedge/example-moneo.toml
new file mode 100644
index 00000000..e4025ccf
--- /dev/null
+++ b/tedge/example-moneo.toml
@@ -0,0 +1,37 @@
+communication_buffer_size = 10
+
+plugin_shutdown_timeout_ms = 10000
+
+[plugins]
+
+
+
+[plugins.logging]
+kind = "log"
+
+[plugins.logging.configuration]
+name = "logging"
+level = "trace"
+acknowledge = false
+setup_logger = false
+
+
+[plugins.plugmqtt]
+kind = "mqtt"
+
+[plugins.plugmqtt.configuration]
+host = "tcp://localhost:1883"
+target = "moneo"
+
+[[plugins.plugmqtt.configuration.subscriptions]]
+topic = "foodebetzma/suitevdevice/0000/80/X80/Timecounter/cds"
+qos = "at_most_once"
+
+
+[plugins.moneo]
+kind = "moneo_mapper"
+
+[plugins.moneo.configuration]
+target = "logging"
+
+
diff --git a/tedge/src/main.rs b/tedge/src/main.rs
index 210f02f0..904c0c43 100644
--- a/tedge/src/main.rs
+++ b/tedge/src/main.rs
@@ -119,6 +119,13 @@ async fn main() -> miette::Result<()> {
         plugin_mqtt_measurement_bridge::MqttMeasurementBridgePluginBuilder::new()
     );
 
+    let application = register_plugin!(
+        application,
+        "moneo",
+        plugin_moneo_mapper::MoneoMapperPluginBuilder,
+        plugin_moneo_mapper::MoneoMapperPluginBuilder
+    );
+
     let (cancel_sender, application) = application.with_config(config)?;
     info!("Application built");