bitwarden_api_api/apis/
security_task_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 reqwest;
12use serde::{Deserialize, Serialize};
13
14use super::{configuration, Error};
15use crate::{apis::ResponseContent, models};
16
17/// struct for typed errors of method [`tasks_get`]
18#[derive(Debug, Clone, Serialize, Deserialize)]
19#[serde(untagged)]
20pub enum TasksGetError {
21    UnknownValue(serde_json::Value),
22}
23
24/// struct for typed errors of method [`tasks_org_id_bulk_create_post`]
25#[derive(Debug, Clone, Serialize, Deserialize)]
26#[serde(untagged)]
27pub enum TasksOrgIdBulkCreatePostError {
28    UnknownValue(serde_json::Value),
29}
30
31/// struct for typed errors of method [`tasks_organization_get`]
32#[derive(Debug, Clone, Serialize, Deserialize)]
33#[serde(untagged)]
34pub enum TasksOrganizationGetError {
35    UnknownValue(serde_json::Value),
36}
37
38/// struct for typed errors of method [`tasks_task_id_complete_patch`]
39#[derive(Debug, Clone, Serialize, Deserialize)]
40#[serde(untagged)]
41pub enum TasksTaskIdCompletePatchError {
42    UnknownValue(serde_json::Value),
43}
44
45pub async fn tasks_get(
46    configuration: &configuration::Configuration,
47    status: Option<models::SecurityTaskStatus>,
48) -> Result<models::SecurityTasksResponseModelListResponseModel, Error<TasksGetError>> {
49    let local_var_configuration = configuration;
50
51    let local_var_client = &local_var_configuration.client;
52
53    let local_var_uri_str = format!("{}/tasks", local_var_configuration.base_path);
54    let mut local_var_req_builder =
55        local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
56
57    if let Some(ref local_var_str) = status {
58        local_var_req_builder =
59            local_var_req_builder.query(&[("status", &local_var_str.to_string())]);
60    }
61    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
62        local_var_req_builder =
63            local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
64    }
65    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
66        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
67    };
68
69    let local_var_req = local_var_req_builder.build()?;
70    let local_var_resp = local_var_client.execute(local_var_req).await?;
71
72    let local_var_status = local_var_resp.status();
73    let local_var_content = local_var_resp.text().await?;
74
75    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
76        serde_json::from_str(&local_var_content).map_err(Error::from)
77    } else {
78        let local_var_entity: Option<TasksGetError> = serde_json::from_str(&local_var_content).ok();
79        let local_var_error = ResponseContent {
80            status: local_var_status,
81            content: local_var_content,
82            entity: local_var_entity,
83        };
84        Err(Error::ResponseError(local_var_error))
85    }
86}
87
88pub async fn tasks_org_id_bulk_create_post(
89    configuration: &configuration::Configuration,
90    org_id: uuid::Uuid,
91    bulk_create_security_tasks_request_model: Option<models::BulkCreateSecurityTasksRequestModel>,
92) -> Result<models::SecurityTasksResponseModelListResponseModel, Error<TasksOrgIdBulkCreatePostError>>
93{
94    let local_var_configuration = configuration;
95
96    let local_var_client = &local_var_configuration.client;
97
98    let local_var_uri_str = format!(
99        "{}/tasks/{orgId}/bulk-create",
100        local_var_configuration.base_path,
101        orgId = crate::apis::urlencode(org_id.to_string())
102    );
103    let mut local_var_req_builder =
104        local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
105
106    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
107        local_var_req_builder =
108            local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
109    }
110    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
111        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
112    };
113    local_var_req_builder = local_var_req_builder.json(&bulk_create_security_tasks_request_model);
114
115    let local_var_req = local_var_req_builder.build()?;
116    let local_var_resp = local_var_client.execute(local_var_req).await?;
117
118    let local_var_status = local_var_resp.status();
119    let local_var_content = local_var_resp.text().await?;
120
121    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
122        serde_json::from_str(&local_var_content).map_err(Error::from)
123    } else {
124        let local_var_entity: Option<TasksOrgIdBulkCreatePostError> =
125            serde_json::from_str(&local_var_content).ok();
126        let local_var_error = ResponseContent {
127            status: local_var_status,
128            content: local_var_content,
129            entity: local_var_entity,
130        };
131        Err(Error::ResponseError(local_var_error))
132    }
133}
134
135pub async fn tasks_organization_get(
136    configuration: &configuration::Configuration,
137    organization_id: Option<uuid::Uuid>,
138    status: Option<models::SecurityTaskStatus>,
139) -> Result<models::SecurityTasksResponseModelListResponseModel, Error<TasksOrganizationGetError>> {
140    let local_var_configuration = configuration;
141
142    let local_var_client = &local_var_configuration.client;
143
144    let local_var_uri_str = format!("{}/tasks/organization", local_var_configuration.base_path);
145    let mut local_var_req_builder =
146        local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
147
148    if let Some(ref local_var_str) = organization_id {
149        local_var_req_builder =
150            local_var_req_builder.query(&[("organizationId", &local_var_str.to_string())]);
151    }
152    if let Some(ref local_var_str) = status {
153        local_var_req_builder =
154            local_var_req_builder.query(&[("status", &local_var_str.to_string())]);
155    }
156    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
157        local_var_req_builder =
158            local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
159    }
160    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
161        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
162    };
163
164    let local_var_req = local_var_req_builder.build()?;
165    let local_var_resp = local_var_client.execute(local_var_req).await?;
166
167    let local_var_status = local_var_resp.status();
168    let local_var_content = local_var_resp.text().await?;
169
170    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
171        serde_json::from_str(&local_var_content).map_err(Error::from)
172    } else {
173        let local_var_entity: Option<TasksOrganizationGetError> =
174            serde_json::from_str(&local_var_content).ok();
175        let local_var_error = ResponseContent {
176            status: local_var_status,
177            content: local_var_content,
178            entity: local_var_entity,
179        };
180        Err(Error::ResponseError(local_var_error))
181    }
182}
183
184pub async fn tasks_task_id_complete_patch(
185    configuration: &configuration::Configuration,
186    task_id: uuid::Uuid,
187) -> Result<(), Error<TasksTaskIdCompletePatchError>> {
188    let local_var_configuration = configuration;
189
190    let local_var_client = &local_var_configuration.client;
191
192    let local_var_uri_str = format!(
193        "{}/tasks/{taskId}/complete",
194        local_var_configuration.base_path,
195        taskId = crate::apis::urlencode(task_id.to_string())
196    );
197    let mut local_var_req_builder =
198        local_var_client.request(reqwest::Method::PATCH, local_var_uri_str.as_str());
199
200    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
201        local_var_req_builder =
202            local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
203    }
204    if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
205        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
206    };
207
208    let local_var_req = local_var_req_builder.build()?;
209    let local_var_resp = local_var_client.execute(local_var_req).await?;
210
211    let local_var_status = local_var_resp.status();
212    let local_var_content = local_var_resp.text().await?;
213
214    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
215        Ok(())
216    } else {
217        let local_var_entity: Option<TasksTaskIdCompletePatchError> =
218            serde_json::from_str(&local_var_content).ok();
219        let local_var_error = ResponseContent {
220            status: local_var_status,
221            content: local_var_content,
222            entity: local_var_entity,
223        };
224        Err(Error::ResponseError(local_var_error))
225    }
226}
bitwarden_api_api/apis/security_task_api.rs

bitwarden_api_api/apis/
security_task_api.rs
