weg_li_api 0.1.4

Making working with the weg.li API more convenient
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
133
134
135
136
137

mod charge;
mod district;
pub mod error;
pub mod export;
mod notice;
pub mod request;
pub mod util;

use std::{
    path::{Path, PathBuf},
    str::FromStr,
};

use anyhow::anyhow;
use charge::{get_charge_from_wegli_api, get_charges_from_wegli_api};
use district::{get_district_from_wegli_api, get_districts_from_wegli_api};
use error::ApiError;
use export::{download_latest_export_from_wegli, get_exports_from_wegli_api};
use notice::{get_notice_from_wegli_api, get_notices_from_wegli_api};
use url::Url;

use crate::types::{
    charge::Charge, district::District, export::Export, notice::Notice, request::RetrySettings,
};

pub struct WegLiApiClient {
    api_url: Url,
    api_token: String,
    /// Retry settings for exponential backoff are activated by default (initial_backoff_ms: 300, max_retries: 5, backoff_multiplier: 2).
    /// If you do not want to retry, provide a retry_settings argument with max_retries set to 0.
    pub retry_settings: Option<RetrySettings>,
}

impl WegLiApiClient {
    pub fn new(
        api_url: &String,
        api_token: &String,
        retry_settings: Option<RetrySettings>,
    ) -> Result<Self, anyhow::Error> {
        Ok(WegLiApiClient {
            api_url: match Url::from_str(&api_url) {
                Err(error) => return Err(anyhow!(error)),
                Ok(url) => url,
            },
            api_token: api_token.to_string(),
            retry_settings,
        })
    }
    /// Get a single notice of the authenticated user by its token
    pub async fn get_notice(&self, notice_token: &String) -> Result<Notice, ApiError> {
        return get_notice_from_wegli_api(
            &self.api_url,
            &self.api_token,
            notice_token,
            &self.retry_settings,
        )
        .await;
    }
    /// Get all notices of the authenticated user
    pub async fn get_notices(&self) -> Result<Vec<Notice>, ApiError> {
        return get_notices_from_wegli_api(&self.api_url, &self.api_token, &self.retry_settings)
            .await;
    }
    /// Get a single charge by its tbnr
    pub async fn get_charge(&self, tbnr: &String) -> Result<Charge, ApiError> {
        return get_charge_from_wegli_api(
            &self.api_url,
            &self.api_token,
            tbnr,
            &self.retry_settings,
        )
        .await;
    }
    /// Get all charges
    pub async fn get_charges(&self) -> Result<Vec<Charge>, ApiError> {
        return get_charges_from_wegli_api(&self.api_url, &self.api_token, &self.retry_settings)
            .await;
    }
    /// Get a single district by zip code
    pub async fn get_district(&self, zip: &String) -> Result<District, ApiError> {
        return get_district_from_wegli_api(
            &self.api_url,
            &self.api_token,
            zip,
            &self.retry_settings,
        )
        .await;
    }
    /// Get all districts
    pub async fn get_districts(&self) -> Result<Vec<District>, ApiError> {
        return get_districts_from_wegli_api(&self.api_url, &self.api_token, &self.retry_settings)
            .await;
    }
    /// Get metadata of exports of the currently authenticated user
    pub async fn get_user_exports(&self) -> Result<Vec<Export>, ApiError> {
        return get_exports_from_wegli_api(
            &self.api_url,
            &self.api_token,
            false,
            &self.retry_settings,
        )
        .await;
    }
    /// Get metadata of all public exports
    pub async fn get_public_exports(&self) -> Result<Vec<Export>, ApiError> {
        return get_exports_from_wegli_api(
            &self.api_url,
            &self.api_token,
            true,
            &self.retry_settings,
        )
        .await;
    }
    /// Download the latest notice export archive
    ///
    /// The `path` is where the zip archive is downloaded and extracted if `unzip` is `true`.
    ///
    /// `public` gets the publicly available export if set to `true`, otherwise the authenticated user's ones.
    ///
    /// Returns the path to the zip file if `unzip` is `false``, otherwise the path to the first (and as of current weg.li behavior only) .csv file extracted.
    pub async fn download_latest_export(
        &self,
        path: &Path,
        public: bool,
        unzip: bool,
    ) -> Result<PathBuf, anyhow::Error> {
        return download_latest_export_from_wegli(
            &self.api_url,
            &self.api_token,
            path,
            public,
            unzip,
            &self.retry_settings,
        )
        .await;
    }
}