diff options
author | Lukasz Woznicki <75632179+makr11st@users.noreply.github.com> | 2022-01-19 13:05:05 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-01-19 13:05:05 +0000 |
commit | 31b5dd2a3b00a28fcbd85d1c8883ca2ab8283a16 (patch) | |
tree | 1940deee45ffd4103fc742b2dd02315b43fd0af0 /crates/core/tedge_mapper/src/c8y_converter.rs | |
parent | 924814805cd8a0ec8897cb9b88784fd7935657f1 (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.rs | 7 |
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"); |