summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/c8y_converter.rs
diff options
context:
space:
mode:
authorLukasz Woznicki <75632179+makr11st@users.noreply.github.com>2022-01-19 13:05:05 +0000
committerGitHub <noreply@github.com>2022-01-19 13:05:05 +0000
commit31b5dd2a3b00a28fcbd85d1c8883ca2ab8283a16 (patch)
tree1940deee45ffd4103fc742b2dd02315b43fd0af0 /crates/core/tedge_mapper/src/c8y_converter.rs
parent924814805cd8a0ec8897cb9b88784fd7935657f1 (diff)
Operations execution from operations files. (#764)
* Add operations reading from operations file and execute when template called * Update docs * Update docs to list supported parameters Signed-off-by: Lukasz Woznicki <lukasz.woznicki@softwareag.com>
Diffstat (limited to 'crates/core/tedge_mapper/src/c8y_converter.rs')
-rw-r--r--crates/core/tedge_mapper/src/c8y_converter.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/crates/core/tedge_mapper/src/c8y_converter.rs b/crates/core/tedge_mapper/src/c8y_converter.rs
index 6fb9997a..ee85ade7 100644
--- a/crates/core/tedge_mapper/src/c8y_converter.rs
+++ b/crates/core/tedge_mapper/src/c8y_converter.rs
@@ -103,13 +103,14 @@ impl Converter for CumulocityConverter {
} else if input.topic.name.starts_with("tedge/alarms") {
self.try_convert_alarm(input)
} else {
- return Err(ConversionError::UnsupportedTopic(input.topic.name.clone()));
+ Err(ConversionError::UnsupportedTopic(input.topic.name.clone()))
}
}
fn try_init_messages(&self) -> Result<Vec<Message>, ConversionError> {
- let ops = Operations::try_new("/etc/tedge/operations")?;
- let ops = ops.get_operations_list("c8y");
+ let ops = Operations::try_new("/etc/tedge/operations", "c8y")?;
+ let ops = ops.get_operations_list();
+ let ops = ops.iter().map(|op| op as &str).collect::<Vec<&str>>();
let ops_msg = SmartRestSetSupportedOperations::new(&ops);
let topic = Topic::new_unchecked("c8y/s/us");