bitwarden_api_api/apis/
self_hosted_organization_licenses_api.rs

1/*
2 * Bitwarden Internal API
3 *
4 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
5 *
6 * The version of the OpenAPI document: latest
7 *
8 * Generated by: https://openapi-generator.tech
9 */
10
11use std::sync::Arc;
12
13use async_trait::async_trait;
14#[cfg(feature = "mockall")]
15use mockall::automock;
16use reqwest;
17use serde::{Deserialize, Serialize, de::Error as _};
18
19use super::{Error, configuration};
20use crate::{
21    apis::{AuthRequired, ContentType, ResponseContent},
22    models,
23};
24
25#[cfg_attr(feature = "mockall", automock)]
26#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
27#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
28pub trait SelfHostedOrganizationLicensesApi: Send + Sync {
29    /// POST /organizations/licenses/self-hosted
30    async fn create_license<'a>(
31        &self,
32        key: &'a str,
33        keys_public_key: &'a str,
34        keys_encrypted_private_key: &'a str,
35        license: std::path::PathBuf,
36        collection_name: Option<&'a str>,
37    ) -> Result<models::OrganizationResponseModel, Error<CreateLicenseError>>;
38
39    /// POST /organizations/licenses/self-hosted/{id}/sync
40    async fn sync_license<'a>(&self, id: &'a str) -> Result<(), Error<SyncLicenseError>>;
41
42    /// POST /organizations/licenses/self-hosted/{id}
43    async fn update_license<'a>(
44        &self,
45        id: &'a str,
46        license: std::path::PathBuf,
47    ) -> Result<(), Error<UpdateLicenseError>>;
48}
49
50pub struct SelfHostedOrganizationLicensesApiClient {
51    configuration: Arc<configuration::Configuration>,
52}
53
54impl SelfHostedOrganizationLicensesApiClient {
55    pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
56        Self { configuration }
57    }
58}
59
60#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
61#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
62impl SelfHostedOrganizationLicensesApi for SelfHostedOrganizationLicensesApiClient {
63    async fn create_license<'a>(
64        &self,
65        key: &'a str,
66        keys_public_key: &'a str,
67        keys_encrypted_private_key: &'a str,
68        license: std::path::PathBuf,
69        collection_name: Option<&'a str>,
70    ) -> Result<models::OrganizationResponseModel, Error<CreateLicenseError>> {
71        let local_var_configuration = &self.configuration;
72
73        let local_var_client = &local_var_configuration.client;
74
75        let local_var_uri_str = format!(
76            "{}/organizations/licenses/self-hosted",
77            local_var_configuration.base_path
78        );
79        let mut local_var_req_builder =
80            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
81
82        local_var_req_builder = local_var_req_builder.query(&[("key", &key.to_string())]);
83        if let Some(ref param_value) = collection_name {
84            local_var_req_builder =
85                local_var_req_builder.query(&[("collectionName", &param_value.to_string())]);
86        }
87        local_var_req_builder =
88            local_var_req_builder.query(&[("keys.publicKey", &keys_public_key.to_string())]);
89        local_var_req_builder = local_var_req_builder.query(&[(
90            "keys.encryptedPrivateKey",
91            &keys_encrypted_private_key.to_string(),
92        )]);
93        if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
94            local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
95        };
96        local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
97        let mut local_var_form = reqwest::multipart::Form::new();
98        // TODO: support file upload for 'license' parameter
99        local_var_req_builder = local_var_req_builder.multipart(local_var_form);
100
101        let local_var_req = local_var_req_builder.build()?;
102        let local_var_resp = local_var_client.execute(local_var_req).await?;
103
104        let local_var_status = local_var_resp.status();
105        let local_var_content_type = local_var_resp
106            .headers()
107            .get("content-type")
108            .and_then(|v| v.to_str().ok())
109            .unwrap_or("application/octet-stream");
110        let local_var_content_type = super::ContentType::from(local_var_content_type);
111        let local_var_content = local_var_resp.text().await?;
112
113        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
114            match local_var_content_type {
115                ContentType::Json => serde_json::from_str(&local_var_content).map_err(Error::from),
116                ContentType::Text => {
117                    return Err(Error::from(serde_json::Error::custom(
118                        "Received `text/plain` content type response that cannot be converted to `models::OrganizationResponseModel`",
119                    )));
120                }
121                ContentType::Unsupported(local_var_unknown_type) => {
122                    return Err(Error::from(serde_json::Error::custom(format!(
123                        "Received `{local_var_unknown_type}` content type response that cannot be converted to `models::OrganizationResponseModel`"
124                    ))));
125                }
126            }
127        } else {
128            let local_var_entity: Option<CreateLicenseError> =
129                serde_json::from_str(&local_var_content).ok();
130            let local_var_error = ResponseContent {
131                status: local_var_status,
132                content: local_var_content,
133                entity: local_var_entity,
134            };
135            Err(Error::ResponseError(local_var_error))
136        }
137    }
138
139    async fn sync_license<'a>(&self, id: &'a str) -> Result<(), Error<SyncLicenseError>> {
140        let local_var_configuration = &self.configuration;
141
142        let local_var_client = &local_var_configuration.client;
143
144        let local_var_uri_str = format!(
145            "{}/organizations/licenses/self-hosted/{id}/sync",
146            local_var_configuration.base_path,
147            id = crate::apis::urlencode(id)
148        );
149        let mut local_var_req_builder =
150            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
151
152        if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
153            local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
154        };
155        local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
156
157        let local_var_req = local_var_req_builder.build()?;
158        let local_var_resp = local_var_client.execute(local_var_req).await?;
159
160        let local_var_status = local_var_resp.status();
161        let local_var_content = local_var_resp.text().await?;
162
163        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
164            Ok(())
165        } else {
166            let local_var_entity: Option<SyncLicenseError> =
167                serde_json::from_str(&local_var_content).ok();
168            let local_var_error = ResponseContent {
169                status: local_var_status,
170                content: local_var_content,
171                entity: local_var_entity,
172            };
173            Err(Error::ResponseError(local_var_error))
174        }
175    }
176
177    async fn update_license<'a>(
178        &self,
179        id: &'a str,
180        license: std::path::PathBuf,
181    ) -> Result<(), Error<UpdateLicenseError>> {
182        let local_var_configuration = &self.configuration;
183
184        let local_var_client = &local_var_configuration.client;
185
186        let local_var_uri_str = format!(
187            "{}/organizations/licenses/self-hosted/{id}",
188            local_var_configuration.base_path,
189            id = crate::apis::urlencode(id)
190        );
191        let mut local_var_req_builder =
192            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
193
194        if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
195            local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
196        };
197        local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
198        let mut local_var_form = reqwest::multipart::Form::new();
199        // TODO: support file upload for 'license' parameter
200        local_var_req_builder = local_var_req_builder.multipart(local_var_form);
201
202        let local_var_req = local_var_req_builder.build()?;
203        let local_var_resp = local_var_client.execute(local_var_req).await?;
204
205        let local_var_status = local_var_resp.status();
206        let local_var_content = local_var_resp.text().await?;
207
208        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
209            Ok(())
210        } else {
211            let local_var_entity: Option<UpdateLicenseError> =
212                serde_json::from_str(&local_var_content).ok();
213            let local_var_error = ResponseContent {
214                status: local_var_status,
215                content: local_var_content,
216                entity: local_var_entity,
217            };
218            Err(Error::ResponseError(local_var_error))
219        }
220    }
221}
222
223/// struct for typed errors of method [`SelfHostedOrganizationLicensesApi::create_license`]
224#[derive(Debug, Clone, Serialize, Deserialize)]
225#[serde(untagged)]
226pub enum CreateLicenseError {
227    UnknownValue(serde_json::Value),
228}
229/// struct for typed errors of method [`SelfHostedOrganizationLicensesApi::sync_license`]
230#[derive(Debug, Clone, Serialize, Deserialize)]
231#[serde(untagged)]
232pub enum SyncLicenseError {
233    UnknownValue(serde_json::Value),
234}
235/// struct for typed errors of method [`SelfHostedOrganizationLicensesApi::update_license`]
236#[derive(Debug, Clone, Serialize, Deserialize)]
237#[serde(untagged)]
238pub enum UpdateLicenseError {
239    UnknownValue(serde_json::Value),
240}
bitwarden_api_api/apis/self_hosted_organization_licenses_api.rs

bitwarden_api_api/apis/
self_hosted_organization_licenses_api.rs
