bitwarden_api_api/apis/
teams_integration_api.rs1use 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 TeamsIntegrationApi: Send + Sync {
29 async fn create<'a>(
31 &self,
32 code: Option<&'a str>,
33 state: Option<&'a str>,
34 ) -> Result<(), Error<CreateError>>;
35
36 async fn incoming_post(&self) -> Result<(), Error<IncomingPostError>>;
38
39 async fn redirect<'a>(&self, organization_id: uuid::Uuid) -> Result<(), Error<RedirectError>>;
41}
42
43pub struct TeamsIntegrationApiClient {
44 configuration: Arc<configuration::Configuration>,
45}
46
47impl TeamsIntegrationApiClient {
48 pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
49 Self { configuration }
50 }
51}
52
53#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
54#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
55impl TeamsIntegrationApi for TeamsIntegrationApiClient {
56 async fn create<'a>(
57 &self,
58 code: Option<&'a str>,
59 state: Option<&'a str>,
60 ) -> Result<(), Error<CreateError>> {
61 let local_var_configuration = &self.configuration;
62
63 let local_var_client = &local_var_configuration.client;
64
65 let local_var_uri_str = format!(
66 "{}/organizations/integrations/teams/create",
67 local_var_configuration.base_path
68 );
69 let mut local_var_req_builder =
70 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
71
72 if let Some(ref param_value) = code {
73 local_var_req_builder =
74 local_var_req_builder.query(&[("code", ¶m_value.to_string())]);
75 }
76 if let Some(ref param_value) = state {
77 local_var_req_builder =
78 local_var_req_builder.query(&[("state", ¶m_value.to_string())]);
79 }
80 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
81
82 let local_var_resp = local_var_req_builder.send().await?;
83
84 let local_var_status = local_var_resp.status();
85 let local_var_content = local_var_resp.text().await?;
86
87 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
88 Ok(())
89 } else {
90 let local_var_entity: Option<CreateError> =
91 serde_json::from_str(&local_var_content).ok();
92 let local_var_error = ResponseContent {
93 status: local_var_status,
94 content: local_var_content,
95 entity: local_var_entity,
96 };
97 Err(Error::ResponseError(local_var_error))
98 }
99 }
100
101 async fn incoming_post(&self) -> Result<(), Error<IncomingPostError>> {
102 let local_var_configuration = &self.configuration;
103
104 let local_var_client = &local_var_configuration.client;
105
106 let local_var_uri_str = format!(
107 "{}/organizations/integrations/teams/incoming",
108 local_var_configuration.base_path
109 );
110 let mut local_var_req_builder =
111 local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
112
113 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
114
115 let local_var_resp = local_var_req_builder.send().await?;
116
117 let local_var_status = local_var_resp.status();
118 let local_var_content = local_var_resp.text().await?;
119
120 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
121 Ok(())
122 } else {
123 let local_var_entity: Option<IncomingPostError> =
124 serde_json::from_str(&local_var_content).ok();
125 let local_var_error = ResponseContent {
126 status: local_var_status,
127 content: local_var_content,
128 entity: local_var_entity,
129 };
130 Err(Error::ResponseError(local_var_error))
131 }
132 }
133
134 async fn redirect<'a>(&self, organization_id: uuid::Uuid) -> Result<(), Error<RedirectError>> {
135 let local_var_configuration = &self.configuration;
136
137 let local_var_client = &local_var_configuration.client;
138
139 let local_var_uri_str = format!(
140 "{}/organizations/{organizationId}/integrations/teams/redirect",
141 local_var_configuration.base_path,
142 organizationId = organization_id
143 );
144 let mut local_var_req_builder =
145 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
146
147 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
148
149 let local_var_resp = local_var_req_builder.send().await?;
150
151 let local_var_status = local_var_resp.status();
152 let local_var_content = local_var_resp.text().await?;
153
154 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
155 Ok(())
156 } else {
157 let local_var_entity: Option<RedirectError> =
158 serde_json::from_str(&local_var_content).ok();
159 let local_var_error = ResponseContent {
160 status: local_var_status,
161 content: local_var_content,
162 entity: local_var_entity,
163 };
164 Err(Error::ResponseError(local_var_error))
165 }
166 }
167}
168
169#[derive(Debug, Clone, Serialize, Deserialize)]
171#[serde(untagged)]
172pub enum CreateError {
173 UnknownValue(serde_json::Value),
174}
175#[derive(Debug, Clone, Serialize, Deserialize)]
177#[serde(untagged)]
178pub enum IncomingPostError {
179 UnknownValue(serde_json::Value),
180}
181#[derive(Debug, Clone, Serialize, Deserialize)]
183#[serde(untagged)]
184pub enum RedirectError {
185 UnknownValue(serde_json::Value),
186}