cloud_terrastodon_azure_devops 0.35.0

Helpers for interacting with Azure DevOps for the Cloud Terrastodon project
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

use cloud_terrastodon_azure_devops_types::AzureDevOpsDescriptor;
use cloud_terrastodon_azure_devops_types::AzureDevOpsOrganizationUrl;
use cloud_terrastodon_command::CacheKey;
use cloud_terrastodon_command::CommandBuilder;
use cloud_terrastodon_command::CommandKind;
use cloud_terrastodon_command::async_trait;
use serde::Deserialize;
use std::path::PathBuf;

pub fn fetch_azure_devops_groups_for_member<'a>(
    org_url: &'a AzureDevOpsOrganizationUrl,
    member_id: &'a AzureDevOpsDescriptor,
) -> AzureDevOpsGroupsForMemberRequest<'a> {
    AzureDevOpsGroupsForMemberRequest { org_url, member_id }
}

pub struct AzureDevOpsGroupsForMemberRequest<'a> {
    pub org_url: &'a AzureDevOpsOrganizationUrl,
    pub member_id: &'a AzureDevOpsDescriptor,
}

#[derive(Debug, Deserialize)]
pub struct AzureDevOpsGroupsForMemberResponse {
    pub count: usize,
    pub value: Vec<AzureDevOpsGroupsForMemberResponseEntry>,
}
#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct AzureDevOpsGroupsForMemberResponseEntry {
    pub container_descriptor: AzureDevOpsDescriptor,
    pub member_descriptor: AzureDevOpsDescriptor,
    #[serde(rename = "_links")]
    pub _links: serde_json::Value,
}

#[async_trait]
impl<'a> cloud_terrastodon_command::CacheableCommand for AzureDevOpsGroupsForMemberRequest<'a> {
    type Output = Vec<AzureDevOpsGroupsForMemberResponseEntry>;

    fn cache_key(&self) -> CacheKey {
        CacheKey::new(PathBuf::from_iter([
            "az",
            "devops",
            self.org_url.organization_name.as_ref(),
            "graph",
            "memberships",
            self.member_id.to_string().as_ref(),
        ]))
    }

    async fn run(self) -> eyre::Result<Self::Output> {
        let organization = &self.org_url.organization_name;
        let subject_descriptor = self.member_id;
        let url = format!(
            "https://vssps.dev.azure.com/{organization}/_apis/graph/Memberships/{subject_descriptor}?api-version=7.1-preview.1&direction=up",
            organization = organization,
            subject_descriptor = subject_descriptor
        );
        let mut cmd = CommandBuilder::new(CommandKind::CloudTerrastodon);
        cmd.cache(self.cache_key());
        cmd.args([
            "az",
            "devops",
            "rest",
            "--method",
            "GET",
            "--url",
            url.as_ref(),
        ]);
        Ok(cmd.run::<AzureDevOpsGroupsForMemberResponse>().await?.value)
    }
}

cloud_terrastodon_command::impl_cacheable_into_future!(AzureDevOpsGroupsForMemberRequest<'a>, 'a);

#[cfg(test)]
mod test {
    use crate::fetch_azure_devops_groups_for_member;
    use crate::fetch_azure_devops_user_license_entitlements;
    use crate::get_default_organization_url;

    #[tokio::test]
    pub async fn it_works() -> eyre::Result<()> {
        let org_url = get_default_organization_url().await?;
        let users = fetch_azure_devops_user_license_entitlements(&org_url).await?;
        for user in users.iter().take(2) {
            let groups_for_user =
                fetch_azure_devops_groups_for_member(&org_url, &user.user.descriptor).await?;
            assert!(
                groups_for_user
                    .iter()
                    .all(|entry| entry.member_descriptor == user.user.descriptor)
            );
        }
        Ok(())
    }
}