summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDidier Wenzek <didier.wenzek@acidalie.com>2022-01-07 12:02:41 +0000
committerGitHub <noreply@github.com>2022-01-07 12:02:41 +0000
commita33a155dc458ad038db9f46f7751f8b34a6e9144 (patch)
tree2e9e4547c9961787e3680fa1abd3d19a1a503e31
parenta8539884e7cb0f84ea2973f53ddd8fc2dd3b360b (diff)
Remove capabilities messages on tedge agent start (#741)
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr> Co-authored-by: Didier Wenzek <didier.wenzek@free.fr>
-rw-r--r--crates/core/tedge_agent/src/agent.rs12
1 files changed, 0 insertions, 12 deletions
diff --git a/crates/core/tedge_agent/src/agent.rs b/crates/core/tedge_agent/src/agent.rs
index 3764523a..b915d748 100644
--- a/crates/core/tedge_agent/src/agent.rs
+++ b/crates/core/tedge_agent/src/agent.rs
@@ -195,8 +195,6 @@ impl SmAgent {
let () = self.process_pending_operation(&mqtt).await?;
- // * Maybe it would be nice if mapper/registry responds
- let () = publish_capabilities(&mqtt).await?;
while let Err(error) = self
.process_subscribed_messages(&mqtt, &mut operations, &plugins)
.await
@@ -526,16 +524,6 @@ fn get_default_plugin(
Ok(tedge_config.query_string_optional(SoftwarePluginDefaultSetting)?)
}
-async fn publish_capabilities(mqtt: &Client) -> Result<(), AgentError> {
- mqtt.publish(Message::new(&Topic::new("tedge/capabilities/software/list")?, "").retain())
- .await?;
-
- mqtt.publish(Message::new(&Topic::new("tedge/capabilities/software/update")?, "").retain())
- .await?;
-
- Ok(())
-}
-
#[cfg(test)]
mod tests {
use super::*;