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

use crate::oss;

use self::builders::{DeleteBucketPolicyBuilder, GetBucketPolicyBuilder, PutBucketPolicyBuilder};

pub mod builders {
    use crate::oss::{
        self,
        api::{self, ApiResponseFrom},
        http,
    };

    pub struct PutBucketPolicyBuilder<'a> {
        client: &'a oss::Client<'a>,
        policy: &'a str,
    }

    impl<'a> PutBucketPolicyBuilder<'a> {
        pub(crate) fn new(client: &'a oss::Client) -> Self {
            Self {
                client,
                policy: Default::default(),
            }
        }

        pub fn with_policy(mut self, value: &'a str) -> Self {
            self.policy = value;
            self
        }

        pub async fn execute(&self) -> api::ApiResult<()> {
            let res = format!("/{}/?{}", self.client.bucket(), "policy");
            let url = format!("{}/?{}", self.client.base_url(), "policy");

            let data = oss::Bytes::from(self.policy.to_string());

            let resp = self
                .client
                .request
                .task()
                .with_url(&url)
                .with_resource(&res)
                .with_method(http::Method::PUT)
                .with_body(data)
                .execute()
                .await?;

            Ok(ApiResponseFrom(resp).to_empty().await)
        }
    }

    pub struct GetBucketPolicyBuilder<'a> {
        client: &'a oss::Client<'a>,
    }

    impl<'a> GetBucketPolicyBuilder<'a> {
        pub(crate) fn new(client: &'a oss::Client) -> Self {
            Self { client }
        }

        pub async fn execute(&self) -> api::ApiResult<String> {
            let res = format!("/{}/?{}", self.client.options.bucket, "policy");
            let url = format!("{}/?{}", self.client.options.base_url(), "policy");

            let resp = self
                .client
                .request
                .task()
                .with_url(&url)
                .with_resource(&res)
                .execute()
                .await?;

            Ok(ApiResponseFrom(resp).to_text().await)
        }
    }

    pub struct DeleteBucketPolicyBuilder<'a> {
        client: &'a oss::Client<'a>,
    }

    impl<'a> DeleteBucketPolicyBuilder<'a> {
        pub(crate) fn new(client: &'a oss::Client) -> Self {
            Self { client }
        }

        pub async fn execute(&self) -> api::ApiResult {
            let res = format!("/{}/?{}", self.client.options.bucket, "policy");
            let url = format!("{}/?{}", self.client.options.base_url(), "policy");

            let resp = self
                .client
                .request
                .task()
                .with_url(&url)
                .with_resource(&res)
                .with_method(http::Method::DELETE)
                .execute()
                .await?;

            Ok(ApiResponseFrom(resp).to_empty().await)
        }
    }
}

/// # 授权策略`Policy`
#[allow(non_snake_case)]
impl<'a> oss::Client<'a> {
    /// PutBucketPolicy接口用于为指定的存储空间`Bucket`设置授权策略`Policy`。
    ///
    /// - [official docs](https://help.aliyun.com/zh/oss/developer-reference/putbucketpolicy)
    /// - [xtoss example](https://github.com/isme-sun/xt_oss/blob/main/examples/api_bucket_policy_put.rs)
    pub fn PutBucketPolicy(&self) -> PutBucketPolicyBuilder {
        PutBucketPolicyBuilder::new(self)
    }

    /// GetBucketPolicy用于获取指定存储空间`Bucket`的权限策略`Policy`。
    ///
    /// - [official docs](https://help.aliyun.com/zh/oss/developer-reference/getbucketpolicy)
    /// - [xtoss example](https://github.com/isme-sun/xt_oss/blob/main/examples/api_bucket_policy_get.rs)
    pub fn GetBucketPolicy(&self) -> GetBucketPolicyBuilder {
        GetBucketPolicyBuilder::new(self)
    }

    /// DeleteBucketPolicy用于删除指定存储空间`Bucket`的权限策略`Policy`。
    ///
    /// - [official docs](https://help.aliyun.com/zh/oss/developer-reference/deletebucketpolicy)
    /// - [xtoss example](https://github.com/isme-sun/xt_oss/blob/main/examples/api_bucket_policy_del.rs)
    pub fn DeleteBucketPolicy(&self) -> DeleteBucketPolicyBuilder {
        DeleteBucketPolicyBuilder::new(self)
    }
}