api_bindium 0.4.0

Framework for api binding crates
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
59
60
61
62
63

use snafu::ResultExt;
use ureq::Agent;
use ureq::Body;
use ureq::RequestBuilder;
use ureq::http::Response;
use ureq::typestate::WithBody;
use ureq::typestate::WithoutBody;

use crate::ApiRequest;
use crate::ApiRequestError;
use crate::HTTPVerb;
use crate::error::UreqSnafu;

impl<T> ApiRequest<T> {
    /// Convert the API request into a ureq request and sends it
    #[cfg_attr(feature = "hotpath", hotpath::measure)]
    pub(super) fn convert_and_send(
        &self,
        agent: &Agent,
    ) -> Result<Response<Body>, ApiRequestError> {
        #[cfg(feature = "tracing")]
        tracing::debug!(
            "Sending {} request at {} (Try {})",
            self.verb,
            self.uri,
            self.tries
        );

        match &self.verb {
            HTTPVerb::Get => {
                let req = self.config_req(agent.get(self.uri()));
                Self::send_without_body(req).context(UreqSnafu {
                    uri: self.uri().clone(),
                })
            }

            HTTPVerb::Post => {
                let req = self.config_req(agent.post(self.uri()));
                Self::send_with_body(req, self.body.clone()).context(UreqSnafu {
                    uri: self.uri().clone(),
                })
            }
        }
    }

    /// Send the ureq request in another thread
    #[cfg_attr(feature = "hotpath", hotpath::measure)]
    fn send_without_body(req: RequestBuilder<WithoutBody>) -> Result<Response<Body>, ureq::Error> {
        req.call()
    }

    /// Send the ureq request with a body in another thread
    #[cfg_attr(feature = "hotpath", hotpath::measure)]
    fn send_with_body(
        req: RequestBuilder<WithBody>,
        body: Option<serde_json::Value>,
    ) -> Result<Response<Body>, ureq::Error> {
        match body {
            None => req.send_empty(),
            Some(body) => req.send_json(body),
        }
    }
}