Updated settings REST API

crates/utils/Cargo.toml

@@ -41,6 +41,8 @@ proxy-header = { version = "0.1.0", features = ["tokio"] }
 regex = "1.7.0"
 blake3 = "1.3.3"
 lru-cache = "0.1.2"
+http-body-util = "0.1.0"
+form_urlencoded = "1.1.0"
 
 [target.'cfg(unix)'.dependencies]
 privdrop = "0.5.3"

crates/utils/src/config/mod.rs

@@ -187,8 +187,8 @@ impl Config {
         config
     }
 
-    pub fn update(&mut self, config: Self) {
-        self.keys.extend(config.keys);
+    pub fn update(&mut self, settings: Vec<(String, String)>) {
+        self.keys.extend(settings);
     }
 }
 

crates/utils/src/lib.rs

@@ -35,6 +35,7 @@ pub mod lru_cache;
 pub mod map;
 pub mod snowflake;
 pub mod suffixlist;
+pub mod url_params;
 
 use opentelemetry::KeyValue;
 use opentelemetry_otlp::WithExportConfig;

crates/utils/src/url_params.rs

@@ -0,0 +1,58 @@
+/*
+ * Copyright (c) 2023 Stalwart Labs Ltd.
+ *
+ * This file is part of Stalwart Mail Server.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of
+ * the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ * in the LICENSE file at the top-level directory of this distribution.
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * You can be released from the requirements of the AGPLv3 license by
+ * purchasing a commercial license. Please contact licensing@stalw.art
+ * for more details.
+*/
+
+use std::{borrow::Cow, collections::HashMap};
+
+#[derive(Default)]
+pub struct UrlParams<'x> {
+    params: HashMap<Cow<'x, str>, Cow<'x, str>>,
+}
+
+impl<'x> UrlParams<'x> {
+    pub fn new(query: Option<&'x str>) -> Self {
+        if let Some(query) = query {
+            Self {
+                params: form_urlencoded::parse(query.as_bytes())
+                    .filter(|(_, value)| !value.is_empty())
+                    .collect(),
+            }
+        } else {
+            Self::default()
+        }
+    }
+
+    pub fn get(&self, key: &str) -> Option<&str> {
+        self.params.get(key).map(|v| v.as_ref())
+    }
+
+    pub fn has_key(&self, key: &str) -> bool {
+        self.params.contains_key(key)
+    }
+
+    pub fn parse<T>(&self, key: &str) -> Option<T>
+    where
+        T: std::str::FromStr,
+    {
+        self.get(key).and_then(|v| v.parse().ok())
+    }
+}