1 files changed, 101 insertions, 0 deletions
diff --git a/plugins/c8y_log_plugin/src/config.rs b/plugins/c8y_log_plugin/src/config.rs
new file mode 100644
index 00000000..580fba95
--- /dev/null
+++ b/plugins/c8y_log_plugin/src/config.rs
@@ -0,0 +1,101 @@
+use c8y_smartrest::topic::C8yTopic;
+use mqtt_channel::Message;
+use serde::Deserialize;
+use std::{borrow::Borrow, path::Path};
+use std::{collections::HashSet, fs};
+use tracing::warn;
+
+#[derive(Deserialize, Debug, Eq, PartialEq, Default)]
+#[serde(deny_unknown_fields)]
+pub struct LogPluginConfig {
+    pub files: Vec<FileEntry>,
+}
+
+#[derive(Deserialize, Debug, Eq, Default, Clone)]
+#[serde(deny_unknown_fields)]
+pub struct FileEntry {
+    pub(crate) path: String,
+    #[serde(rename = "type")]
+    pub config_type: String,
+}
+
+impl PartialEq for FileEntry {
+    fn eq(&self, other: &Self) -> bool {
+        self.config_type == other.config_type
+    }
+}
+
+impl Borrow<String> for FileEntry {
+    fn borrow(&self) -> &String {
+        &self.config_type
+    }
+}
+
+impl LogPluginConfig {
+    pub fn new(config_file_path: &Path) -> Self {
+        let config = Self::read_config(config_file_path);
+        config
+    }
+
+    pub fn read_config(path: &Path) -> Self {
+        let path_str = path.display().to_string();
+        match fs::read_to_string(path) {
+            Ok(contents) => match toml::from_str(contents.as_str()) {
+                Ok(config) => config,
+                _ => {
+                    warn!("The config file {} is malformed.", path_str);
+                    Self::default()
+                }
+            },
+            Err(_) => {
+                warn!(
+                    "The config file {} does not exist or is not readable.",
+                    path_str
+                );
+                Self::default()
+            }
+        }
+    }
+
+    pub fn to_supported_config_types_message(&self) -> Result<Message, anyhow::Error> {
+        let topic = C8yTopic::SmartRestResponse.to_topic()?;
+        Ok(Message::new(&topic, self.to_smartrest_payload()))
+    }
+
+    pub fn get_all_file_types(&self) -> Vec<String> {
+        self.files
+            .iter()
+            .map(|x| x.config_type.to_string())
+            .collect::<HashSet<_>>()
+            .iter()
+            .map(|x| x.to_string())
+            .collect::<Vec<_>>()
+    }
+
+    // 118,typeA,typeB,...
+    fn to_smartrest_payload(&self) -> String {
+        let mut config_types = self.get_all_file_types();
+        let () = config_types.sort();
+        let supported_config_types = config_types.join(",");
+        format!("118,{supported_config_types}")
+    }
+}
+
+#[test]
+fn test_no_duplicated_file_types() {
+    let files = vec![
+        FileEntry {
+            path: "a/path".to_string(),
+            config_type: "type_one".to_string(),
+        },
+        FileEntry {
+            path: "some/path".to_string(),
+            config_type: "type_one".to_string(),
+        },
+    ];
+    let logs_config = LogPluginConfig { files: files };
+    assert_eq!(
+        logs_config.get_all_file_types(),
+        vec!["type_one".to_string()]
+    );
+}