use reqwest;
use crate::apis::ResponseContent;
use super::{Error, configuration};
#[derive(Clone, Debug, Default)]
pub struct DeleteCustomerParams {
pub customer_id: String
}
#[derive(Clone, Debug, Default)]
pub struct GetCustomerParams {
pub customer_id: String
}
#[derive(Clone, Debug, Default)]
pub struct ListUsersParams {
pub customer_id: String
}
#[derive(Clone, Debug, Default)]
pub struct UpdateCustomerParams {
pub customer_id: String,
pub billing_contact_id: Option<String>,
pub billing_network_type: Option<String>,
pub billing_ref: Option<String>,
pub can_configure_wordpress: Option<bool>,
pub can_reset_passwords: Option<bool>,
pub can_upload_vcl: Option<bool>,
pub force_2fa: Option<bool>,
pub force_sso: Option<bool>,
pub has_account_panel: Option<bool>,
pub has_improved_events: Option<bool>,
pub has_improved_ssl_config: Option<bool>,
pub has_openstack_logging: Option<bool>,
pub has_pci: Option<bool>,
pub has_pci_passwords: Option<bool>,
pub ip_whitelist: Option<String>,
pub legal_contact_id: Option<String>,
pub name: Option<String>,
pub owner_id: Option<String>,
pub phone_number: Option<String>,
pub postal_address: Option<String>,
pub pricing_plan: Option<String>,
pub pricing_plan_id: Option<String>,
pub security_contact_id: Option<String>,
pub technical_contact_id: Option<String>
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteCustomerError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetCustomerError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetLoggedInCustomerError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ListUsersError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateCustomerError {
UnknownValue(serde_json::Value),
}
pub async fn delete_customer(configuration: &mut configuration::Configuration, params: DeleteCustomerParams) -> Result<crate::models::InlineResponse200, Error<DeleteCustomerError>> {
let local_var_configuration = configuration;
let customer_id = params.customer_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/customer/{customer_id}", local_var_configuration.base_path, customer_id=crate::apis::urlencode(customer_id));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_apikey) = local_var_configuration.api_key {
let local_var_key = local_var_apikey.key.clone();
let local_var_value = match local_var_apikey.prefix {
Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
None => local_var_key,
};
local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
if "DELETE" != "GET" && "DELETE" != "HEAD" {
let headers = local_var_resp.headers();
local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => configuration::DEFAULT_RATELIMIT,
};
local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => 0,
};
}
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<DeleteCustomerError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn get_customer(configuration: &mut configuration::Configuration, params: GetCustomerParams) -> Result<crate::models::CustomerResponse, Error<GetCustomerError>> {
let local_var_configuration = configuration;
let customer_id = params.customer_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/customer/{customer_id}", local_var_configuration.base_path, customer_id=crate::apis::urlencode(customer_id));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_apikey) = local_var_configuration.api_key {
let local_var_key = local_var_apikey.key.clone();
let local_var_value = match local_var_apikey.prefix {
Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
None => local_var_key,
};
local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
if "GET" != "GET" && "GET" != "HEAD" {
let headers = local_var_resp.headers();
local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => configuration::DEFAULT_RATELIMIT,
};
local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => 0,
};
}
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<GetCustomerError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn get_logged_in_customer(configuration: &mut configuration::Configuration) -> Result<crate::models::CustomerResponse, Error<GetLoggedInCustomerError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/current_customer", local_var_configuration.base_path);
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_apikey) = local_var_configuration.api_key {
let local_var_key = local_var_apikey.key.clone();
let local_var_value = match local_var_apikey.prefix {
Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
None => local_var_key,
};
local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
if "GET" != "GET" && "GET" != "HEAD" {
let headers = local_var_resp.headers();
local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => configuration::DEFAULT_RATELIMIT,
};
local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => 0,
};
}
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<GetLoggedInCustomerError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn list_users(configuration: &mut configuration::Configuration, params: ListUsersParams) -> Result<Vec<crate::models::SchemasUserResponse>, Error<ListUsersError>> {
let local_var_configuration = configuration;
let customer_id = params.customer_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/customer/{customer_id}/users", local_var_configuration.base_path, customer_id=crate::apis::urlencode(customer_id));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_apikey) = local_var_configuration.api_key {
let local_var_key = local_var_apikey.key.clone();
let local_var_value = match local_var_apikey.prefix {
Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
None => local_var_key,
};
local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
if "GET" != "GET" && "GET" != "HEAD" {
let headers = local_var_resp.headers();
local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => configuration::DEFAULT_RATELIMIT,
};
local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => 0,
};
}
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<ListUsersError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}
pub async fn update_customer(configuration: &mut configuration::Configuration, params: UpdateCustomerParams) -> Result<crate::models::CustomerResponse, Error<UpdateCustomerError>> {
let local_var_configuration = configuration;
let customer_id = params.customer_id;
let billing_contact_id = params.billing_contact_id;
let billing_network_type = params.billing_network_type;
let billing_ref = params.billing_ref;
let can_configure_wordpress = params.can_configure_wordpress;
let can_reset_passwords = params.can_reset_passwords;
let can_upload_vcl = params.can_upload_vcl;
let force_2fa = params.force_2fa;
let force_sso = params.force_sso;
let has_account_panel = params.has_account_panel;
let has_improved_events = params.has_improved_events;
let has_improved_ssl_config = params.has_improved_ssl_config;
let has_openstack_logging = params.has_openstack_logging;
let has_pci = params.has_pci;
let has_pci_passwords = params.has_pci_passwords;
let ip_whitelist = params.ip_whitelist;
let legal_contact_id = params.legal_contact_id;
let name = params.name;
let owner_id = params.owner_id;
let phone_number = params.phone_number;
let postal_address = params.postal_address;
let pricing_plan = params.pricing_plan;
let pricing_plan_id = params.pricing_plan_id;
let security_contact_id = params.security_contact_id;
let technical_contact_id = params.technical_contact_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/customer/{customer_id}", local_var_configuration.base_path, customer_id=crate::apis::urlencode(customer_id));
let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_apikey) = local_var_configuration.api_key {
let local_var_key = local_var_apikey.key.clone();
let local_var_value = match local_var_apikey.prefix {
Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
None => local_var_key,
};
local_var_req_builder = local_var_req_builder.header("Fastly-Key", local_var_value);
};
let mut local_var_form_params = std::collections::HashMap::new();
if let Some(local_var_param_value) = billing_contact_id {
local_var_form_params.insert("billing_contact_id", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = billing_network_type {
local_var_form_params.insert("billing_network_type", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = billing_ref {
local_var_form_params.insert("billing_ref", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = can_configure_wordpress {
local_var_form_params.insert("can_configure_wordpress", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = can_reset_passwords {
local_var_form_params.insert("can_reset_passwords", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = can_upload_vcl {
local_var_form_params.insert("can_upload_vcl", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = force_2fa {
local_var_form_params.insert("force_2fa", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = force_sso {
local_var_form_params.insert("force_sso", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_account_panel {
local_var_form_params.insert("has_account_panel", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_improved_events {
local_var_form_params.insert("has_improved_events", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_improved_ssl_config {
local_var_form_params.insert("has_improved_ssl_config", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_openstack_logging {
local_var_form_params.insert("has_openstack_logging", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_pci {
local_var_form_params.insert("has_pci", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = has_pci_passwords {
local_var_form_params.insert("has_pci_passwords", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = ip_whitelist {
local_var_form_params.insert("ip_whitelist", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = legal_contact_id {
local_var_form_params.insert("legal_contact_id", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = name {
local_var_form_params.insert("name", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = owner_id {
local_var_form_params.insert("owner_id", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = phone_number {
local_var_form_params.insert("phone_number", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = postal_address {
local_var_form_params.insert("postal_address", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = pricing_plan {
local_var_form_params.insert("pricing_plan", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = pricing_plan_id {
local_var_form_params.insert("pricing_plan_id", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = security_contact_id {
local_var_form_params.insert("security_contact_id", local_var_param_value.to_string());
}
if let Some(local_var_param_value) = technical_contact_id {
local_var_form_params.insert("technical_contact_id", local_var_param_value.to_string());
}
local_var_req_builder = local_var_req_builder.form(&local_var_form_params);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
if "PUT" != "GET" && "PUT" != "HEAD" {
let headers = local_var_resp.headers();
local_var_configuration.rate_limit_remaining = match headers.get("Fastly-RateLimit-Remaining") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => configuration::DEFAULT_RATELIMIT,
};
local_var_configuration.rate_limit_reset = match headers.get("Fastly-RateLimit-Reset") {
Some(v) => v.to_str().unwrap().parse().unwrap(),
None => 0,
};
}
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<UpdateCustomerError> = serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
Err(Error::ResponseError(local_var_error))
}
}