use std::sync::Arc;
use async_trait::async_trait;
#[cfg(feature = "mockall")]
use mockall::automock;
use reqwest;
use serde::{Deserialize, Serialize, de::Error as _};
use super::{Error, configuration};
use crate::{
apis::{AuthRequired, ContentType, ResponseContent},
models,
};
#[cfg_attr(feature = "mockall", automock)]
#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
pub trait PushApi: Send + Sync {
async fn add_organization<'a>(
&self,
push_update_request_model: Option<models::PushUpdateRequestModel>,
) -> Result<(), Error>;
async fn delete<'a>(
&self,
push_device_request_model: Option<models::PushDeviceRequestModel>,
) -> Result<(), Error>;
async fn delete_organization<'a>(
&self,
push_update_request_model: Option<models::PushUpdateRequestModel>,
) -> Result<(), Error>;
async fn register<'a>(
&self,
push_registration_request_model: Option<models::PushRegistrationRequestModel>,
) -> Result<(), Error>;
async fn send<'a>(
&self,
json_element_push_send_request_model: Option<models::JsonElementPushSendRequestModel>,
) -> Result<(), Error>;
}
pub struct PushApiClient {
configuration: Arc<configuration::Configuration>,
}
impl PushApiClient {
pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
Self { configuration }
}
}
#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
impl PushApi for PushApiClient {
async fn add_organization<'a>(
&self,
push_update_request_model: Option<models::PushUpdateRequestModel>,
) -> Result<(), Error> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/push/add-organization",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
local_var_req_builder = local_var_req_builder.json(&push_update_request_model);
bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
}
async fn delete<'a>(
&self,
push_device_request_model: Option<models::PushDeviceRequestModel>,
) -> Result<(), Error> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/push/delete", local_var_configuration.base_path);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
local_var_req_builder = local_var_req_builder.json(&push_device_request_model);
bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
}
async fn delete_organization<'a>(
&self,
push_update_request_model: Option<models::PushUpdateRequestModel>,
) -> Result<(), Error> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/push/delete-organization",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
local_var_req_builder = local_var_req_builder.json(&push_update_request_model);
bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
}
async fn register<'a>(
&self,
push_registration_request_model: Option<models::PushRegistrationRequestModel>,
) -> Result<(), Error> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/push/register", local_var_configuration.base_path);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
local_var_req_builder = local_var_req_builder.json(&push_registration_request_model);
bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
}
async fn send<'a>(
&self,
json_element_push_send_request_model: Option<models::JsonElementPushSendRequestModel>,
) -> Result<(), Error> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/push/send", local_var_configuration.base_path);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.with_extension(AuthRequired::Bearer);
local_var_req_builder = local_var_req_builder.json(&json_element_push_send_request_model);
bitwarden_api_base::process_with_empty_response(local_var_req_builder).await
}
}