alpaca-data 0.10.2

High-performance Rust client for Alpaca Market Data API
Documentation 
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

#[allow(dead_code)]
#[derive(Clone, Debug, Default, Eq, PartialEq)]
pub(crate) struct QueryWriter {
    pairs: Vec<(String, String)>,
}

#[allow(dead_code)]
impl QueryWriter {
    pub(crate) fn push_csv<I, S>(&mut self, key: &'static str, values: I)
    where
        I: IntoIterator<Item = S>,
        S: AsRef<str>,
    {
        let joined = values
            .into_iter()
            .map(|value| value.as_ref().to_string())
            .collect::<Vec<_>>()
            .join(",");

        if !joined.is_empty() {
            self.pairs.push((key.to_string(), joined));
        }
    }

    pub(crate) fn push_opt<T>(&mut self, key: &'static str, value: Option<T>)
    where
        T: ToString,
    {
        if let Some(value) = value {
            self.pairs.push((key.to_string(), value.to_string()));
        }
    }

    pub(crate) fn finish(self) -> Vec<(String, String)> {
        self.pairs
    }
}

#[cfg(test)]
mod tests {
    use super::QueryWriter;

    #[test]
    fn query_writer_joins_symbols_and_skips_none() {
        let mut query = QueryWriter::default();
        query.push_csv("symbols", ["AAPL", "MSFT"]);
        query.push_opt("limit", Some(100u32));
        query.push_opt::<u32>("page_token", None);

        assert_eq!(
            query.finish(),
            vec![
                ("symbols".to_string(), "AAPL,MSFT".to_string()),
                ("limit".to_string(), "100".to_string()),
            ]
        );
    }
}