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::{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 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
81 local_var_req_builder = local_var_req_builder
82 .header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
83 }
84 if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
85 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
86 };
87
88 let local_var_req = local_var_req_builder.build()?;
89 let local_var_resp = local_var_client.execute(local_var_req).await?;
90
91 let local_var_status = local_var_resp.status();
92 let local_var_content = local_var_resp.text().await?;
93
94 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
95 Ok(())
96 } else {
97 let local_var_entity: Option<CreateError> =
98 serde_json::from_str(&local_var_content).ok();
99 let local_var_error = ResponseContent {
100 status: local_var_status,
101 content: local_var_content,
102 entity: local_var_entity,
103 };
104 Err(Error::ResponseError(local_var_error))
105 }
106 }
107
108 async fn incoming_post(&self) -> Result<(), Error<IncomingPostError>> {
109 let local_var_configuration = &self.configuration;
110
111 let local_var_client = &local_var_configuration.client;
112
113 let local_var_uri_str = format!(
114 "{}/organizations/integrations/teams/incoming",
115 local_var_configuration.base_path
116 );
117 let mut local_var_req_builder =
118 local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
119
120 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
121 local_var_req_builder = local_var_req_builder
122 .header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
123 }
124 if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
125 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
126 };
127
128 let local_var_req = local_var_req_builder.build()?;
129 let local_var_resp = local_var_client.execute(local_var_req).await?;
130
131 let local_var_status = local_var_resp.status();
132 let local_var_content = local_var_resp.text().await?;
133
134 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
135 Ok(())
136 } else {
137 let local_var_entity: Option<IncomingPostError> =
138 serde_json::from_str(&local_var_content).ok();
139 let local_var_error = ResponseContent {
140 status: local_var_status,
141 content: local_var_content,
142 entity: local_var_entity,
143 };
144 Err(Error::ResponseError(local_var_error))
145 }
146 }
147
148 async fn redirect<'a>(&self, organization_id: uuid::Uuid) -> Result<(), Error<RedirectError>> {
149 let local_var_configuration = &self.configuration;
150
151 let local_var_client = &local_var_configuration.client;
152
153 let local_var_uri_str = format!(
154 "{}/organizations/{organizationId}/integrations/teams/redirect",
155 local_var_configuration.base_path,
156 organizationId = organization_id
157 );
158 let mut local_var_req_builder =
159 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
160
161 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
162 local_var_req_builder = local_var_req_builder
163 .header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
164 }
165 if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
166 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
167 };
168
169 let local_var_req = local_var_req_builder.build()?;
170 let local_var_resp = local_var_client.execute(local_var_req).await?;
171
172 let local_var_status = local_var_resp.status();
173 let local_var_content = local_var_resp.text().await?;
174
175 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
176 Ok(())
177 } else {
178 let local_var_entity: Option<RedirectError> =
179 serde_json::from_str(&local_var_content).ok();
180 let local_var_error = ResponseContent {
181 status: local_var_status,
182 content: local_var_content,
183 entity: local_var_entity,
184 };
185 Err(Error::ResponseError(local_var_error))
186 }
187 }
188}
189
190#[derive(Debug, Clone, Serialize, Deserialize)]
192#[serde(untagged)]
193pub enum CreateError {
194 UnknownValue(serde_json::Value),
195}
196#[derive(Debug, Clone, Serialize, Deserialize)]
198#[serde(untagged)]
199pub enum IncomingPostError {
200 UnknownValue(serde_json::Value),
201}
202#[derive(Debug, Clone, Serialize, Deserialize)]
204#[serde(untagged)]
205pub enum RedirectError {
206 UnknownValue(serde_json::Value),
207}