huskarl-core 0.8.1

Base library for huskarl (OAuth2 client) ecosystem.
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

use bytes::Bytes;
use http::{HeaderMap, StatusCode};
use serde::de::DeserializeOwned;
use snafu::prelude::*;

use crate::{
    error::{Error, ErrorKind},
    http::{HttpClient, Idempotency},
};

/// Source error for non-2xx responses; the kind-level classification is
/// [`ErrorKind::Protocol`].
#[derive(Debug, Snafu)]
#[snafu(display("bad status: {status}"))]
pub(crate) struct BadStatusError {
    status: StatusCode,
    body: Bytes,
}

pub(crate) async fn get<T: DeserializeOwned>(
    http_client: &dyn HttpClient,
    uri: http::Uri,
    headers: HeaderMap,
) -> Result<T, Error> {
    let (mut parts, ()) = http::Request::new(()).into_parts();
    parts.headers = headers;
    parts.uri = uri;
    let request = http::Request::from_parts(parts, Bytes::new());

    let response = http_client
        .execute(request, Idempotency::Idempotent)
        .await?;

    if response.status.is_success() {
        serde_json::from_slice(&response.body)
            .map_err(|source| Error::new(ErrorKind::Protocol, source))
    } else {
        Err(Error::new(
            ErrorKind::Protocol,
            BadStatusSnafu {
                status: response.status,
                body: response.body,
            }
            .build(),
        ))
    }
}