decthings-api 0.1.5

Official Rust API client for Decthings
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

use std::sync::Arc;

use super::DecthingsClientError;

#[derive(Clone, Default)]
pub(crate) struct HttpImpl {
    client: reqwest::Client,
}

impl HttpImpl {
    pub async fn get(
        &self,
        http_server_address: &str,
        api: &str,
        method: &str,
        body: Vec<u8>,
        api_key: Option<Arc<str>>,
        extra_headers: Arc<http::HeaderMap<http::HeaderValue>>,
    ) -> Result<bytes::Bytes, DecthingsClientError> {
        let mut builder = self
            .client
            .post(format!("{}/{}/{}", http_server_address, api, method))
            .header(reqwest::header::CONTENT_TYPE, "application/octet-stream")
            .body(body);
        if let Some(api_key) = api_key {
            builder = builder.bearer_auth(api_key);
        }

        for (key, value) in &*extra_headers {
            builder = builder.header(key, value);
        }
        let result = builder.send().await;
        let response = result
            .map_err(DecthingsClientError::Http)?
            .error_for_status()
            .map_err(DecthingsClientError::Http)?;
        response.bytes().await.map_err(DecthingsClientError::Http)
    }
}