Clear the retain message once the operation is done

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

crates/extensions/c8y_mapper_ext/src/log_upload.rs

@@ -21,6 +21,7 @@ use tedge_api::messages::LogUploadCmdPayload;
 use tedge_api::Jsonify;
 use tedge_mqtt_ext::Message;
 use tedge_mqtt_ext::MqttMessage;
+use tedge_mqtt_ext::QoS;
 use tedge_mqtt_ext::TopicFilter;
 use tedge_utils::file::create_directory_with_defaults;
 use tedge_utils::file::create_file_with_defaults;
@@ -134,15 +135,23 @@ impl CumulocityConverter {
                     .to_smartrest()?,
                 };
 
-                vec![Message::new(&smartrest_topic, smartrest_operation_status)]
+                let c8y_notification = Message::new(&smartrest_topic, smartrest_operation_status);
+                let clean_operation = Message::new(&message.topic, "")
+                    .with_retain()
+                    .with_qos(QoS::AtLeastOnce);
+                vec![c8y_notification, clean_operation]
             }
             CommandStatus::Failed => {
                 let smartrest_operation_status = SmartRestSetOperationToFailed::new(
                     CumulocitySupportedOperations::C8yLogFileRequest,
                     response.reason.clone().unwrap_or_default(),
                 )
                 .to_smartrest()?;
-                vec![Message::new(&smartrest_topic, smartrest_operation_status)]
+                let c8y_notification = Message::new(&smartrest_topic, smartrest_operation_status);
+                let clean_operation = Message::new(&message.topic, "")
+                    .with_retain()
+                    .with_qos(QoS::AtLeastOnce);
+                vec![c8y_notification, clean_operation]
             }
             _ => {
                 vec![] // Do nothing as other components might handle those states