exante 0.2.0

HTTP client for Exante REST API version 3.0
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

use crate::ClientError;
use http::HeaderValue;
use rustify::{Endpoint, MiddleWare};

#[derive(Clone)]
pub(crate) struct Middle {
    credentials: HeaderValue,
}

impl Middle {
    pub(crate) fn new(api_key: &str, secret_key: &str) -> Self {
        Self {
            credentials: basic_auth(api_key, secret_key),
        }
    }
}

impl MiddleWare for Middle {
    fn request<E: Endpoint>(
        &self,
        _endpoint: &E,
        req: &mut http::Request<Vec<u8>>,
    ) -> Result<(), ClientError> {
        req.headers_mut()
            .append(http::header::AUTHORIZATION, self.credentials.clone());
        Ok(())
    }

    fn response<E: Endpoint>(
        &self,
        _endpoint: &E,
        _resp: &mut http::Response<Vec<u8>>,
    ) -> Result<(), ClientError> {
        Ok(())
    }
}

fn basic_auth(username: &str, password: &str) -> HeaderValue {
    use base64::prelude::BASE64_STANDARD;
    use base64::write::EncoderWriter;
    use std::io::Write;

    let mut buf = b"Basic ".to_vec();
    {
        let mut encoder = EncoderWriter::new(&mut buf, &BASE64_STANDARD);
        let _ = write!(encoder, "{username}:{password}");
    }
    let mut header = HeaderValue::from_bytes(&buf).expect("base64 is always valid HeaderValue");
    header.set_sensitive(true);
    header
}