summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/c8y/converter.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/core/tedge_mapper/src/c8y/converter.rs')
-rw-r--r--crates/core/tedge_mapper/src/c8y/converter.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/crates/core/tedge_mapper/src/c8y/converter.rs b/crates/core/tedge_mapper/src/c8y/converter.rs
index 9ec58cb0..fd9223b5 100644
--- a/crates/core/tedge_mapper/src/c8y/converter.rs
+++ b/crates/core/tedge_mapper/src/c8y/converter.rs
@@ -357,13 +357,13 @@ where
message: &DiscoverOp,
) -> Result<Option<Message>, ConversionError> {
match message.event_type {
- EventType::ADD => {
+ EventType::Add => {
let ops_dir = message.ops_dir.clone();
let op_name = message.operation_name.clone();
let op = get_operation(ops_dir.join(op_name))?;
self.operations.add_operation(op);
}
- EventType::REMOVE => {
+ EventType::Remove => {
self.operations.remove_operation(&message.operation_name);
}
}
@@ -379,7 +379,7 @@ async fn parse_c8y_topics(
) -> Result<Vec<Message>, ConversionError> {
match process_smartrest(
message.payload_str()?,
- &operations,
+ operations,
http_proxy,
operation_logs,
)
@@ -721,7 +721,7 @@ async fn process_smartrest(
match message_id {
"528" => forward_software_request(payload, http_proxy).await,
"510" => forward_restart_request(payload),
- template => forward_operation_request(payload, template, &operations, operation_logs).await,
+ template => forward_operation_request(payload, template, operations, operation_logs).await,
}
}