komga_sdk/apis/
sync_points_api.rs1use reqwest;
13use serde::{Deserialize, Serialize, de::Error as _};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration, ContentType};
16
17
18#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum DeleteSyncPointsForCurrentUserError {
22 Status400(models::ValidationErrorResponse),
23 UnknownValue(serde_json::Value),
24}
25
26
27pub async fn delete_sync_points_for_current_user(configuration: &configuration::Configuration, key_id: Option<Vec<String>>) -> Result<(), Error<DeleteSyncPointsForCurrentUserError>> {
29 let p_query_key_id = key_id;
31
32 let uri_str = format!("{}/api/v1/syncpoints/me", configuration.base_path);
33 let mut req_builder = configuration.client.request(reqwest::Method::DELETE, &uri_str);
34
35 if let Some(ref param_value) = p_query_key_id {
36 req_builder = match "multi" {
37 "multi" => req_builder.query(¶m_value.into_iter().map(|p| ("key_id".to_owned(), p.to_string())).collect::<Vec<(std::string::String, std::string::String)>>()),
38 _ => req_builder.query(&[("key_id", ¶m_value.into_iter().map(|p| p.to_string()).collect::<Vec<String>>().join(",").to_string())]),
39 };
40 }
41 if let Some(ref user_agent) = configuration.user_agent {
42 req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
43 }
44 if let Some(ref apikey) = configuration.api_key {
45 let key = apikey.key.clone();
46 let value = match apikey.prefix {
47 Some(ref prefix) => format!("{} {}", prefix, key),
48 None => key,
49 };
50 req_builder = req_builder.header("X-API-Key", value);
51 };
52 if let Some(ref auth_conf) = configuration.basic_auth {
53 req_builder = req_builder.basic_auth(auth_conf.0.to_owned(), auth_conf.1.to_owned());
54 };
55
56 let req = req_builder.build()?;
57 let resp = configuration.client.execute(req).await?;
58
59 let status = resp.status();
60
61 if !status.is_client_error() && !status.is_server_error() {
62 Ok(())
63 } else {
64 let content = resp.text().await?;
65 let entity: Option<DeleteSyncPointsForCurrentUserError> = serde_json::from_str(&content).ok();
66 Err(Error::ResponseError(ResponseContent { status, content, entity }))
67 }
68}
69