bitwarden_api_api/apis/
security_task_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 SecurityTaskApi: Send + Sync {
29 async fn bulk_create_tasks<'a>(
31 &self,
32 org_id: uuid::Uuid,
33 bulk_create_security_tasks_request_model: Option<
34 models::BulkCreateSecurityTasksRequestModel,
35 >,
36 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error>;
37
38 async fn complete<'a>(&self, task_id: uuid::Uuid) -> Result<(), Error>;
40
41 async fn get<'a>(
43 &self,
44 status: Option<models::SecurityTaskStatus>,
45 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error>;
46
47 async fn get_task_metrics_for_organization<'a>(
49 &self,
50 organization_id: uuid::Uuid,
51 ) -> Result<models::SecurityTaskMetricsResponseModel, Error>;
52
53 async fn list_for_organization<'a>(
55 &self,
56 organization_id: Option<uuid::Uuid>,
57 status: Option<models::SecurityTaskStatus>,
58 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error>;
59}
60
61pub struct SecurityTaskApiClient {
62 configuration: Arc<configuration::Configuration>,
63}
64
65impl SecurityTaskApiClient {
66 pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
67 Self { configuration }
68 }
69}
70
71#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
72#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
73impl SecurityTaskApi for SecurityTaskApiClient {
74 async fn bulk_create_tasks<'a>(
75 &self,
76 org_id: uuid::Uuid,
77 bulk_create_security_tasks_request_model: Option<
78 models::BulkCreateSecurityTasksRequestModel,
79 >,
80 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error> {
81 let local_var_configuration = &self.configuration;
82
83 let local_var_client = &local_var_configuration.client;
84
85 let local_var_uri_str = format!(
86 "{}/tasks/{orgId}/bulk-create",
87 local_var_configuration.base_path,
88 orgId = org_id
89 );
90 let mut local_var_req_builder =
91 local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
92
93 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
94 local_var_req_builder =
95 local_var_req_builder.json(&bulk_create_security_tasks_request_model);
96
97 bitwarden_api_base::process_with_json_response(local_var_req_builder).await
98 }
99
100 async fn complete<'a>(&self, task_id: uuid::Uuid) -> Result<(), Error> {
101 let local_var_configuration = &self.configuration;
102
103 let local_var_client = &local_var_configuration.client;
104
105 let local_var_uri_str = format!(
106 "{}/tasks/{taskId}/complete",
107 local_var_configuration.base_path,
108 taskId = task_id
109 );
110 let mut local_var_req_builder =
111 local_var_client.request(reqwest::Method::PATCH, local_var_uri_str.as_str());
112
113 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
114
115 bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
116 }
117
118 async fn get<'a>(
119 &self,
120 status: Option<models::SecurityTaskStatus>,
121 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error> {
122 let local_var_configuration = &self.configuration;
123
124 let local_var_client = &local_var_configuration.client;
125
126 let local_var_uri_str = format!("{}/tasks", local_var_configuration.base_path);
127 let mut local_var_req_builder =
128 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
129
130 if let Some(ref param_value) = status {
131 local_var_req_builder =
132 local_var_req_builder.query(&[("status", ¶m_value.to_string())]);
133 }
134 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
135
136 bitwarden_api_base::process_with_json_response(local_var_req_builder).await
137 }
138
139 async fn get_task_metrics_for_organization<'a>(
140 &self,
141 organization_id: uuid::Uuid,
142 ) -> Result<models::SecurityTaskMetricsResponseModel, Error> {
143 let local_var_configuration = &self.configuration;
144
145 let local_var_client = &local_var_configuration.client;
146
147 let local_var_uri_str = format!(
148 "{}/tasks/{organizationId}/metrics",
149 local_var_configuration.base_path,
150 organizationId = organization_id
151 );
152 let mut local_var_req_builder =
153 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
154
155 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
156
157 bitwarden_api_base::process_with_json_response(local_var_req_builder).await
158 }
159
160 async fn list_for_organization<'a>(
161 &self,
162 organization_id: Option<uuid::Uuid>,
163 status: Option<models::SecurityTaskStatus>,
164 ) -> Result<models::SecurityTasksResponseModelListResponseModel, Error> {
165 let local_var_configuration = &self.configuration;
166
167 let local_var_client = &local_var_configuration.client;
168
169 let local_var_uri_str = format!("{}/tasks/organization", local_var_configuration.base_path);
170 let mut local_var_req_builder =
171 local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
172
173 if let Some(ref param_value) = organization_id {
174 local_var_req_builder =
175 local_var_req_builder.query(&[("organizationId", ¶m_value.to_string())]);
176 }
177 if let Some(ref param_value) = status {
178 local_var_req_builder =
179 local_var_req_builder.query(&[("status", ¶m_value.to_string())]);
180 }
181 local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
182
183 bitwarden_api_base::process_with_json_response(local_var_req_builder).await
184 }
185}