pattrick 0.7.0

Pattrick is a command line tool for managing Personal Access Tokens (PAT) in Azure DevOps.
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

use std::error::Error;

use reqwest::Method;

use crate::{
    ListTokenResponse, PatToken, PatTokenListRequest, PatTokenManager,
    crud::error::DEVOPS_ERROR_MESSAGE,
};

impl PatTokenManager {
    /// List PAT tokens
    ///
    /// # Example
    ///
    /// ```rust,no_run
    /// use pattrick::{PatTokenManager, PatTokenListRequest, DisplayFilterOption};
    /// use pattrick::azure::get_ad_token_for_devops;
    ///
    /// # tokio_test::block_on(async {
    /// let pat_manager = PatTokenManager::new(get_ad_token_for_devops(1).await?).await?;
    ///
    /// let pat_tokens = pat_manager.list_pat_tokens(
    ///     PatTokenListRequest {
    ///         display_filter_option: DisplayFilterOption::All
    ///     }
    /// ).await?;
    /// # Ok::<(), Box<dyn std::error::Error>>(())});
    /// ```
    pub async fn list_pat_tokens(
        &self,
        list_request: PatTokenListRequest,
    ) -> Result<Vec<PatToken>, Box<dyn Error>> {
        let mut pat_tokens: Vec<PatToken> = Vec::new();
        let response = self
            .base_request(Method::GET, &self.pat_url)
            .query(&[("displayFilterOption", &list_request.display_filter_option)])
            .send()
            .await?;

        log::debug!("Response: {:#?}", response);
        match response.error_for_status() {
            Ok(response) => {
                log::debug!("{:#?}", response);
                let mut lt_result = response.json::<ListTokenResponse>().await?;
                pat_tokens.append(&mut lt_result.pat_tokens);

                while let Some(token) = &lt_result.continuation_token {
                    if token.is_empty() {
                        return Ok(pat_tokens);
                    }
                    let response = self
                        .base_request(Method::GET, &self.pat_url)
                        .query(&[("displayFilterOption", &list_request.display_filter_option)])
                        .query(&[("continuationToken", token)])
                        .send()
                        .await?;

                    lt_result = response.json::<ListTokenResponse>().await?;
                    pat_tokens.append(&mut lt_result.pat_tokens);
                }

                Ok(pat_tokens)
            }
            Err(e) => {
                if let Some(status) = e.status()
                    && status.is_client_error()
                {
                    return Err::<Vec<PatToken>, Box<dyn Error>>(DEVOPS_ERROR_MESSAGE.into());
                }
                Err::<Vec<PatToken>, Box<dyn Error>>(Box::new(e))
            }
        }
    }
}