opendal/services/yandex_disk/
config.rs1use std::fmt::Debug;
19use std::fmt::Formatter;
20
21use super::backend::YandexDiskBuilder;
22use serde::Deserialize;
23use serde::Serialize;
24
25#[derive(Default, Serialize, Deserialize, Clone, PartialEq, Eq)]
27#[serde(default)]
28#[non_exhaustive]
29pub struct YandexDiskConfig {
30    pub root: Option<String>,
34    pub access_token: String,
36}
37
38impl Debug for YandexDiskConfig {
39    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
40        let mut ds = f.debug_struct("Config");
41
42        ds.field("root", &self.root);
43
44        ds.finish()
45    }
46}
47
48impl crate::Configurator for YandexDiskConfig {
49    type Builder = YandexDiskBuilder;
50
51    fn from_uri(uri: &crate::types::OperatorUri) -> crate::Result<Self> {
52        let mut map = uri.options().clone();
53
54        if let Some(root) = uri.root() {
55            if !root.is_empty() {
56                map.insert("root".to_string(), root.to_string());
57            }
58        }
59
60        Self::from_iter(map)
61    }
62
63    #[allow(deprecated)]
64    fn into_builder(self) -> Self::Builder {
65        YandexDiskBuilder {
66            config: self,
67            http_client: None,
68        }
69    }
70}
71
72#[cfg(test)]
73mod tests {
74    use super::*;
75    use crate::Configurator;
76    use crate::types::OperatorUri;
77
78    #[test]
79    fn from_uri_sets_root_and_preserves_token() {
80        let uri = OperatorUri::new(
81            "yandex-disk://disk/root/path",
82            vec![("access_token".to_string(), "secret".to_string())],
83        )
84        .unwrap();
85
86        let cfg = YandexDiskConfig::from_uri(&uri).unwrap();
87        assert_eq!(cfg.root.as_deref(), Some("root/path"));
88        assert_eq!(cfg.access_token, "secret".to_string());
89    }
90}