open_feature_flagd/resolver/in_process/model/
flag_parser.rs

1use super::feature_flag::FeatureFlag;
2use super::feature_flag::ParsingResult;
3use anyhow::Result;
4use serde_json::{Map, Value};
5use std::collections::HashMap;
6
7pub struct FlagParser;
8
9impl FlagParser {
10    pub fn parse_string(configuration: &str) -> Result<ParsingResult> {
11        let value: Value = serde_json::from_str(configuration)?;
12        let obj = value
13            .as_object()
14            .ok_or_else(|| anyhow::anyhow!("Invalid JSON structure"))?;
15
16        let flags = obj
17            .get("flags")
18            .and_then(|v| v.as_object())
19            .ok_or_else(|| anyhow::anyhow!("No flag configurations found in the payload"))?;
20
21        let flag_set_metadata = obj
22            .get("metadata")
23            .and_then(|v| v.as_object())
24            .map(|m| Self::convert_map_to_hashmap(m))
25            .unwrap_or_default();
26
27        let mut flag_map = HashMap::new();
28        for (key, value) in flags {
29            let flag: FeatureFlag = serde_json::from_value(value.clone())?;
30            flag_map.insert(key.clone(), flag);
31        }
32
33        Ok(ParsingResult {
34            flags: flag_map,
35            flag_set_metadata,
36        })
37    }
38
39    fn convert_map_to_hashmap(map: &Map<String, Value>) -> HashMap<String, serde_json::Value> {
40        map.iter().map(|(k, v)| (k.clone(), v.clone())).collect()
41    }
42}