use reqwest;
use super::{configuration, Error};
use crate::apis::ResponseContent;
use crate::models::{FetchOrgOrderBy, SuccessfulResponse};
use crate::propelauth::auth::AUTH_HOSTNAME_HEADER;
#[derive(Clone, Debug, Default)]
pub struct AddUserToOrgParams {
pub add_user_to_org_request: crate::models::AddUserToOrgRequest,
}
#[derive(Clone, Debug, Default)]
pub struct AllowOrgToEnableSamlParams {
pub org_id: String,
}
#[derive(Clone, Debug, Default)]
pub struct ChangeUserRoleInOrgParams {
pub change_user_role_in_org_request: crate::models::ChangeUserRoleInOrgRequest,
}
#[derive(Clone, Debug, Default)]
pub struct CreateOrgParams {
pub create_org_request: crate::models::CreateOrgRequest,
}
#[derive(Clone, Debug, Default)]
pub struct DisallowSamlParams {
pub org_id: String,
}
#[derive(Clone, Debug, Default)]
pub struct CreateSamlConnectionLinkParams {
pub org_id: String,
pub expires_in_seconds: Option<i64>,
}
#[derive(Clone, Debug, Default)]
pub struct FetchOrgParams {
pub org_id: String,
}
#[derive(Clone, Debug, Default)]
pub struct FetchOrgsByQueryParams {
pub page_size: Option<i64>,
pub page_number: Option<i64>,
pub order_by: Option<FetchOrgOrderBy>,
pub name: Option<String>,
pub legacy_org_id: Option<String>,
pub domain: Option<String>,
}
#[derive(Clone, Debug, Default)]
pub struct FetchPendingInvitesParams {
pub page_size: Option<i64>,
pub page_number: Option<i64>,
pub org_id: Option<String>,
}
#[derive(Clone, Debug, Default)]
pub struct FetchUsersInOrgParams {
pub org_id: String,
pub page_size: Option<i64>,
pub page_number: Option<i64>,
pub include_orgs: Option<bool>,
pub role: Option<String>,
}
#[derive(Clone, Debug, Default)]
pub struct RemoveUserFromOrgParams {
pub remove_user_from_org_request: crate::models::RemoveUserFromOrgRequest,
}
#[derive(Clone, Debug, Default)]
pub struct UpdateOrgParams {
pub org_id: String,
pub update_org_request: crate::models::UpdateOrgRequest,
}
#[derive(Clone, Debug, Default)]
pub struct SubscribeOrgToRoleMappingParams {
pub org_id: String,
pub update_org_request: crate::models::SubscribeOrgToRoleMappingRequest,
}
#[derive(Clone, Debug, Default)]
pub struct DeleteOrgParams {
pub org_id: String,
}
#[derive(Clone, Debug, Default)]
pub struct RevokePendingOrgInviteParams {
pub revoke_pending_org_invite_request: crate::models::RevokePendingOrgInviteRequest,
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserToOrgError {
Status400(serde_json::Value),
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AllowOrgToEnableSamlError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ChangeUserRoleInOrgError {
Status400(serde_json::Value),
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum CreateOrgError {
Status400(crate::models::BadCreateOrgRequest),
Status401(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DisallowSamlError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum CreateSamlConnectionLinkError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchSamlSpMetadataError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum SetSamlIdpMetadataError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum SamlGoLiveError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteSamlConnectionError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchOrgError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchCustomRoleMappingsError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchPendingInvitesError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum RevokePendingOrgInviteError {
Status401(serde_json::Value),
Status400(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchOrgsByQueryError {
Status400(crate::models::BadFetchOrgQuery),
Status401(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum FetchUsersInOrgError {
Status400(crate::models::BadFetchUsersInOrgQuery),
Status401(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum RemoveUserFromOrgError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateOrgError {
Status400(crate::models::BadUpdateOrgRequest),
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum SubscribeOrgToRoleMappingError {
Status400(crate::models::BadUpdateOrgRequest),
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteOrgError {
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum SetOidcIdpMetadataError {
Status400(serde_json::Value),
Status401(serde_json::Value),
Status404(serde_json::Value),
UnknownValue(serde_json::Value),
}
pub async fn add_user_to_org(
configuration: &configuration::Configuration,
params: AddUserToOrgParams,
) -> Result<crate::models::SuccessfulResponse, Error<AddUserToOrgError>> {
let local_var_configuration = configuration;
let add_user_to_org_request = params.add_user_to_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/add_user",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&add_user_to_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<AddUserToOrgError> =
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 allow_org_to_enable_saml(
configuration: &configuration::Configuration,
params: AllowOrgToEnableSamlParams,
) -> Result<crate::models::SuccessfulResponse, Error<AllowOrgToEnableSamlError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}/allow_saml",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<AllowOrgToEnableSamlError> =
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 change_user_role_in_org(
configuration: &configuration::Configuration,
params: ChangeUserRoleInOrgParams,
) -> Result<crate::models::SuccessfulResponse, Error<ChangeUserRoleInOrgError>> {
let local_var_configuration = configuration;
let change_user_role_in_org_request = params.change_user_role_in_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/change_role",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&change_user_role_in_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<ChangeUserRoleInOrgError> =
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 create_org(
configuration: &configuration::Configuration,
params: CreateOrgParams,
) -> Result<crate::models::CreateOrgResponse, Error<CreateOrgError>> {
let local_var_configuration = configuration;
let create_org_request = params.create_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/api/backend/v1/org/", local_var_configuration.base_path);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&create_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<CreateOrgError> =
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 disallow_saml(
configuration: &configuration::Configuration,
params: DisallowSamlParams,
) -> Result<crate::models::SuccessfulResponse, Error<DisallowSamlError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}/disallow_saml",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<DisallowSamlError> =
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 create_saml_connection_link(
configuration: &configuration::Configuration,
params: CreateSamlConnectionLinkParams,
) -> Result<crate::models::CreateSamlConnectionLinkResponse, Error<CreateSamlConnectionLinkError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let expires_in_seconds = params.expires_in_seconds;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}/create_saml_connection_link",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let request = serde_json::json!({
"expires_in_seconds": expires_in_seconds,
});
local_var_req_builder = local_var_req_builder.json(&request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<CreateSamlConnectionLinkError> =
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 fetch_saml_sp_metadata(
configuration: &configuration::Configuration,
org_id: String,
) -> Result<crate::models::FetchSamlSpMetadataResponse, Error<FetchSamlSpMetadataError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/saml_sp_metadata/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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);
}
if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token);
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchSamlSpMetadataError> =
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 set_saml_idp_metadata(
configuration: &configuration::Configuration,
set_idp_request: crate::models::SetSamlIdpMetadataRequest,
) -> Result<crate::models::SuccessfulResponse, Error<SetSamlIdpMetadataError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/saml_idp_metadata",
local_var_configuration.base_path,
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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);
}
if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token);
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&set_idp_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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() {
Ok(SuccessfulResponse::new())
} else {
let local_var_entity: Option<SetSamlIdpMetadataError> =
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 saml_go_live(
configuration: &configuration::Configuration,
org_id: String,
) -> Result<crate::models::SuccessfulResponse, Error<SamlGoLiveError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/saml_idp_metadata/go_live/{}",
local_var_configuration.base_path, org_id
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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);
}
if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token);
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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() {
Ok(SuccessfulResponse::new())
} else {
let local_var_entity: Option<SamlGoLiveError> =
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 delete_saml_connection(
configuration: &configuration::Configuration,
org_id: String,
) -> Result<crate::models::SuccessfulResponse, Error<DeleteSamlConnectionError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/saml_idp_metadata/{}",
local_var_configuration.base_path, org_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);
}
if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token);
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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() {
Ok(SuccessfulResponse::new())
} else {
let local_var_entity: Option<DeleteSamlConnectionError> =
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 fetch_org(
configuration: &configuration::Configuration,
params: FetchOrgParams,
) -> Result<crate::models::FetchOrgResponse, Error<FetchOrgError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchOrgError> = 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 fetch_custom_role_mappings(
configuration: &configuration::Configuration,
) -> Result<crate::models::FetchCustomRoleMappingsResponse, Error<FetchCustomRoleMappingsError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/custom_role_mappings",
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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchCustomRoleMappingsError> =
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 fetch_pending_invites(
configuration: &configuration::Configuration,
params: FetchPendingInvitesParams,
) -> Result<crate::models::FetchPendingInvitesResponse, Error<FetchPendingInvitesError>> {
let local_var_configuration = configuration;
let FetchPendingInvitesParams {
page_size,
page_number,
org_id,
} = params;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/pending_org_invites",
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_str) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("page_size", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page_number {
local_var_req_builder =
local_var_req_builder.query(&[("page_number", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = org_id {
local_var_req_builder =
local_var_req_builder.query(&[("org_id", &local_var_str.to_string())]);
}
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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchPendingInvitesError> =
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 revoke_pending_org_invite(
configuration: &configuration::Configuration,
params: RevokePendingOrgInviteParams,
) -> Result<crate::models::SuccessfulResponse, Error<RevokePendingOrgInviteError>> {
let local_var_configuration = configuration;
let revoke_pending_org_invite_request = params.revoke_pending_org_invite_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/pending_org_invites",
local_var_configuration.base_path
);
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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&revoke_pending_org_invite_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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(|e| Error::from(e))
} else {
let local_var_entity: Option<RevokePendingOrgInviteError> =
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 fetch_orgs_by_query(
configuration: &configuration::Configuration,
params: FetchOrgsByQueryParams,
) -> Result<crate::models::FetchOrgsResponse, Error<FetchOrgsByQueryError>> {
let local_var_configuration = configuration;
let FetchOrgsByQueryParams {
page_size,
page_number,
order_by,
name,
legacy_org_id,
domain,
} = params;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/query",
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_str) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("page_size", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page_number {
local_var_req_builder =
local_var_req_builder.query(&[("page_number", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = order_by {
local_var_req_builder =
local_var_req_builder.query(&[("order_by", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = name {
local_var_req_builder =
local_var_req_builder.query(&[("name", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = legacy_org_id {
local_var_req_builder =
local_var_req_builder.query(&[("legacy_org_id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = domain {
local_var_req_builder =
local_var_req_builder.query(&[("domain", &local_var_str.to_string())]);
}
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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchOrgsByQueryError> =
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 fetch_users_in_org(
configuration: &configuration::Configuration,
params: FetchUsersInOrgParams,
) -> Result<crate::models::UserPagedResponse, Error<FetchUsersInOrgError>> {
let local_var_configuration = configuration;
let FetchUsersInOrgParams {
org_id,
page_size,
page_number,
include_orgs,
role,
} = params;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/user/org/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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_str) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("page_size", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = page_number {
local_var_req_builder =
local_var_req_builder.query(&[("page_number", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_orgs {
local_var_req_builder =
local_var_req_builder.query(&[("include_orgs", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = role {
local_var_req_builder =
local_var_req_builder.query(&[("role", &local_var_str.to_string())]);
}
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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<FetchUsersInOrgError> =
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 remove_user_from_org(
configuration: &configuration::Configuration,
params: RemoveUserFromOrgParams,
) -> Result<crate::models::SuccessfulResponse, Error<RemoveUserFromOrgError>> {
let local_var_configuration = configuration;
let remove_user_from_org_request = params.remove_user_from_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/remove_user",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&remove_user_from_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<RemoveUserFromOrgError> =
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_org(
configuration: &configuration::Configuration,
params: UpdateOrgParams,
) -> Result<crate::models::SuccessfulResponse, Error<UpdateOrgError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let update_org_request = params.update_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&update_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<UpdateOrgError> =
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 subscribe_org_to_role_mapping(
configuration: &configuration::Configuration,
params: SubscribeOrgToRoleMappingParams,
) -> Result<crate::models::SuccessfulResponse, Error<SubscribeOrgToRoleMappingError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let update_org_request = params.update_org_request;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&update_org_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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<SubscribeOrgToRoleMappingError> =
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 set_oidc_idp_metadata(
configuration: &configuration::Configuration,
set_idp_request: crate::models::SetOidcIdpMetadataRequest,
) -> Result<crate::models::SuccessfulResponse, Error<SetOidcIdpMetadataError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/oidc_idp_metadata",
local_var_configuration.base_path,
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, 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);
}
if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token);
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
local_var_req_builder = local_var_req_builder.json(&set_idp_request);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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() {
Ok(SuccessfulResponse::new())
} else {
let local_var_entity: Option<SetOidcIdpMetadataError> =
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 delete_org(
configuration: &configuration::Configuration,
params: DeleteOrgParams,
) -> Result<crate::models::SuccessfulResponse, Error<DeleteOrgError>> {
let local_var_configuration = configuration;
let org_id = params.org_id;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/api/backend/v1/org/{org_id}",
local_var_configuration.base_path,
org_id = crate::apis::urlencode(org_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_token) = local_var_configuration.bearer_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder.header(
AUTH_HOSTNAME_HEADER,
local_var_configuration.auth_hostname.to_owned(),
);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
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(|e| Error::from(e))
} else {
let local_var_entity: Option<DeleteOrgError> =
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))
}
}