cloud_terrastodon_azure 0.36.0

Helpers for interacting with Azure 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

use crate::bust_oauth2_permission_grants_cache;
use cloud_terrastodon_azure_types::AzureTenantId;
use cloud_terrastodon_azure_types::OAuth2PermissionGrantId;
use cloud_terrastodon_command::CacheKey;
use cloud_terrastodon_command::CacheableCommand;
use cloud_terrastodon_command::async_trait;
use cloud_terrastodon_rest::RestRequest;
use http::Method;
use serde::Serialize;
use std::path::PathBuf;
use std::time::Duration;
use tracing::info;

pub struct OAuth2PermissionGrantUpdateRequest {
    pub tenant_id: AzureTenantId,
    pub id: OAuth2PermissionGrantId,
    pub scope: String,
}

pub fn update_oauth2_permission_grant(
    tenant_id: AzureTenantId,
    id: OAuth2PermissionGrantId,
    scope: String,
) -> OAuth2PermissionGrantUpdateRequest {
    OAuth2PermissionGrantUpdateRequest {
        tenant_id,
        id,
        scope,
    }
}

#[async_trait]
impl CacheableCommand for OAuth2PermissionGrantUpdateRequest {
    type Output = ();

    fn cache_key(&self) -> CacheKey {
        CacheKey {
            path: PathBuf::from_iter([
                "ms",
                "graph",
                "PATCH",
                "oauth2PermissionGrants",
                self.tenant_id.to_string().as_str(),
                self.id.to_string().as_str(),
            ]),
            valid_for: Duration::ZERO,
        }
    }

    async fn run(self) -> eyre::Result<Self::Output> {
        let cache_key = self.cache_key();
        info!("Updating OAuth2 permission grant {}", self.id);
        let url = format!(
            "https://graph.microsoft.com/v1.0/oauth2PermissionGrants/{}",
            self.id
        );

        #[derive(Serialize)]
        struct UpdateBody {
            scope: String,
        }

        let body = UpdateBody { scope: self.scope };
        RestRequest::new(Method::PATCH, &url)?
            .tenant(self.tenant_id)
            .cache(cache_key)
            .body(serde_json::to_string_pretty(&body)?)
            .receive_raw()
            .await?;
        bust_oauth2_permission_grants_cache(self.tenant_id).await?;
        Ok(())
    }
}

cloud_terrastodon_command::impl_cacheable_into_future!(OAuth2PermissionGrantUpdateRequest);