nrfcloudlib 0.1.3

Library to interact with nrf cloud
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132

use log::info;

pub mod messages;

pub struct NRFCloudClient {
    client: reqwest::Client,
    token: String,
    base_url: String,
}

impl NRFCloudClient {
    pub fn new(token: &str) -> Self {
        Self {
            client: reqwest::Client::new(),
            token: token.to_string(),
            base_url: "https://api.nrfcloud.com/v1".to_string(),
        }
    }

    fn with_base_url(mut self, base_url: &str) -> Self {
        self.base_url = base_url.to_string();
        self
    }

    /// Makes a GET request to the specified endpoint
    ///
    /// # Arguments
    ///
    /// * `endpoint` - The API endpoint to call (will be appended to the base URL)
    ///
    /// # Returns
    ///
    /// A Result containing the response text or an error
    pub async fn get(&self, endpoint: &str) -> Result<String, reqwest::Error> {
        let url = format!("{}{}", self.base_url, endpoint);

        let response = self
            .client
            .get(&url)
            .header("Authorization", format!("Bearer {}", self.token))
            .send()
            .await?;

        info!("Response: {}", response.status());
        response.error_for_status()?.text().await
    }

    /// Makes a GET request with query parameters to the specified endpoint
    ///
    /// # Arguments
    ///
    /// * `endpoint` - The API endpoint to call (will be appended to the base URL)
    /// * `params` - Query parameters to include in the request
    ///
    /// # Returns
    ///
    /// A Result containing the response text or an error
    async fn get_with_params<T: serde::Serialize + ?Sized>(
        &self,
        endpoint: &str,
        params: &T,
    ) -> Result<String, reqwest::Error> {
        let url = format!("{}{}", self.base_url, endpoint);

        let response = self
            .client
            .get(&url)
            .header("Authorization", format!("Bearer {}", self.token))
            .query(params)
            .send()
            .await?;
        info!("Response: {}", response.status());

        response.error_for_status()?.text().await
    }

    /// Makes a GET request and deserializes the JSON response
    ///
    /// # Arguments
    ///
    /// * `endpoint` - The API endpoint to call (will be appended to the base URL)
    ///
    /// # Returns
    ///
    /// A Result containing the deserialized JSON response or an error
    async fn get_json<T: serde::de::DeserializeOwned>(
        &self,
        endpoint: &str,
    ) -> Result<T, reqwest::Error> {
        let url = format!("{}{}", self.base_url, endpoint);

        let response = self
            .client
            .get(&url)
            .header("Authorization", format!("Bearer {}", self.token))
            .send()
            .await?;

        info!("Response: {}", response.status());

        response.error_for_status()?.json::<T>().await
    }

    /// Makes a GET request with query parameters and deserializes the JSON response
    ///
    /// # Arguments
    ///
    /// * `endpoint` - The API endpoint to call (will be appended to the base URL)
    /// * `params` - Query parameters to include in the request
    ///
    /// # Returns
    ///
    /// A Result containing the deserialized JSON response or an error
    async fn get_json_with_params<P: serde::Serialize + ?Sized, T: serde::de::DeserializeOwned>(
        &self,
        endpoint: &str,
        params: &P,
    ) -> Result<T, reqwest::Error> {
        let url = format!("{}{}", self.base_url, endpoint);

        let response = self
            .client
            .get(&url)
            .header("Authorization", format!("Bearer {}", self.token))
            .query(params)
            .send()
            .await?;
        info!("Response: {}", response.status());

        response.error_for_status()?.json::<T>().await
    }
}