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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

use std::time::Duration;

#[cfg(feature = "use_tokio")]
use reqwest::Client;
use tracing::info;
use url::Url;

#[derive(Debug, Clone)]
pub struct FPConfig {
    pub remote_url: Url,
    pub toggles_url: Option<Url>,
    pub events_url: Option<Url>,
    pub server_sdk_key: String,
    pub refresh_interval: Duration,
    #[cfg(feature = "use_tokio")]
    pub http_client: Option<Client>,
    pub start_wait: Option<Duration>,

    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
    pub realtime_url: Option<Url>,
    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
    pub realtime_path: Option<String>,
}

#[derive(Debug, Clone)]
pub(crate) struct Config {
    pub toggles_url: Url,
    pub events_url: Url,
    pub server_sdk_key: String,
    pub refresh_interval: Duration,
    #[cfg(feature = "use_tokio")]
    pub http_client: Option<Client>,
    pub start_wait: Option<Duration>,

    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
    pub realtime_url: Url,
    #[cfg(all(feature = "use_tokio", feature = "realtime"))]
    pub realtime_path: String,
}

impl Default for FPConfig {
    fn default() -> Self {
        Self {
            server_sdk_key: "".to_owned(),
            remote_url: Url::parse("https://featureprobe.io/server").unwrap(),
            toggles_url: None,
            events_url: None,
            refresh_interval: Duration::from_secs(5),
            start_wait: None,
            #[cfg(feature = "use_tokio")]
            http_client: None,

            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_url: None,
            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_path: None,
        }
    }
}

impl Default for Config {
    fn default() -> Self {
        Self {
            server_sdk_key: "".to_owned(),
            toggles_url: Url::parse("https://featureprobe.io/server/api/server-sdk/toggles")
                .unwrap(),
            events_url: Url::parse("https://featureprobe.io/server/api/events").unwrap(),
            refresh_interval: Duration::from_secs(60),
            start_wait: None,
            #[cfg(feature = "use_tokio")]
            http_client: None,

            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_url: Url::parse("https://featureprobe.io/server/realtime").unwrap(),
            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_path: "/server/realtime".to_owned(),
        }
    }
}

impl FPConfig {
    pub(crate) fn build(&self) -> Config {
        info!("build_config from {:?}", self);
        let remote_url = self.remote_url.to_string();
        let remote_url = match remote_url.ends_with('/') {
            true => remote_url,
            false => remote_url + "/",
        };

        #[cfg(all(feature = "use_tokio", feature = "realtime"))]
        let realtime_url = match &self.realtime_url {
            None => Url::parse(&(remote_url.clone() + "realtime")).expect("invalid realtime url"),
            Some(url) => url.to_owned(),
        };

        #[cfg(all(feature = "use_tokio", feature = "realtime"))]
        let realtime_path = match &self.realtime_path {
            Some(p) => p.to_owned(),
            None => realtime_url.path().to_owned(),
        };

        let toggles_url = match &self.toggles_url {
            None => Url::parse(&(remote_url.clone() + "api/server-sdk/toggles"))
                .expect("invalid toggles url"),
            Some(url) => url.to_owned(),
        };

        let events_url = match &self.events_url {
            None => Url::parse(&(remote_url + "api/events")).expect("invalid events url"),
            Some(url) => url.to_owned(),
        };

        Config {
            toggles_url,
            events_url,
            server_sdk_key: self.server_sdk_key.clone(),
            refresh_interval: self.refresh_interval,
            start_wait: self.start_wait,
            #[cfg(feature = "use_tokio")]
            http_client: self.http_client.clone(),
            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_url,
            #[cfg(all(feature = "use_tokio", feature = "realtime"))]
            realtime_path,
        }
    }
}