1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

use std::collections::HashMap;

use serde_json::{Map, Value};

use crate::{
    ovsdb::db::{parse_str_map, OvsDbUpdate, GLOBAL_CONFIG_TABLE},
    MergedOvsDbGlobalConfig, OvsDbGlobalConfig,
};

impl From<&Map<std::string::String, Value>> for OvsDbGlobalConfig {
    fn from(m: &Map<std::string::String, Value>) -> Self {
        let mut ret = Self::default();
        if let (Some(Value::Array(ids)), Some(Value::Array(other_cfg))) =
            (m.get("external_ids"), m.get("other_config"))
        {
            ret.external_ids = Some(convert_map(parse_str_map(ids)));
            ret.other_config = Some(convert_map(parse_str_map(other_cfg)));
        }
        ret
    }
}

// Convert HashMap<String, String> to HashMap<String, Option<String>>
fn convert_map(
    mut m: HashMap<String, String>,
) -> HashMap<String, Option<String>> {
    let mut ret = HashMap::new();
    for (k, v) in m.drain() {
        ret.insert(k, Some(v));
    }
    ret
}

impl From<&MergedOvsDbGlobalConfig> for OvsDbUpdate {
    fn from(ovs_conf: &MergedOvsDbGlobalConfig) -> Self {
        let mut row = HashMap::new();
        let mut value_array = Vec::new();
        for (k, v) in ovs_conf.external_ids.iter() {
            if let Some(v) = v {
                value_array.push(Value::Array(vec![
                    Value::String(k.to_string()),
                    Value::String(v.to_string()),
                ]));
            }
        }
        row.insert(
            "external_ids".to_string(),
            Value::Array(vec![
                Value::String("map".to_string()),
                Value::Array(value_array),
            ]),
        );
        let mut value_array = Vec::new();
        for (k, v) in ovs_conf.other_config.iter() {
            if let Some(v) = v {
                value_array.push(Value::Array(vec![
                    Value::String(k.to_string()),
                    Value::String(v.to_string()),
                ]));
            }
        }
        row.insert(
            "other_config".to_string(),
            Value::Array(vec![
                Value::String("map".to_string()),
                Value::Array(value_array),
            ]),
        );

        OvsDbUpdate {
            table: GLOBAL_CONFIG_TABLE.to_string(),
            conditions: vec![],
            row,
        }
    }
}