Create generic tedge configuration plugin

Cargo.toml

@@ -10,6 +10,7 @@ members = [
     "plugins/c8y_log_plugin",
     "plugins/c8y_remote_access_plugin",
     "plugins/tedge_apt_plugin",
+    "plugins/tedge_configuration_plugin",
     "plugins/tedge_dummy_plugin",
     "plugins/tedge_log_plugin",
 ]
@@ -129,6 +130,7 @@ tedge_api = { path = "crates/core/tedge_api" }
 tedge_config = { path = "crates/common/tedge_config" }
 tedge_config_macros = { path = "crates/common/tedge_config_macros" }
 tedge_config_macros-impl = { path = "crates/common/tedge_config_macros/impl" }
+tedge_config_manager = { path = "crates/extensions/tedge_config_manager" }
 tedge_downloader_ext = { path = "crates/extensions/tedge_downloader_ext" }
 tedge_file_system_ext = { path = "crates/extensions/tedge_file_system_ext" }
 tedge_health_ext = { path = "crates/extensions/tedge_health_ext" }

crates/core/tedge_api/src/messages.rs

@@ -671,6 +671,73 @@ impl LogUploadCmdPayload {
     }
 }
 
+#[derive(Debug, Deserialize, Serialize, Eq, PartialEq, Clone)]
+#[serde(rename_all = "camelCase")]
+pub struct ConfigSnapshotCmdPayload {
+    pub status: CommandStatus,
+    pub tedge_url: String,
+    #[serde(rename = "type")]
+    pub config_type: String,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub path: Option<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub reason: Option<String>,
+}
+
+impl<'a> Jsonify<'a> for ConfigSnapshotCmdPayload {}
+
+impl ConfigSnapshotCmdPayload {
+    pub fn executing(&mut self) {
+        self.status = CommandStatus::Executing;
+        self.reason = None;
+    }
+
+    pub fn successful(&mut self, path: impl Into<String>) {
+        self.status = CommandStatus::Successful;
+        self.reason = None;
+        self.path = Some(path.into())
+    }
+
+    pub fn failed(&mut self, reason: impl Into<String>) {
+        self.status = CommandStatus::Failed;
+        self.reason = Some(reason.into());
+    }
+}
+
+#[derive(Debug, Deserialize, Serialize, Eq, PartialEq, Clone)]
+#[serde(rename_all = "camelCase")]
+pub struct ConfigUpdateCmdPayload {
+    pub status: CommandStatus,
+    pub tedge_url: String,
+    pub remote_url: String,
+    #[serde(rename = "type")]
+    pub config_type: String,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub path: Option<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub reason: Option<String>,
+}
+
+impl<'a> Jsonify<'a> for ConfigUpdateCmdPayload {}
+
+impl ConfigUpdateCmdPayload {
+    pub fn executing(&mut self) {
+        self.status = CommandStatus::Executing;
+        self.reason = None;
+    }
+
+    pub fn successful(&mut self, path: impl Into<String>) {
+        self.status = CommandStatus::Successful;
+        self.reason = None;
+        self.path = Some(path.into())
+    }
+
+    pub fn failed(&mut self, reason: impl Into<String>) {
+        self.status = CommandStatus::Failed;
+        self.reason = Some(reason.into());
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;

crates/core/tedge_api/src/mqtt_topics.rs

@@ -424,6 +424,8 @@ pub enum OperationType {
     SoftwareList,
     SoftwareUpdate,
     LogUpload,
+    ConfigSnapshot,
+    ConfigUpdate,
     Custom(String),
 }
 
@@ -436,6 +438,8 @@ impl FromStr for OperationType {
             "software_list" => Ok(OperationType::SoftwareList),
             "software_update" => Ok(OperationType::SoftwareUpdate),
             "log_upload" => Ok(OperationType::LogUpload),
+            "config_snapshot" => Ok(OperationType::ConfigSnapshot),
+            "config_update" => Ok(OperationType::ConfigUpdate),
             operation => Ok(OperationType::Custom(operation.to_string())),
         }
     }
@@ -448,6 +452,8 @@ impl Display for OperationType {
             OperationType::SoftwareList => write!(f, "software_list"),
             OperationType::SoftwareUpdate => write!(f, "software_update"),
             OperationType::LogUpload => write!(f, "log_upload"),
+            OperationType::ConfigSnapshot => write!(f, "config_snapshot"),
+            OperationType::ConfigUpdate => write!(f, "config_update"),
             OperationType::Custom(operation) => write!(f, "{operation}"),
         }
     }

crates/extensions/tedge_config_manager/Cargo.toml

@@ -0,0 +1,34 @@
+[package]
+name = "tedge_config_manager"
+description = "thin-edge extension adding support for configuration management"
+version = { workspace = true }
+authors = { workspace = true }
+edition = { workspace = true }
+rust-version = { workspace = true }
+license = { workspace = true }
+homepage = { workspace = true }
+repository = { workspace = true }
+
+[dependencies]
+async-trait = { workspace = true }
+http = { workspace = true }
+log = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+tedge_actors = { workspace = true }
+tedge_api = { workspace = true }
+tedge_config = { workspace = true }
+tedge_downloader_ext = { workspace = true }
+tedge_file_system_ext = { workspace = true }
+tedge_http_ext = { workspace = true }
+tedge_mqtt_ext = { workspace = true }
+tedge_utils = { workspace = true }
+thiserror = { workspace = true }
+toml = { workspace = true }
+
+[dev-dependencies]
+anyhow = { workspace = true }
+tedge_actors = { workspace = true, features = ["test-helpers"] }
+tedge_http_ext = { workspace = true, features = ["test_helpers"] }
+tedge_test_utils = { workspace = true }
+tokio = { workspace = true, features = ["macros"] }