#![cfg(feature = "cloudflare_data")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(clippy::missing_errors_doc, clippy::doc_markdown, clippy::useless_format)]
#![allow(unused_imports)]
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use foundation_netio::shared::client::http_client::HttpClient;
use serde::{Deserialize, Serialize};
use foundation_macros::JsonHash;
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpApiResponseCommon {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpApiResponseSingle {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpContextAwareness {
pub enabled: bool,
pub skip: DlpSkipConfig,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomEntry {
pub created_at: String,
pub description: Option<String>,
pub enabled: bool,
pub id: String,
pub name: String,
pub pattern: DlpPattern,
pub profile_id: Option<String>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomEntryUpdate {
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomEntryUpdateType {
pub description: Option<String>,
pub name: String,
pub pattern: DlpPattern,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomProfile {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: i64,
pub confidence_threshold: Option<serde_json::Value>,
pub context_awareness: Option<DlpContextAwareness>,
pub created_at: String,
pub data_classes: Option<Vec<String>>,
pub data_tags: Option<Vec<String>>,
pub description: Option<String>,
pub entries: Option<Vec<DlpEntry>>,
pub id: String,
pub name: String,
pub ocr_enabled: bool,
pub sensitivity_levels: Option<Vec<DlpSensitivityLevelRef>>,
pub shared_entries: Option<Vec<DlpEntry>>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomProfileArray {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpCustomProfileUpdate {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: Option<i64>,
pub confidence_threshold: Option<String>,
pub context_awareness: Option<DlpContextAwareness>,
pub data_classes: Option<Vec<String>>,
pub data_tags: Option<Vec<String>>,
pub description: Option<String>,
pub entries: Option<Vec<DlpProfileEntryUpdate>>,
pub name: String,
pub ocr_enabled: Option<bool>,
pub sensitivity_levels: Option<Vec<DlpSensitivityLevelRef>>,
pub shared_entries: Option<Vec<DlpSharedEntryUpdate>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDataset {
pub case_sensitive: Option<bool>,
pub columns: Vec<DlpDatasetColumn>,
pub created_at: String,
pub description: Option<String>,
pub encoding_version: i64,
pub id: String,
pub name: String,
pub num_cells: i64,
pub secret: bool,
pub status: DlpDatasetUploadStatus,
pub updated_at: String,
pub uploads: Vec<DlpDatasetUpload>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetArray {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetColumn {
pub entry_id: String,
pub header_name: String,
pub num_cells: i64,
pub upload_status: DlpDatasetUploadStatus,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetColumnArray {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetCreation {
pub dataset: DlpDataset,
pub encoding_version: i64,
pub max_cells: i64,
pub secret: Option<String>,
pub version: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetNewVersion {
pub case_sensitive: Option<bool>,
pub columns: Option<Vec<DlpDatasetColumn>>,
pub encoding_version: i64,
pub max_cells: i64,
pub secret: Option<String>,
pub version: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetUpload {
pub num_cells: i64,
pub status: DlpDatasetUploadStatus,
pub version: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetUploadStatus {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsCreateRequest {
pub case_sensitive: Option<bool>,
pub description: Option<String>,
pub encoding_version: Option<i64>,
pub name: String,
pub secret: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsCreateResponse {
pub result: Option<DlpDatasetCreation>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsCreateVersionResponse {
pub result: Option<DlpDatasetNewVersion>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsDefineColumnsRequestItem {
pub header_name: String,
pub num_cells: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsDefineColumnsResponse {
pub result: Option<Vec<DlpDatasetColumn>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsReadAllResponse {
pub result: Option<Vec<DlpDataset>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsReadResponse {
pub result: Option<DlpDataset>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsUpdateRequest {
pub case_sensitive: Option<bool>,
pub description: Option<String>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsUpdateResponse {
pub result: Option<DlpDataset>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsUploadDatasetColumnResponse {
pub result: Option<DlpDatasetColumn>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDatasetsUploadVersionResponse {
pub result: Option<DlpDataset>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDlpSettings {
pub ai_context_analysis: bool,
pub ocr: bool,
pub payload_logging: DlpPayloadLogSetting,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDlpSettingsUpdate {
pub ai_context_analysis: Option<bool>,
pub ocr: Option<bool>,
pub payload_logging: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpDocumentFingerprintEntry {
pub created_at: String,
pub enabled: bool,
pub id: String,
pub name: String,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEmpty {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesCreateEntryResponse {
pub result: Option<DlpCustomEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesCreateIntegrationEntryResponse {
pub result: Option<DlpIntegrationEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesCreatePredefinedEntryResponse {
pub result: Option<DlpPredefinedEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesDeleteEntryResponse {
pub result: Option<DlpEmpty>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesDeleteIntegrationEntryResponse {
pub result: Option<DlpEmpty>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesDeletePredefinedEntryResponse {
pub result: Option<DlpEmpty>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesGetDlpEntryResponse {
pub result: Option<DlpEntryWithSharedProfiles>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesListAllEntriesResponse {
pub result: Option<Vec<DlpEntryWithUploadStatus>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesUpdateCustomEntryResponse {
pub result: Option<DlpCustomEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesUpdateEntryResponse {
pub result: Option<DlpEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesUpdateIntegrationEntryResponse {
pub result: Option<DlpIntegrationEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntriesUpdatePredefinedEntryResponse {
pub result: Option<DlpPredefinedEntry>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntry {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryConfidence {
pub ai_context_available: bool,
pub available: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryOfNewProfile {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryProfile {
pub id: String,
pub name: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryUpdate {
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryUpdateType {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryWithSharedProfiles {
pub profiles: Vec<DlpEntryProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpEntryWithUploadStatus {
pub upload_status: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpExactDataEntry {
pub case_sensitive: bool,
pub created_at: String,
pub enabled: bool,
pub id: String,
pub name: String,
pub secret: bool,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpIntegrationEntry {
pub created_at: String,
pub enabled: bool,
pub id: String,
pub name: String,
pub profile_id: Option<String>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpIntegrationProfile {
pub created_at: String,
pub description: Option<String>,
pub entries: Vec<DlpEntry>,
pub id: String,
pub name: String,
pub shared_entries: Vec<DlpEntry>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpLimits {
pub max_dataset_cells: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpLimitsGetResponse {
pub result: Option<DlpLimits>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewCustomEntry {
pub description: Option<String>,
pub enabled: bool,
pub name: String,
pub pattern: DlpPattern,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewCustomEntryWithId {
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewCustomProfile {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: Option<i64>,
pub confidence_threshold: Option<String>,
pub context_awareness: Option<DlpContextAwareness>,
pub data_classes: Option<Vec<String>>,
pub data_tags: Option<Vec<String>>,
pub description: Option<String>,
pub entries: Option<Vec<DlpEntryOfNewProfile>>,
pub name: String,
pub ocr_enabled: Option<bool>,
pub sensitivity_levels: Option<Vec<DlpSensitivityLevelRef>>,
pub shared_entries: Option<Vec<DlpNewSharedEntry>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewEntry {
pub description: Option<String>,
pub enabled: bool,
pub name: String,
pub pattern: DlpPattern,
pub profile_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewPredefinedEntry {
pub enabled: bool,
pub entry_id: String,
pub profile_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewPredefinedProfile {
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewSharedEntry {
pub enabled: bool,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpNewWordListEntry {
pub enabled: bool,
pub name: String,
pub words: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPattern {
pub regex: String,
pub validation: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPatternValidateResponse {
pub result: Option<DlpRegexValidationResult>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogSetting {
pub masking_level: Option<serde_json::Value>,
pub public_key: Option<String>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedEntry {
pub confidence: DlpEntryConfidence,
pub enabled: bool,
pub id: String,
pub name: String,
pub profile_id: Option<String>,
pub variant: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedEntryUpdate {
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedProfile {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: i64,
pub confidence_threshold: Option<serde_json::Value>,
pub context_awareness: Option<DlpContextAwareness>,
pub entries: Vec<DlpEntry>,
pub id: String,
pub name: String,
pub ocr_enabled: Option<bool>,
pub open_access: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedProfileConfig {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: i64,
pub confidence_threshold: Option<String>,
pub enabled_entries: Vec<String>,
pub entries: Vec<DlpEntry>,
pub id: String,
pub name: String,
pub ocr_enabled: Option<bool>,
pub open_access: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedProfileConfigUpdate {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: Option<i64>,
pub confidence_threshold: Option<String>,
pub enabled_entries: Option<Vec<String>>,
pub entries: Option<Vec<DlpPredefinedProfileEntryUpdate>>,
pub ocr_enabled: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedProfileEntryUpdate {
pub enabled: bool,
pub id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPredefinedProfileUpdate {
pub ai_context_enabled: Option<bool>,
pub allowed_match_count: Option<i64>,
pub confidence_threshold: Option<String>,
pub context_awareness: Option<DlpContextAwareness>,
pub entries: Option<Vec<DlpPredefinedProfileEntryUpdate>>,
pub ocr_enabled: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfile {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfileArray {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfileEntryUpdate {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesCreateCustomProfilesResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesCreatePredefinedProfileConfigResponse {
pub result: Option<DlpPredefinedProfileConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesCreatePredefinedProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesDeleteCustomProfileResponse {
pub result: Option<DlpEmpty>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesDeletePredefinedProfileResponse {
pub result: Option<DlpEmpty>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesGetCustomProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesGetDlpProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesGetPredefinedProfileConfigResponse {
pub result: Option<DlpPredefinedProfileConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesGetPredefinedProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesListAllCustomProfilesResponse {
pub result: Option<Vec<DlpCustomProfile>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesListAllProfilesResponse {
pub result: Option<Vec<DlpProfile>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesUpdateCustomProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesUpdatePredefinedProfileConfigResponse {
pub result: Option<DlpPredefinedProfileConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpProfilesUpdatePredefinedProfileResponse {
pub result: Option<DlpProfile>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpRegexValidationQuery {
pub max_match_bytes: Option<i64>,
pub regex: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpRegexValidationResult {
pub valid: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSensitivityLevelRef {
pub group_id: String,
pub level_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSettingsDeleteResponse {
pub result: Option<DlpDlpSettings>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSettingsEditResponse {
pub result: Option<DlpDlpSettings>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSettingsGetResponse {
pub result: Option<DlpDlpSettings>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSettingsUpdateResponse {
pub result: Option<DlpDlpSettings>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSharedEntryUpdate {
pub enabled: bool,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpSkipConfig {
pub files: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpWordListEntry {
pub created_at: String,
pub enabled: bool,
pub id: String,
pub name: String,
pub profile_id: Option<String>,
pub updated_at: String,
pub word_list: serde_json::Value,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsReadAllArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsCreateArgs {
pub account_id: String,
pub body: DlpDatasetsCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsReadArgs {
pub account_id: String,
pub dataset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsUpdateArgs {
pub account_id: String,
pub dataset_id: String,
pub body: DlpDatasetsUpdateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsDeleteArgs {
pub account_id: String,
pub dataset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsCreateVersionArgs {
pub account_id: String,
pub dataset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsUploadVersionArgs {
pub account_id: String,
pub dataset_id: String,
pub version: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsDefineColumnsArgs {
pub account_id: String,
pub dataset_id: String,
pub version: String,
pub body: Vec<DlpDatasetsDefineColumnsRequestItem>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpDatasetsUploadDatasetColumnArgs {
pub account_id: String,
pub dataset_id: String,
pub version: String,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesListAllEntriesArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesCreateEntryArgs {
pub account_id: String,
pub body: DlpNewEntry,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesUpdateCustomEntryArgs {
pub account_id: String,
pub entry_id: String,
pub body: DlpCustomEntryUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesCreateIntegrationEntryArgs {
pub account_id: String,
pub body: DlpNewPredefinedEntry,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesUpdateIntegrationEntryArgs {
pub account_id: String,
pub entry_id: String,
pub body: DlpPredefinedEntryUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesDeleteIntegrationEntryArgs {
pub account_id: String,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesCreatePredefinedEntryArgs {
pub account_id: String,
pub body: DlpNewPredefinedEntry,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesUpdatePredefinedEntryArgs {
pub account_id: String,
pub entry_id: String,
pub body: DlpPredefinedEntryUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesDeletePredefinedEntryArgs {
pub account_id: String,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesGetDlpEntryArgs {
pub account_id: String,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesUpdateEntryArgs {
pub account_id: String,
pub entry_id: String,
pub body: DlpEntryUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpEntriesDeleteEntryArgs {
pub account_id: String,
pub entry_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpLimitsGetArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpPatternValidateArgs {
pub account_id: String,
pub body: DlpRegexValidationQuery,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesListAllProfilesArgs {
pub account_id: String,
pub all: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesListAllCustomProfilesArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesCreateCustomProfilesArgs {
pub account_id: String,
pub body: DlpNewCustomProfile,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesGetCustomProfileArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesUpdateCustomProfileArgs {
pub account_id: String,
pub profile_id: String,
pub body: DlpCustomProfileUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesDeleteCustomProfileArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesCreatePredefinedProfileArgs {
pub account_id: String,
pub body: DlpNewPredefinedProfile,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesGetPredefinedProfileArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesUpdatePredefinedProfileArgs {
pub account_id: String,
pub profile_id: String,
pub body: DlpPredefinedProfileUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesDeletePredefinedProfileArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesGetPredefinedProfileConfigArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesCreatePredefinedProfileConfigArgs {
pub account_id: String,
pub profile_id: String,
pub body: DlpPredefinedProfileConfigUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesUpdatePredefinedProfileConfigArgs {
pub account_id: String,
pub profile_id: String,
pub body: DlpPredefinedProfileConfigUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpProfilesGetDlpProfileArgs {
pub account_id: String,
pub profile_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpSettingsGetArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpSettingsUpdateArgs {
pub account_id: String,
pub body: DlpDlpSettingsUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpSettingsEditArgs {
pub account_id: String,
pub body: DlpDlpSettingsUpdate,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpSettingsDeleteArgs {
pub account_id: String,
}
pub async fn dlp_datasets_read_all_request<F>(
client: DynNetClient,
args: &DlpDatasetsReadAllArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsReadAllResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsReadAllResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_create_request<F>(
client: DynNetClient,
args: &DlpDatasetsCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsCreateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsCreateResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_read_request<F>(
client: DynNetClient,
args: &DlpDatasetsReadArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsReadResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}",
args.account_id,
args.dataset_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsReadResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_update_request<F>(
client: DynNetClient,
args: &DlpDatasetsUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsUpdateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}",
args.account_id,
args.dataset_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsUpdateResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_delete_request<F>(
client: DynNetClient,
args: &DlpDatasetsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}",
args.account_id,
args.dataset_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn dlp_datasets_create_version_request<F>(
client: DynNetClient,
args: &DlpDatasetsCreateVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsCreateVersionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}/upload",
args.account_id,
args.dataset_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsCreateVersionResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_upload_version_request<F>(
client: DynNetClient,
args: &DlpDatasetsUploadVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsUploadVersionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}/upload/{}",
args.account_id,
args.dataset_id,
args.version,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsUploadVersionResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_define_columns_request<F>(
client: DynNetClient,
args: &DlpDatasetsDefineColumnsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsDefineColumnsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}/versions/{}",
args.account_id,
args.dataset_id,
args.version,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsDefineColumnsResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_datasets_upload_dataset_column_request<F>(
client: DynNetClient,
args: &DlpDatasetsUploadDatasetColumnArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpDatasetsUploadDatasetColumnResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/datasets/{}/versions/{}/entries/{}",
args.account_id,
args.dataset_id,
args.version,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpDatasetsUploadDatasetColumnResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_list_all_entries_request<F>(
client: DynNetClient,
args: &DlpEntriesListAllEntriesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesListAllEntriesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesListAllEntriesResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_create_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesCreateEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesCreateEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesCreateEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_update_custom_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesUpdateCustomEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesUpdateCustomEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/custom/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesUpdateCustomEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_create_integration_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesCreateIntegrationEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesCreateIntegrationEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/integration",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesCreateIntegrationEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_update_integration_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesUpdateIntegrationEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesUpdateIntegrationEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/integration/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesUpdateIntegrationEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_delete_integration_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesDeleteIntegrationEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesDeleteIntegrationEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/integration/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesDeleteIntegrationEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_create_predefined_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesCreatePredefinedEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesCreatePredefinedEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/predefined",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesCreatePredefinedEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_update_predefined_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesUpdatePredefinedEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesUpdatePredefinedEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/predefined/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesUpdatePredefinedEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_delete_predefined_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesDeletePredefinedEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesDeletePredefinedEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/predefined/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesDeletePredefinedEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_get_dlp_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesGetDlpEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesGetDlpEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesGetDlpEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_update_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesUpdateEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesUpdateEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesUpdateEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_entries_delete_entry_request<F>(
client: DynNetClient,
args: &DlpEntriesDeleteEntryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpEntriesDeleteEntryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/entries/{}",
args.account_id,
args.entry_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpEntriesDeleteEntryResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_limits_get_request<F>(
client: DynNetClient,
args: &DlpLimitsGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpLimitsGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/limits",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpLimitsGetResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_pattern_validate_request<F>(
client: DynNetClient,
args: &DlpPatternValidateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpPatternValidateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/patterns/validate",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpPatternValidateResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_list_all_profiles_request<F>(
client: DynNetClient,
args: &DlpProfilesListAllProfilesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesListAllProfilesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("all", args.all.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesListAllProfilesResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_list_all_custom_profiles_request<F>(
client: DynNetClient,
args: &DlpProfilesListAllCustomProfilesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesListAllCustomProfilesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/custom",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesListAllCustomProfilesResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_create_custom_profiles_request<F>(
client: DynNetClient,
args: &DlpProfilesCreateCustomProfilesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesCreateCustomProfilesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/custom",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesCreateCustomProfilesResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_get_custom_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesGetCustomProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesGetCustomProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/custom/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesGetCustomProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_update_custom_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesUpdateCustomProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesUpdateCustomProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/custom/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesUpdateCustomProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_delete_custom_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesDeleteCustomProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesDeleteCustomProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/custom/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesDeleteCustomProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_create_predefined_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesCreatePredefinedProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesCreatePredefinedProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesCreatePredefinedProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_get_predefined_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesGetPredefinedProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesGetPredefinedProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesGetPredefinedProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_update_predefined_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesUpdatePredefinedProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesUpdatePredefinedProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesUpdatePredefinedProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_delete_predefined_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesDeletePredefinedProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesDeletePredefinedProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesDeletePredefinedProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_get_predefined_profile_config_request<F>(
client: DynNetClient,
args: &DlpProfilesGetPredefinedProfileConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesGetPredefinedProfileConfigResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}/config",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesGetPredefinedProfileConfigResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_create_predefined_profile_config_request<F>(
client: DynNetClient,
args: &DlpProfilesCreatePredefinedProfileConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesCreatePredefinedProfileConfigResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}/config",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesCreatePredefinedProfileConfigResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_update_predefined_profile_config_request<F>(
client: DynNetClient,
args: &DlpProfilesUpdatePredefinedProfileConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesUpdatePredefinedProfileConfigResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/predefined/{}/config",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesUpdatePredefinedProfileConfigResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_profiles_get_dlp_profile_request<F>(
client: DynNetClient,
args: &DlpProfilesGetDlpProfileArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpProfilesGetDlpProfileResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/profiles/{}",
args.account_id,
args.profile_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpProfilesGetDlpProfileResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_settings_get_request<F>(
client: DynNetClient,
args: &DlpSettingsGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpSettingsGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/settings",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpSettingsGetResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_settings_update_request<F>(
client: DynNetClient,
args: &DlpSettingsUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpSettingsUpdateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/settings",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpSettingsUpdateResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_settings_edit_request<F>(
client: DynNetClient,
args: &DlpSettingsEditArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpSettingsEditResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/settings",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::patch(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpSettingsEditResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}
pub async fn dlp_settings_delete_request<F>(
client: DynNetClient,
args: &DlpSettingsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpSettingsDeleteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/settings",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
let response = client.send_async(builder.build()).await
.map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;
let status: usize = response.get_status().into();
let headers = response.get_headers_ref().clone();
if status < 200 || status >= 300 {
let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let body = (!error_bytes.is_empty())
.then(|| String::from_utf8_lossy(&error_bytes).into_owned());
return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
}
let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
let parsed: DlpSettingsDeleteResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
Ok(ApiResponse { status: status as u16, headers, body: parsed })
}