#![cfg(feature = "cloudflare_media")]
#![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 BrapiDeleteCancelCrawlResponse {
pub errors: Option<Vec<BrapiDeleteCancelCrawlResponseErrorsItem>>,
pub result: BrapiDeleteCancelCrawlResponseResult,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiDeleteCancelCrawlResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiDeleteCancelCrawlResponseResult {
pub job_id: String,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiGetCrawlResultResponse {
pub errors: Option<Vec<BrapiGetCrawlResultResponseErrorsItem>>,
pub result: BrapiGetCrawlResultResponseResult,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiGetCrawlResultResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiGetCrawlResultResponseResult {
#[serde(rename = "browserSecondsUsed")]
pub browser_seconds_used: f64,
pub cursor: Option<String>,
pub finished: f64,
pub id: String,
pub records: Vec<BrapiGetCrawlResultResponseResultRecordsItem>,
pub skipped: f64,
pub status: String,
pub total: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiGetCrawlResultResponseResultRecordsItem {
pub html: Option<String>,
pub json: Option<serde_json::Value>,
pub markdown: Option<String>,
pub metadata: BrapiGetCrawlResultResponseResultRecordsItemMetadata,
pub status: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiGetCrawlResultResponseResultRecordsItemMetadata {
pub status: f64,
pub title: Option<String>,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostContentRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostContentResponse {
pub errors: Option<Vec<BrapiPostContentResponseErrorsItem>>,
pub meta: BrapiPostContentResponseMeta,
pub result: Option<String>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostContentResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostContentResponseMeta {
pub status: Option<f64>,
pub title: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostCrawlRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostCrawlResponse {
pub errors: Option<Vec<BrapiPostCrawlResponseErrorsItem>>,
pub result: String,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostCrawlResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostJsonRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostJsonResponse {
pub errors: Option<Vec<BrapiPostJsonResponseErrorsItem>>,
pub result: serde_json::Value,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostJsonResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostLinksRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostLinksResponse {
pub errors: Option<Vec<BrapiPostLinksResponseErrorsItem>>,
pub result: Vec<String>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostLinksResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostMarkdownRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostMarkdownResponse {
pub errors: Option<Vec<BrapiPostMarkdownResponseErrorsItem>>,
pub result: Option<String>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostMarkdownResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostPdfRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponse {
pub errors: Option<Vec<BrapiPostScrapeResponseErrorsItem>>,
pub result: Vec<BrapiPostScrapeResponseResultItem>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponseResultItem {
pub results: BrapiPostScrapeResponseResultItemResults,
pub selector: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponseResultItemResults {
pub attributes: Vec<BrapiPostScrapeResponseResultItemResultsAttributesItem>,
pub height: f64,
pub html: String,
pub left: f64,
pub text: String,
pub top: f64,
pub width: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponseResultItemResultsAttributesItem {
pub name: String,
pub value: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScreenshotRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScreenshotResponse {
pub errors: Option<Vec<BrapiPostScreenshotResponseErrorsItem>>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScreenshotResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotResponse {
pub errors: Option<Vec<BrapiPostSnapshotResponseErrorsItem>>,
pub meta: BrapiPostSnapshotResponseMeta,
pub result: Option<BrapiPostSnapshotResponseResult>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotResponseErrorsItem {
pub code: f64,
pub message: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotResponseMeta {
pub status: Option<f64>,
pub title: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotResponseResult {
pub content: String,
pub screenshot: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsApiResponseCommon {
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 CallsApiResponseSingle {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsApp {
pub created: Option<CallsCreated>,
pub modified: Option<CallsModified>,
pub name: Option<CallsName>,
pub uid: Option<CallsIdentifier>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppEditableFields {
pub name: Option<CallsName>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppResponseCollection {
pub result: Option<Vec<CallsApp>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppResponseSingle {
pub result: Option<CallsApp>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppResponseSingleWithSecret {
pub result: Option<CallsAppWithSecret>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppWithSecret {
pub created: Option<CallsCreated>,
pub modified: Option<CallsModified>,
pub name: Option<CallsName>,
pub secret: Option<CallsSecret>,
pub uid: Option<CallsIdentifier>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsCreated {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsModified {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsName {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsSecret {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKey {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyCollection {
pub result: Option<Vec<CallsTurnKeyObject>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyEditableFields {
pub name: Option<CallsTurnKeyName>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyName {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyObject {
pub created: Option<CallsCreated>,
pub modified: Option<CallsModified>,
pub name: Option<CallsName>,
pub uid: Option<CallsIdentifier>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyResponseSingle {
pub result: Option<CallsTurnKeyObject>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeySingleWithSecret {
pub result: Option<CallsTurnKeyWithKey>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyWithKey {
pub created: Option<CallsCreated>,
pub key: Option<CallsTurnKey>,
pub modified: Option<CallsModified>,
pub name: Option<CallsTurnKeyName>,
pub uid: Option<CallsIdentifier>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateAppResponse {
pub data: Option<CreateAppResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateAppResponseData {
pub app: Option<CreateAppResponseDataApp>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateAppResponseDataApp {
pub created_at: Option<String>,
pub id: Option<String>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct FetchAllLivestreamsResponse {
pub data: Option<FetchAllLivestreamsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct FetchAllLivestreamsResponseData {
pub created_at: Option<String>,
pub disabled: Option<String>,
pub id: Option<String>,
pub ingest_server: Option<String>,
pub meeting_id: Option<String>,
pub name: Option<String>,
pub paging: Option<FetchAllLivestreamsResponseDataPaging>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct FetchAllLivestreamsResponseDataPaging {
pub end_offset: Option<i64>,
pub start_offset: Option<i64>,
pub total_count: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetAppsResponse {
pub data: Option<Vec<GetAppsResponseDataItem>>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetAppsResponseDataItem {
pub created_at: Option<String>,
pub id: Option<String>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetLivestreamAnalyticsCompleteResponse {
pub data: Option<GetLivestreamAnalyticsCompleteResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetLivestreamAnalyticsCompleteResponseData {
pub count: Option<i64>,
pub total_ingest_seconds: Option<i64>,
pub total_viewer_seconds: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponse {
pub data: Option<GetOrgAnalyticsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponseData {
pub recording_stats: Option<GetOrgAnalyticsResponseDataRecordingStats>,
pub session_stats: Option<GetOrgAnalyticsResponseDataSessionStats>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponseDataRecordingStats {
pub day_stats: Option<Vec<GetOrgAnalyticsResponseDataRecordingStatsDayStatsItem>>,
pub recording_count: Option<i64>,
pub recording_minutes_consumed: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponseDataRecordingStatsDayStatsItem {
pub day: Option<String>,
pub total_recording_minutes: Option<i64>,
pub total_recordings: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponseDataSessionStats {
pub day_stats: Option<Vec<GetOrgAnalyticsResponseDataSessionStatsDayStatsItem>>,
pub sessions_count: Option<i64>,
pub sessions_minutes_consumed: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetOrgAnalyticsResponseDataSessionStatsDayStatsItem {
pub day: Option<String>,
pub total_session_minutes: Option<f64>,
pub total_sessions: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2ActiveLivestreamSessionDetailsResponse {
pub data: Option<GetV2ActiveLivestreamSessionDetailsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2ActiveLivestreamSessionDetailsResponseData {
pub livestream: Option<GetV2ActiveLivestreamSessionDetailsResponseDataLivestream>,
pub session: Option<GetV2ActiveLivestreamSessionDetailsResponseDataSession>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2ActiveLivestreamSessionDetailsResponseDataLivestream {
pub created_at: Option<String>,
pub disabled: Option<String>,
pub id: Option<String>,
pub ingest_server: Option<String>,
pub meeting_id: Option<String>,
pub name: Option<String>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2ActiveLivestreamSessionDetailsResponseDataSession {
pub created_at: Option<String>,
pub err_message: Option<String>,
pub id: Option<String>,
pub ingest_seconds: Option<String>,
pub invoked_time: Option<String>,
pub livestream_id: Option<String>,
pub started_time: Option<String>,
pub stopped_time: Option<String>,
pub updated_at: Option<String>,
pub viewer_seconds: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdResponse {
pub data: Option<GetV2LivestreamSessionLivestreamIdResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdResponseData {
pub livestream: Option<GetV2LivestreamSessionLivestreamIdResponseDataLivestream>,
pub paging: Option<GetV2LivestreamSessionLivestreamIdResponseDataPaging>,
pub session: Option<GetV2LivestreamSessionLivestreamIdResponseDataSession>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdResponseDataLivestream {
pub created_at: Option<String>,
pub disabled: Option<String>,
pub id: Option<String>,
pub ingest_server: Option<String>,
pub meeting_id: Option<String>,
pub name: Option<String>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdResponseDataPaging {
pub end_offset: Option<i64>,
pub start_offset: Option<i64>,
pub total_count: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdResponseDataSession {
pub created_at: Option<String>,
pub err_message: Option<String>,
pub id: Option<String>,
pub ingest_seconds: Option<f64>,
pub invoked_time: Option<String>,
pub livestream_id: Option<String>,
pub started_time: Option<String>,
pub stopped_time: Option<String>,
pub updated_at: Option<String>,
pub viewer_seconds: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamsLivestreamSessionIdResponse {
pub data: Option<GetV2LivestreamsLivestreamSessionIdResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamsLivestreamSessionIdResponseData {
pub created_at: Option<String>,
pub err_message: Option<String>,
pub id: Option<String>,
pub ingest_seconds: Option<i64>,
pub livestream_id: Option<String>,
pub started_time: Option<String>,
pub stopped_time: Option<String>,
pub updated_at: Option<String>,
pub viewer_seconds: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponse {
pub data: Option<GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponseData {
pub created_at: Option<String>,
pub err_message: Option<String>,
pub id: Option<String>,
pub ingest_seconds: Option<f64>,
pub invoked_time: Option<String>,
pub livestream_id: Option<String>,
pub paging: Option<GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponseDataPaging>,
pub stopped_time: Option<String>,
pub updated_at: Option<String>,
pub viewer_seconds: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponseDataPaging {
pub end_offset: Option<f64>,
pub start_offset: Option<f64>,
pub total_count: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2MeetingsMeetingIdActiveLivestreamResponse {
pub data: Option<GetV2MeetingsMeetingIdActiveLivestreamResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV2MeetingsMeetingIdActiveLivestreamResponseData {
pub created_at: Option<String>,
pub disabled: Option<String>,
pub id: Option<String>,
pub ingest_server: Option<String>,
pub meeting_id: Option<String>,
pub name: Option<String>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesApiResponseCollectionV2 {
pub result: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesApiResponseCommon {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: serde_json::Value,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesApiResponseSingle {
pub result: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesDeletedResponse {
pub result: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImage {
pub creator: Option<ImagesImageCreator>,
pub filename: Option<ImagesImageFilename>,
pub id: Option<ImagesImageIdentifier>,
pub meta: Option<ImagesImageMetadata>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<ImagesImageRequireSignedURLs>,
pub uploaded: Option<ImagesImageUploaded>,
pub variants: Option<Vec<serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageCreator {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageDirectUploadResponseV2 {
pub result: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageFilename {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageHeroUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeyName {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeyResponseCollection {
pub result: Option<ImagesImageKeysResponse>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeyValue {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeys {
pub name: Option<ImagesImageKeyName>,
pub value: Option<ImagesImageKeyValue>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeysResponse {
pub keys: Option<Vec<ImagesImageKeys>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageMetadata {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageOriginalUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagePatchRequest {
pub creator: Option<String>,
pub metadata: Option<serde_json::Value>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageRequireSignedURLs {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageResponseSingle {
pub result: Option<ImagesImage>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageThumbnailUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageUploaded {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantDefinition {
pub id: ImagesImageVariantIdentifier,
#[serde(rename = "neverRequireSignedURLs")]
pub never_require_signed_ur_ls: Option<ImagesImageVariantNeverRequireSignedURLs>,
pub options: ImagesImageVariantOptions,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantFit {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantFlatResponse {
pub result: Option<ImagesImageVariantDefinition>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantHeight {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantListResponse {
pub result: Option<ImagesImageVariantsResponse>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantNeverRequireSignedURLs {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantOptions {
pub fit: ImagesImageVariantFit,
pub height: ImagesImageVariantHeight,
pub metadata: ImagesImageVariantSchemasMetadata,
pub width: ImagesImageVariantWidth,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantPatchRequest {
#[serde(rename = "neverRequireSignedURLs")]
pub never_require_signed_ur_ls: Option<ImagesImageVariantNeverRequireSignedURLs>,
pub options: ImagesImageVariantOptions,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantPublicRequest {
pub hero: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantResponse {
pub variant: Option<ImagesImageVariantDefinition>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantSchemasMetadata {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantSimpleResponse {
pub result: Option<ImagesImageVariantResponse>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantWidth {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariants {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantsResponse {
pub variants: Option<ImagesImageVariantPublicRequest>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesListContinuationToken {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesListResponseV2 {
pub result: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStats {
pub count: Option<ImagesImagesStatsCount>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStatsAllowed {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStatsCount {
pub allowed: Option<ImagesImagesStatsAllowed>,
pub current: Option<ImagesImagesStatsCurrent>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStatsCurrent {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStatsResponse {
pub result: Option<ImagesImagesStats>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LivestreamSessionDetailsResponse {
pub data: Option<LivestreamSessionDetailsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LivestreamSessionDetailsResponseData {
pub livestreams: Option<Vec<LivestreamSessionDetailsResponseDataLivestreamsItem>>,
pub paging: Option<LivestreamSessionDetailsResponseDataPaging>,
pub sessions: Option<LivestreamSessionDetailsResponseDataSessions>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LivestreamSessionDetailsResponseDataLivestreamsItem {
pub created_at: Option<String>,
pub disabled: Option<bool>,
pub id: Option<String>,
pub ingest_server: Option<String>,
pub meeting_id: Option<String>,
pub name: Option<String>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LivestreamSessionDetailsResponseDataPaging {
pub end_offset: Option<i64>,
pub start_offset: Option<i64>,
pub total_count: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LivestreamSessionDetailsResponseDataSessions {
pub created_at: Option<String>,
pub err_message: Option<String>,
pub id: Option<String>,
pub ingest_seconds: Option<String>,
pub invoked_time: Option<String>,
pub livestream_id: Option<String>,
pub started_time: Option<String>,
pub stopped_time: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PauseResumeStopRecordingRequest {
pub action: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostSessionsSessionIdSummaryResponse {
pub data: Option<PostSessionsSessionIdSummaryResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostSessionsSessionIdSummaryResponseData {
pub message: Option<String>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponse {
pub result: RadarGetBgpRoutesRealtimeResponseResult,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResult {
pub meta: RadarGetBgpRoutesRealtimeResponseResultMeta,
pub routes: Vec<RadarGetBgpRoutesRealtimeResponseResultRoutesItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResultMeta {
pub asn_info: Vec<RadarGetBgpRoutesRealtimeResponseResultMetaAsnInfoItem>,
pub collectors: Vec<RadarGetBgpRoutesRealtimeResponseResultMetaCollectorsItem>,
pub data_time: String,
pub prefix_origins: Vec<RadarGetBgpRoutesRealtimeResponseResultMetaPrefixOriginsItem>,
pub query_time: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResultMetaAsnInfoItem {
pub as_name: String,
pub asn: i64,
pub country_code: String,
pub org_id: String,
pub org_name: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResultMetaCollectorsItem {
pub collector: String,
pub latest_realtime_ts: String,
pub latest_rib_ts: String,
pub latest_updates_ts: String,
pub peers_count: i64,
pub peers_v4_count: i64,
pub peers_v6_count: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResultMetaPrefixOriginsItem {
pub origin: i64,
pub prefix: String,
pub rpki_validation: String,
pub total_peers: i64,
pub total_visible: i64,
pub visibility: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeResponseResultRoutesItem {
pub as_path: Vec<i64>,
pub collector: String,
pub communities: Vec<String>,
pub prefix: String,
pub timestamp: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitAIConfig {
pub summarization: Option<RealtimekitSummarizationConfig>,
pub transcription: Option<RealtimekitTranscriptionConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitActiveSession {
pub associated_id: String,
pub breakout_rooms: Option<Vec<Box<RealtimekitActiveSession>>>,
pub created_at: String,
pub ended_at: Option<String>,
pub id: String,
pub live_participants: f64,
pub max_concurrent_participants: f64,
pub meeting_display_name: String,
pub meta: Option<serde_json::Value>,
pub minutes_consumed: f64,
pub organization_id: String,
pub started_at: String,
pub status: String,
#[serde(rename = "type")]
pub r#type: String,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitAddParticipantResponse {
pub data: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitAudioConfig {
pub channel: Option<String>,
pub codec: Option<String>,
pub export_file: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitCreatePollResponse {
pub data: Option<RealtimekitCreatePollResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitCreatePollResponseData {
pub action: Option<String>,
pub poll: Option<RealtimekitPoll>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitDeleteParticipantResponse {
pub data: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGenericSuccessResponse {
pub data: Option<serde_json::Value>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetActiveRecordingResponse {
pub data: RealtimekitRecording,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetActiveSessionResponse {
pub data: Option<Box<RealtimekitActiveSession>>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetAllMeetingsResponse {
pub data: Option<Vec<RealtimekitMeeting>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetAllParticipantsResponse {
pub data: Option<Vec<RealtimekitParticipant>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetAllPresetsResponse {
pub data: Option<Vec<RealtimekitPresetListItem>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetMeetingResponse {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponse {
pub data: Option<RealtimekitGetParticipantDataFromPeerIdResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseData {
pub participant: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipant>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipant {
pub created_at: Option<String>,
pub custom_participant_id: Option<String>,
pub display_name: Option<String>,
pub duration: Option<f64>,
pub id: Option<String>,
pub joined_at: Option<String>,
pub left_at: Option<String>,
pub peer_report: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReport>,
pub peer_stats: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStats>,
pub quality_stats: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantQualityStats>,
pub role: Option<String>,
pub updated_at: Option<String>,
pub user_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReport {
pub metadata: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadata>,
pub quality: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQuality>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadata {
pub audio_devices_updates: Option<Vec<serde_json::Value>>,
pub browser_metadata: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataBrowserMetadata>,
pub candidate_pairs: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataCandidatePairs>,
pub device_info: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataDeviceInfo>,
pub events: Option<Vec<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataEventsItem>>,
pub ip_information: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataIpInformation>,
pub pc_metadata: Option<Vec<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataPcMetadataItem>>,
pub room_view_type: Option<String>,
pub sdk_name: Option<String>,
pub sdk_version: Option<String>,
pub selected_device_updates: Option<Vec<serde_json::Value>>,
pub speaker_devices_updates: Option<Vec<serde_json::Value>>,
pub video_devices_updates: Option<Vec<serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataBrowserMetadata {
pub browser: Option<String>,
pub browser_version: Option<String>,
pub engine: Option<String>,
pub user_agent: Option<String>,
pub webgl_support: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataCandidatePairs {
pub consuming_transport: Option<Vec<serde_json::Value>>,
pub producing_transport: Option<Vec<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataCandidatePairsProducingTransportItem>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataCandidatePairsProducingTransportItem {
pub available_outgoing_bitrate: Option<i64>,
pub bytes_discarded_on_send: Option<i64>,
pub bytes_received: Option<i64>,
pub bytes_sent: Option<i64>,
pub current_round_trip_time: Option<f64>,
pub last_packet_received_timestamp: Option<i64>,
pub last_packet_sent_timestamp: Option<i64>,
pub local_candidate_address: Option<String>,
pub local_candidate_id: Option<String>,
pub local_candidate_network_type: Option<String>,
pub local_candidate_port: Option<i64>,
pub local_candidate_protocol: Option<String>,
pub local_candidate_related_address: Option<String>,
pub local_candidate_related_port: Option<i64>,
pub local_candidate_type: Option<String>,
pub nominated: Option<bool>,
pub packets_discarded_on_send: Option<i64>,
pub packets_received: Option<i64>,
pub packets_sent: Option<i64>,
pub remote_candidate_address: Option<String>,
pub remote_candidate_id: Option<String>,
pub remote_candidate_port: Option<i64>,
pub remote_candidate_protocol: Option<String>,
pub remote_candidate_type: Option<String>,
pub total_round_trip_time: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataDeviceInfo {
pub cpus: Option<i64>,
pub is_mobile: Option<bool>,
pub os: Option<String>,
pub os_version: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataEventsItem {
pub name: Option<String>,
pub timestamp: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataIpInformation {
pub asn: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataIpInformationAsn>,
pub city: Option<String>,
pub country: Option<String>,
pub ipv4: Option<String>,
pub region: Option<String>,
pub timezone: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataIpInformationAsn {
pub asn: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataPcMetadataItem {
pub effective_network_type: Option<String>,
pub reflexive_connectivity: Option<bool>,
pub relay_connectivity: Option<bool>,
pub timestamp: Option<String>,
pub turn_connectivity: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQuality {
pub audio_consumer: Option<Vec<serde_json::Value>>,
pub audio_consumer_cumulative: Option<serde_json::Value>,
pub audio_producer: Option<Vec<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerItem>>,
pub audio_producer_cumulative: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulative>,
pub screenshare_audio_consumer: Option<Vec<serde_json::Value>>,
pub screenshare_audio_consumer_cumulative: Option<serde_json::Value>,
pub screenshare_audio_producer: Option<Vec<serde_json::Value>>,
pub screenshare_audio_producer_cumulative: Option<serde_json::Value>,
pub screenshare_video_consumer: Option<Vec<serde_json::Value>>,
pub screenshare_video_consumer_cumulative: Option<serde_json::Value>,
pub screenshare_video_producer: Option<Vec<serde_json::Value>>,
pub screenshare_video_producer_cumulative: Option<serde_json::Value>,
pub video_consumer: Option<Vec<serde_json::Value>>,
pub video_consumer_cumulative: Option<serde_json::Value>,
pub video_producer: Option<Vec<serde_json::Value>>,
pub video_producer_cumulative: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulative {
pub packet_loss: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativePacketLoss>,
pub quality_mos: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativeQualityMos>,
pub rtt: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativeRtt>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativePacketLoss {
#[serde(rename = "10_or_greater_event_fraction")]
pub field_10_or_greater_event_fraction: Option<i64>,
#[serde(rename = "25_or_greater_event_fraction")]
pub field_25_or_greater_event_fraction: Option<i64>,
#[serde(rename = "50_or_greater_event_fraction")]
pub field_50_or_greater_event_fraction: Option<i64>,
#[serde(rename = "5_or_greater_event_fraction")]
pub field_5_or_greater_event_fraction: Option<i64>,
pub avg: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativeQualityMos {
pub avg: Option<i64>,
pub p50: Option<i64>,
pub p75: Option<i64>,
pub p90: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerCumulativeRtt {
#[serde(rename = "100ms_or_greater_event_fraction")]
pub field_100ms_or_greater_event_fraction: Option<f64>,
#[serde(rename = "250ms_or_greater_event_fraction")]
pub field_250ms_or_greater_event_fraction: Option<f64>,
#[serde(rename = "500ms_or_greater_event_fraction")]
pub field_500ms_or_greater_event_fraction: Option<f64>,
pub avg: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportQualityAudioProducerItem {
pub bytes_sent: Option<i64>,
pub jitter: Option<i64>,
pub mid: Option<String>,
pub mos_quality: Option<i64>,
pub packets_lost: Option<i64>,
pub packets_sent: Option<i64>,
pub producer_id: Option<String>,
pub rtt: Option<f64>,
pub ssrc: Option<i64>,
pub timestamp: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStats {
pub device_info: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsDeviceInfo>,
pub events: Option<Vec<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItem>>,
pub ip_information: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsIpInformation>,
pub precall_network_information: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsPrecallNetworkInformation>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsDeviceInfo {
pub browser: Option<String>,
pub browser_version: Option<String>,
pub cpus: Option<i64>,
pub engine: Option<String>,
pub is_mobile: Option<bool>,
pub os: Option<String>,
pub os_version: Option<String>,
pub sdk_name: Option<String>,
pub sdk_version: Option<String>,
pub user_agent: Option<String>,
pub webgl_support: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItem {
pub metadata: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadata>,
pub timestamp: Option<String>,
#[serde(rename = "type")]
pub r#type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadata {
pub connection_info: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfo>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfo {
pub backend_r_t_t: Option<f64>,
pub connectivity: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoConnectivity>,
pub effective_network_type: Option<String>,
pub fractional_loss: Option<i64>,
pub ip_details: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoIpDetails>,
pub jitter: Option<i64>,
pub location: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoLocation>,
pub r_t_t: Option<f64>,
pub throughput: Option<i64>,
pub turn_connectivity: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoConnectivity {
pub host: Option<bool>,
pub reflexive: Option<bool>,
pub relay: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoIpDetails {
pub asn: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoIpDetailsAsn>,
pub city: Option<String>,
pub country: Option<String>,
pub ip: Option<String>,
pub loc: Option<String>,
pub postal: Option<String>,
pub region: Option<String>,
pub timezone: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoIpDetailsAsn {
pub asn: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoLocation {
pub coords: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoLocationCoords>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoLocationCoords {
pub latitude: Option<f64>,
pub longitude: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsIpInformation {
pub asn: Option<RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsIpInformationAsn>,
pub city: Option<String>,
pub country: Option<String>,
pub ip_location: Option<String>,
pub ipv4: Option<String>,
pub org: Option<String>,
pub region: Option<String>,
pub timezone: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsIpInformationAsn {
pub asn: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsPrecallNetworkInformation {
pub backend_rtt: Option<f64>,
pub effective_networktype: Option<String>,
pub fractional_loss: Option<i64>,
pub jitter: Option<i64>,
pub reflexive_connectivity: Option<bool>,
pub relay_connectivity: Option<bool>,
pub rtt: Option<f64>,
pub throughput: Option<i64>,
pub turn_connectivity: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantQualityStats {
pub audio_bandwidth: Option<i64>,
pub audio_stats: Option<Vec<serde_json::Value>>,
pub average_quality: Option<i64>,
pub end: Option<String>,
pub first_audio_packet_received: Option<String>,
pub first_video_packet_received: Option<String>,
pub last_audio_packet_received: Option<String>,
pub last_video_packet_received: Option<String>,
pub peer_ids: Option<Vec<String>>,
pub start: Option<String>,
pub total_audio_packets: Option<i64>,
pub total_audio_packets_lost: Option<i64>,
pub total_video_packets: Option<i64>,
pub total_video_packets_lost: Option<i64>,
pub video_bandwidth: Option<i64>,
pub video_stats: Option<Vec<serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDetailsResponse {
pub data: Option<RealtimekitGetParticipantDetailsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantDetailsResponseData {
pub participant: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetParticipantResponse {
pub data: RealtimekitParticipant,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetPresetBodyResponse {
pub data: serde_json::Value,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetRecordingResponse {
pub data: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetRecordingsResponse {
pub data: Option<Vec<serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionDetailsResponse {
pub data: Option<RealtimekitGetSessionDetailsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionDetailsResponseData {
pub session: Option<Box<RealtimekitActiveSession>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionParticipantsResponse {
pub data: Option<RealtimekitGetSessionParticipantsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionParticipantsResponseData {
pub participants: Option<Vec<RealtimekitParticipantsList>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionTranscriptResponse {
pub data: Option<RealtimekitTranscript>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionTranscriptSummaryResponse {
pub data: Option<RealtimekitTranscriptSummary>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionsResponse {
pub data: Option<RealtimekitGetSessionsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetSessionsResponseData {
pub sessions: Option<Vec<Box<RealtimekitActiveSession>>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitKickAllParticipantsResponse {
pub data: Option<RealtimekitKickAllParticipantsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitKickAllParticipantsResponseData {
pub action: Option<String>,
pub kicked_participants_count: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitKickParticipantsResponse {
pub data: Option<RealtimekitKickParticipantsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitKickParticipantsResponseData {
pub action: Option<String>,
pub participants: Option<Vec<RealtimekitSessionParticipant>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitLivestreamingConfig {
pub rtmp_url: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitMeeting {
pub created_at: String,
pub id: String,
pub live_stream_on_start: Option<bool>,
pub persist_chat: Option<bool>,
pub record_on_start: Option<bool>,
pub session_keep_alive_time_in_secs: Option<f64>,
pub status: Option<String>,
pub summarize_on_end: Option<bool>,
pub title: Option<String>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitMuteAllParticipantsResponse {
pub data: Option<RealtimekitMuteAllParticipantsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitMuteAllParticipantsResponseData {
pub action: Option<String>,
pub muted_participants_count: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitMuteParticipantsResponse {
pub data: Option<RealtimekitMuteParticipantsResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitMuteParticipantsResponseData {
pub action: Option<String>,
pub participants: Option<Vec<RealtimekitSessionParticipant>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitPagingResponse {
pub data: Vec<serde_json::Value>,
pub paging: std::collections::HashMap<String, serde_json::Value>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitParticipant {
pub created_at: String,
pub custom_participant_id: String,
pub id: String,
pub name: Option<String>,
pub picture: Option<String>,
pub preset_name: String,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitParticipantsList {
pub created_at: Option<String>,
pub custom_participant_id: Option<String>,
pub display_name: Option<String>,
pub duration: Option<f64>,
pub id: Option<String>,
pub joined_at: Option<String>,
pub left_at: Option<String>,
pub preset_name: Option<String>,
pub updated_at: Option<String>,
pub user_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitPatchWebhookRequest {
pub enabled: Option<bool>,
pub events: Option<Vec<String>>,
pub name: Option<String>,
pub url: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitPoll {
pub anonymous: Option<bool>,
pub created_by: Option<String>,
pub hide_votes: Option<bool>,
pub id: String,
pub options: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub question: String,
pub voted: Option<Vec<String>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitPresetListItem {
pub created_at: Option<String>,
pub id: Option<String>,
pub name: Option<String>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitRealtimekitBucketConfig {
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitRecording {
pub audio_download_url: Option<String>,
pub download_url: Option<String>,
pub download_url_expiry: Option<String>,
pub file_size: Option<f64>,
pub id: String,
pub invoked_time: String,
pub output_file_name: String,
pub recording_duration: Option<i64>,
pub session_id: Option<String>,
pub started_time: Option<String>,
pub status: String,
pub stopped_time: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitRecordingConfig {
pub audio_config: Option<RealtimekitAudioConfig>,
pub file_name_prefix: Option<String>,
pub live_streaming_config: Option<RealtimekitLivestreamingConfig>,
pub max_seconds: Option<f64>,
pub realtimekit_bucket_config: Option<RealtimekitRealtimekitBucketConfig>,
pub storage_config: Option<RealtimekitStorageConfig>,
pub video_config: Option<RealtimekitVideoConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitRegenTokenResponse {
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitSessionParticipant {
pub created_at: String,
pub email: Option<String>,
pub id: String,
pub name: Option<String>,
pub picture: Option<String>,
pub updated_at: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitStorageConfig {
pub access_key: Option<String>,
pub auth_method: Option<String>,
pub bucket: Option<String>,
pub host: Option<String>,
pub password: Option<String>,
pub path: Option<String>,
pub port: Option<f64>,
pub private_key: Option<String>,
pub region: Option<String>,
pub secret: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
pub username: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitSummarizationConfig {
pub summary_type: Option<String>,
pub text_format: Option<String>,
pub word_limit: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitTranscript {
#[serde(rename = "sessionId")]
pub session_id: String,
pub transcript_download_url: String,
pub transcript_download_url_expiry: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitTranscriptSummary {
#[serde(rename = "sessionId")]
pub session_id: String,
#[serde(rename = "summaryDownloadUrl")]
pub summary_download_url: String,
#[serde(rename = "summaryDownloadUrlExpiry")]
pub summary_download_url_expiry: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitTranscriptionConfig {
pub keywords: Option<Vec<String>>,
pub language: Option<String>,
pub profanity_filter: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitVideoConfig {
pub codec: Option<String>,
pub export_file: Option<bool>,
pub height: Option<i64>,
pub watermark: Option<std::collections::HashMap<String, serde_json::Value>>,
pub width: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitWebhook {
pub created_at: String,
pub enabled: bool,
pub events: Vec<String>,
pub id: String,
pub name: String,
pub updated_at: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitWebhookRequest {
pub enabled: Option<bool>,
pub events: Vec<String>,
pub name: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitWebhookSuccessResponse {
pub data: RealtimekitWebhook,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitWebhooksListSuccessResponse {
pub data: Vec<RealtimekitWebhook>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StartLivestreamingRequest {
pub name: Option<String>,
pub video_config: Option<StartLivestreamingRequestVideoConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StartLivestreamingRequestVideoConfig {
pub height: Option<i64>,
pub width: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StartLivestreamingResponse {
pub data: Option<StartLivestreamingResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StartLivestreamingResponseData {
pub id: Option<String>,
pub ingest_server: Option<String>,
pub playback_url: Option<String>,
pub status: Option<String>,
pub stream_key: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StopLivestreamingResponse {
pub data: Option<StopLivestreamingResponseData>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StopLivestreamingResponseData {
pub message: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamAllowedOrigins {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamApiResponseCommon {
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 StreamCreated {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamCreator {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamDownloadedFrom {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamDuration {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamErrorReasonCode {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamErrorReasonText {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamHeight {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInput {
pub height: Option<i64>,
pub width: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputRtmps {
#[serde(rename = "streamKey")]
pub stream_key: Option<StreamInputRtmpsStreamKey>,
pub url: Option<StreamInputRtmpsUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputRtmpsStreamKey {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputRtmpsUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputSrt {
pub passphrase: Option<StreamInputSrtStreamPassphrase>,
#[serde(rename = "streamId")]
pub stream_id: Option<StreamInputSrtStreamId>,
pub url: Option<StreamInputSrtUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputSrtStreamId {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputSrtStreamPassphrase {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputSrtUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputWebrtc {
pub url: Option<StreamInputWebrtcUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamInputWebrtcUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInput {
pub created: Option<StreamLiveInputCreated>,
#[serde(rename = "deleteRecordingAfterDays")]
pub delete_recording_after_days: Option<StreamLiveInputRecordingDeletion>,
pub enabled: Option<StreamLiveInputEnabled>,
pub meta: Option<StreamLiveInputMetadata>,
pub modified: Option<StreamLiveInputModified>,
pub recording: Option<StreamLiveInputRecordingSettings>,
pub rtmps: Option<StreamInputRtmps>,
#[serde(rename = "rtmpsPlayback")]
pub rtmps_playback: Option<StreamPlaybackRtmps>,
pub srt: Option<StreamInputSrt>,
#[serde(rename = "srtPlayback")]
pub srt_playback: Option<StreamPlaybackSrt>,
pub status: Option<StreamLiveInputStatus>,
pub uid: Option<StreamLiveInputIdentifier>,
#[serde(rename = "webRTC")]
pub web_rtc: Option<StreamInputWebrtc>,
#[serde(rename = "webRTCPlayback")]
pub web_rtc_playback: Option<StreamPlaybackWebrtc>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputCreated {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputEnabled {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputMetadata {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputModified {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingAllowedOrigins {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingDeletion {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingHideLiveViewerCount {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingMode {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingRequireSignedURLs {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingSettings {
#[serde(rename = "allowedOrigins")]
pub allowed_origins: Option<Vec<String>>,
#[serde(rename = "hideLiveViewerCount")]
pub hide_live_viewer_count: Option<StreamLiveInputRecordingHideLiveViewerCount>,
pub mode: Option<StreamLiveInputRecordingMode>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<StreamLiveInputRecordingRequireSignedURLs>,
#[serde(rename = "timeoutSeconds")]
pub timeout_seconds: Option<StreamLiveInputRecordingTimeoutSeconds>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputRecordingTimeoutSeconds {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputStatus {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamMaxDurationSeconds {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamMediaMetadata {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamMediaState {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamMediaStatus {
#[serde(rename = "errorReasonCode")]
pub error_reason_code: Option<StreamErrorReasonCode>,
#[serde(rename = "errorReasonText")]
pub error_reason_text: Option<StreamErrorReasonText>,
#[serde(rename = "pctComplete")]
pub pct_complete: Option<StreamPctComplete>,
pub state: Option<StreamMediaState>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamModified {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamName {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamOneTimeUploadExpiry {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamOpacity {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPadding {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPctComplete {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlayback {
pub dash: Option<String>,
pub hls: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackRtmps {
#[serde(rename = "streamKey")]
pub stream_key: Option<StreamPlaybackRtmpsStreamKey>,
pub url: Option<StreamPlaybackRtmpsUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackRtmpsStreamKey {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackRtmpsUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackSrt {
pub passphrase: Option<StreamPlaybackSrtStreamPassphrase>,
#[serde(rename = "streamId")]
pub stream_id: Option<StreamPlaybackSrtStreamId>,
pub url: Option<StreamPlaybackSrtUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackSrtStreamId {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackSrtStreamPassphrase {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackSrtUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackWebrtc {
pub url: Option<StreamPlaybackWebrtcUrl>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPlaybackWebrtcUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPosition {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamPreview {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamReadyToStream {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamReadyToStreamAt {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamRequireSignedURLs {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamScale {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamScheduledDeletion {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamSize {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamThumbnailTimestampPct {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamThumbnailUrl {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamUploaded {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideoResponseCollection {
pub range: Option<i64>,
pub result: Option<Vec<StreamVideos>>,
pub total: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideos {
#[serde(rename = "allowedOrigins")]
pub allowed_origins: Option<Vec<String>>,
pub created: Option<StreamCreated>,
pub creator: Option<StreamCreator>,
pub duration: Option<StreamDuration>,
pub input: Option<StreamInput>,
#[serde(rename = "liveInput")]
pub live_input: Option<StreamLiveInput>,
#[serde(rename = "maxDurationSeconds")]
pub max_duration_seconds: Option<StreamMaxDurationSeconds>,
pub meta: Option<StreamMediaMetadata>,
pub modified: Option<StreamModified>,
pub playback: Option<StreamPlayback>,
pub preview: Option<StreamPreview>,
#[serde(rename = "readyToStream")]
pub ready_to_stream: Option<StreamReadyToStream>,
#[serde(rename = "readyToStreamAt")]
pub ready_to_stream_at: Option<StreamReadyToStreamAt>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<StreamRequireSignedURLs>,
#[serde(rename = "scheduledDeletion")]
pub scheduled_deletion: Option<StreamScheduledDeletion>,
pub size: Option<StreamSize>,
pub status: Option<StreamMediaStatus>,
pub thumbnail: Option<StreamThumbnailUrl>,
#[serde(rename = "thumbnailTimestampPct")]
pub thumbnail_timestamp_pct: Option<StreamThumbnailTimestampPct>,
pub uid: Option<StreamIdentifier>,
#[serde(rename = "uploadExpiry")]
pub upload_expiry: Option<StreamOneTimeUploadExpiry>,
pub uploaded: Option<StreamUploaded>,
pub watermark: Option<StreamWatermarks>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWatermarkCreated {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWatermarkIdentifier {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWatermarkSize {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWatermarks {
pub created: Option<StreamWatermarkCreated>,
#[serde(rename = "downloadedFrom")]
pub downloaded_from: Option<StreamDownloadedFrom>,
pub height: Option<StreamHeight>,
pub name: Option<StreamName>,
pub opacity: Option<StreamOpacity>,
pub padding: Option<StreamPadding>,
pub position: Option<StreamPosition>,
pub scale: Option<StreamScale>,
pub size: Option<StreamWatermarkSize>,
pub uid: Option<StreamWatermarkIdentifier>,
pub width: Option<StreamWidth>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWidth {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostContentArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostContentRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostCrawlArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostCrawlRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiGetCrawlResultArgs {
pub account_id: String,
pub job_id: String,
pub cache_ttl: Option<String>,
pub status: Option<String>,
pub cursor: Option<String>,
pub limit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiDeleteCancelCrawlArgs {
pub account_id: String,
pub job_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostJsonArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostJsonRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostLinksArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostLinksRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostMarkdownArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostMarkdownRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostPdfArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostPdfRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostScrapeArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostScrapeRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostScreenshotArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostScreenshotRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct BrapiPostSnapshotArgs {
pub account_id: String,
pub cache_ttl: Option<String>,
pub body: BrapiPostSnapshotRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsListArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsCreateANewAppArgs {
pub account_id: String,
pub body: CallsAppEditableFields,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsRetrieveAppDetailsArgs {
pub app_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsUpdateAppDetailsArgs {
pub app_id: String,
pub account_id: String,
pub body: CallsAppEditableFields,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsDeleteAppArgs {
pub app_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsTurnKeyListArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsTurnKeyCreateArgs {
pub account_id: String,
pub body: CallsTurnKeyEditableFields,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsRetrieveTurnKeyDetailsArgs {
pub key_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsUpdateTurnKeyArgs {
pub key_id: String,
pub account_id: String,
pub body: CallsTurnKeyEditableFields,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsDeleteTurnKeyArgs {
pub key_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesUploadAnImageViaUrlArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesKeysListSigningKeysArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesKeysAddSigningKeyArgs {
pub signing_key_name: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesKeysDeleteSigningKeyArgs {
pub signing_key_name: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesImagesUsageStatisticsArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsListVariantsArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsCreateAVariantArgs {
pub account_id: String,
pub body: ImagesImageVariantDefinition,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsVariantDetailsArgs {
pub variant_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsUpdateAVariantArgs {
pub variant_id: String,
pub account_id: String,
pub body: ImagesImageVariantPatchRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsDeleteAVariantArgs {
pub variant_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsVariantDetailsFlatArgs {
pub variant_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesImageDetailsArgs {
pub image_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesUpdateImageArgs {
pub image_id: String,
pub account_id: String,
pub body: ImagesImagePatchRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesDeleteImageArgs {
pub image_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesBaseImageArgs {
pub image_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesListImagesV2Args {
pub account_id: String,
pub continuation_token: Option<String>,
pub per_page: Option<String>,
pub sort_order: Option<String>,
pub creator: Option<String>,
pub meta_field_operator: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesCreateAuthenticatedDirectUploadUrlV2Args {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAppsArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateAppArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetOrgAnalyticsArgs {
pub account_id: String,
pub app_id: String,
pub start_date: Option<String>,
pub end_date: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetLivestreamAnalyticsCompleteArgs {
pub account_id: String,
pub app_id: String,
pub start_time: Option<String>,
pub end_time: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct FetchAllLivestreamsArgs {
pub account_id: String,
pub app_id: String,
pub exclude_meetings: Option<String>,
pub per_page: Option<String>,
pub page_no: Option<String>,
pub status: Option<String>,
pub start_time: Option<String>,
pub end_time: Option<String>,
pub sort_order: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV2LivestreamsLivestreamSessionIdArgs {
pub account_id: String,
pub app_id: String,
pub livestream_session_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV2LivestreamSessionLivestreamIdArgs {
pub account_id: String,
pub app_id: String,
pub livestream_id: String,
pub page_no: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV2ActiveLivestreamSessionDetailsArgs {
pub account_id: String,
pub app_id: String,
pub livestream_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAllMeetingsArgs {
pub account_id: String,
pub app_id: String,
pub page_no: Option<String>,
pub per_page: Option<String>,
pub start_time: Option<String>,
pub end_time: Option<String>,
pub search: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateMeetingArgs {
pub account_id: String,
pub app_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetMeetingArgs {
pub meeting_id: String,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ReplaceMeetingArgs {
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateMeetingArgs {
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV2MeetingsMeetingIdActiveLivestreamArgs {
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StopLivestreamingArgs {
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetActiveSessionArgs {
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct KickPartcipantsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct KickAllParticipantsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MuteParticipantsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MuteAllParticipantsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreatePollArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct LivestreamSessionDetailsArgs {
pub meeting_id: String,
pub page_no: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StartLivestreamingArgs {
pub meeting_id: String,
pub body: StartLivestreamingRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetMeetingParticipantsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
pub page_no: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AddParticipantArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetMeetingParticipantArgs {
pub meeting_id: String,
pub participant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct EditParticipantArgs {
pub meeting_id: String,
pub participant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteMeetingParticipantArgs {
pub meeting_id: String,
pub participant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RegenerateTokenArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
pub participant_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetPresetsArgs {
pub account_id: String,
pub app_id: String,
pub per_page: Option<String>,
pub page_no: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostPresetsArgs {
pub account_id: String,
pub app_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetPresetsPresetIdArgs {
pub account_id: String,
pub app_id: String,
pub preset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PatchPresetsPresetIdArgs {
pub account_id: String,
pub app_id: String,
pub preset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeletePresetsPresetIdArgs {
pub account_id: String,
pub app_id: String,
pub preset_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAllRecordingsArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: Option<String>,
pub page_no: Option<String>,
pub per_page: Option<String>,
pub expired: Option<String>,
pub search: Option<String>,
pub sort_by: Option<String>,
pub sort_order: Option<String>,
pub start_time: Option<String>,
pub end_time: Option<String>,
pub status: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StartRecordingArgs {
pub account_id: String,
pub app_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetActiveRecordingArgs {
pub account_id: String,
pub app_id: String,
pub meeting_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StartTrackRecordingForAMeetingArgs {
pub account_id: String,
pub app_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetOneRecordingArgs {
pub account_id: String,
pub app_id: String,
pub recording_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PauseResumeStopRecordingArgs {
pub account_id: String,
pub app_id: String,
pub recording_id: String,
pub body: PauseResumeStopRecordingRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSessionsArgs {
pub account_id: String,
pub app_id: String,
pub page_no: Option<String>,
pub per_page: Option<String>,
pub sort_by: Option<String>,
pub sort_order: Option<String>,
pub start_time: Option<String>,
pub end_time: Option<String>,
pub participants: Option<String>,
pub status: Option<String>,
pub search: Option<String>,
pub associated_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetParticipantDataFromPeerIdArgs {
pub account_id: String,
pub app_id: String,
pub peer_id: String,
pub filters: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSessionDetailsArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
pub include_breakout_rooms: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV2LivestreamsessionSessionMeetingIdActiveLivestreamArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
pub per_page: Option<String>,
pub page_no: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSessionParticipantsArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
pub search: Option<String>,
pub page_no: Option<String>,
pub per_page: Option<String>,
pub sort_order: Option<String>,
pub sort_by: Option<String>,
pub include_peer_events: Option<String>,
pub view: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetParticipantDetailsArgs {
pub account_id: String,
pub app_id: String,
pub participant_id: String,
pub session_id: String,
pub filters: Option<String>,
pub include_peer_events: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSessionSummaryArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostSessionsSessionIdSummaryArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSessionTranscriptArgs {
pub account_id: String,
pub app_id: String,
pub session_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetAllWebhooksArgs {
pub account_id: String,
pub app_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AddWebhookArgs {
pub account_id: String,
pub app_id: String,
pub body: RealtimekitWebhookRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetWebhookArgs {
pub account_id: String,
pub app_id: String,
pub webhook_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ReplaceWebhookArgs {
pub account_id: String,
pub app_id: String,
pub webhook_id: String,
pub body: RealtimekitWebhookRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct EditWebhookArgs {
pub account_id: String,
pub app_id: String,
pub webhook_id: String,
pub body: RealtimekitPatchWebhookRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteWebhookArgs {
pub account_id: String,
pub app_id: String,
pub webhook_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosListVideosArgs {
pub account_id: String,
pub status: Option<String>,
pub creator: Option<String>,
pub r#type: Option<String>,
pub asc: Option<String>,
pub video_name: Option<String>,
pub search: Option<String>,
pub start: Option<String>,
pub end: Option<String>,
pub include_counts: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosInitiateVideoUploadsUsingTusArgs {
pub account_id: String,
pub direct_user: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRoutesRealtimeArgs {
pub prefix: Option<String>,
pub format: Option<String>,
}
pub async fn brapi_post_content_request<F>(
client: DynNetClient,
args: &BrapiPostContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostContentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/content",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostContentResponse = 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 brapi_post_crawl_request<F>(
client: DynNetClient,
args: &BrapiPostCrawlArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostCrawlResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/crawl",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostCrawlResponse = 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 brapi_get_crawl_result_request<F>(
client: DynNetClient,
args: &BrapiGetCrawlResultArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiGetCrawlResultResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/crawl/{}",
args.account_id,
args.job_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("cacheTTL", args.cache_ttl.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
builder = builder.query("limit", args.limit.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: BrapiGetCrawlResultResponse = 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 brapi_delete_cancel_crawl_request<F>(
client: DynNetClient,
args: &BrapiDeleteCancelCrawlArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiDeleteCancelCrawlResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/crawl/{}",
args.account_id,
args.job_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: BrapiDeleteCancelCrawlResponse = 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 brapi_post_json_request<F>(
client: DynNetClient,
args: &BrapiPostJsonArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostJsonResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/json",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostJsonResponse = 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 brapi_post_links_request<F>(
client: DynNetClient,
args: &BrapiPostLinksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostLinksResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/links",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostLinksResponse = 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 brapi_post_markdown_request<F>(
client: DynNetClient,
args: &BrapiPostMarkdownArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostMarkdownResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/markdown",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostMarkdownResponse = 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 brapi_post_pdf_request<F>(
client: DynNetClient,
args: &BrapiPostPdfArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/pdf",
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.query("cacheTTL", args.cache_ttl.as_deref());
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 });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn brapi_post_scrape_request<F>(
client: DynNetClient,
args: &BrapiPostScrapeArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostScrapeResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/scrape",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostScrapeResponse = 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 brapi_post_screenshot_request<F>(
client: DynNetClient,
args: &BrapiPostScreenshotArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostScreenshotResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/screenshot",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostScreenshotResponse = 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 brapi_post_snapshot_request<F>(
client: DynNetClient,
args: &BrapiPostSnapshotArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BrapiPostSnapshotResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/browser-rendering/snapshot",
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.query("cacheTTL", args.cache_ttl.as_deref());
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: BrapiPostSnapshotResponse = 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 calls_apps_list_request<F>(
client: DynNetClient,
args: &CallsAppsListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsAppResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/apps",
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: CallsAppResponseCollection = 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 calls_apps_create_a_new_app_request<F>(
client: DynNetClient,
args: &CallsAppsCreateANewAppArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsAppResponseSingleWithSecret>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/apps",
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: CallsAppResponseSingleWithSecret = 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 calls_apps_retrieve_app_details_request<F>(
client: DynNetClient,
args: &CallsAppsRetrieveAppDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsAppResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/apps/{}",
args.account_id,
args.app_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: CallsAppResponseSingle = 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 calls_apps_update_app_details_request<F>(
client: DynNetClient,
args: &CallsAppsUpdateAppDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsAppResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/apps/{}",
args.account_id,
args.app_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: CallsAppResponseSingle = 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 calls_apps_delete_app_request<F>(
client: DynNetClient,
args: &CallsAppsDeleteAppArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsAppResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/apps/{}",
args.account_id,
args.app_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: CallsAppResponseSingle = 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 calls_turn_key_list_request<F>(
client: DynNetClient,
args: &CallsTurnKeyListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsTurnKeyCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/turn_keys",
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: CallsTurnKeyCollection = 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 calls_turn_key_create_request<F>(
client: DynNetClient,
args: &CallsTurnKeyCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsTurnKeySingleWithSecret>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/turn_keys",
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: CallsTurnKeySingleWithSecret = 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 calls_retrieve_turn_key_details_request<F>(
client: DynNetClient,
args: &CallsRetrieveTurnKeyDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsTurnKeyResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/turn_keys/{}",
args.account_id,
args.key_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: CallsTurnKeyResponseSingle = 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 calls_update_turn_key_request<F>(
client: DynNetClient,
args: &CallsUpdateTurnKeyArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsTurnKeyResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/turn_keys/{}",
args.account_id,
args.key_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: CallsTurnKeyResponseSingle = 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 calls_delete_turn_key_request<F>(
client: DynNetClient,
args: &CallsDeleteTurnKeyArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CallsTurnKeyResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/calls/turn_keys/{}",
args.account_id,
args.key_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: CallsTurnKeyResponseSingle = 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 cloudflare_images_upload_an_image_via_url_request<F>(
client: DynNetClient,
args: &CloudflareImagesUploadAnImageViaUrlArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1",
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()))?;
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: ImagesImageResponseSingle = 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 cloudflare_images_keys_list_signing_keys_request<F>(
client: DynNetClient,
args: &CloudflareImagesKeysListSigningKeysArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageKeyResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/keys",
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: ImagesImageKeyResponseCollection = 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 cloudflare_images_keys_add_signing_key_request<F>(
client: DynNetClient,
args: &CloudflareImagesKeysAddSigningKeyArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageKeyResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/keys/{}",
args.account_id,
args.signing_key_name,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&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: ImagesImageKeyResponseCollection = 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 cloudflare_images_keys_delete_signing_key_request<F>(
client: DynNetClient,
args: &CloudflareImagesKeysDeleteSigningKeyArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageKeyResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/keys/{}",
args.account_id,
args.signing_key_name,
);
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: ImagesImageKeyResponseCollection = 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 cloudflare_images_images_usage_statistics_request<F>(
client: DynNetClient,
args: &CloudflareImagesImagesUsageStatisticsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImagesStatsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/stats",
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: ImagesImagesStatsResponse = 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 cloudflare_images_variants_list_variants_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsListVariantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageVariantListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants",
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: ImagesImageVariantListResponse = 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 cloudflare_images_variants_create_a_variant_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsCreateAVariantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageVariantSimpleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants",
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: ImagesImageVariantSimpleResponse = 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 cloudflare_images_variants_variant_details_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsVariantDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageVariantSimpleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants/{}",
args.account_id,
args.variant_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: ImagesImageVariantSimpleResponse = 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 cloudflare_images_variants_update_a_variant_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsUpdateAVariantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageVariantSimpleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants/{}",
args.account_id,
args.variant_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: ImagesImageVariantSimpleResponse = 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 cloudflare_images_variants_delete_a_variant_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsDeleteAVariantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesDeletedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants/{}",
args.account_id,
args.variant_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: ImagesDeletedResponse = 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 cloudflare_images_variants_variant_details_flat_request<F>(
client: DynNetClient,
args: &CloudflareImagesVariantsVariantDetailsFlatArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageVariantFlatResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/variants/{}/flat",
args.account_id,
args.variant_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: ImagesImageVariantFlatResponse = 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 cloudflare_images_image_details_request<F>(
client: DynNetClient,
args: &CloudflareImagesImageDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/{}",
args.account_id,
args.image_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: ImagesImageResponseSingle = 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 cloudflare_images_update_image_request<F>(
client: DynNetClient,
args: &CloudflareImagesUpdateImageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/{}",
args.account_id,
args.image_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: ImagesImageResponseSingle = 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 cloudflare_images_delete_image_request<F>(
client: DynNetClient,
args: &CloudflareImagesDeleteImageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesDeletedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/{}",
args.account_id,
args.image_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: ImagesDeletedResponse = 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 cloudflare_images_base_image_request<F>(
client: DynNetClient,
args: &CloudflareImagesBaseImageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v1/{}/blob",
args.account_id,
args.image_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 });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn cloudflare_images_list_images_v2_request<F>(
client: DynNetClient,
args: &CloudflareImagesListImagesV2Args,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImagesListResponseV2>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v2",
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("continuation_token", args.continuation_token.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
builder = builder.query("creator", args.creator.as_deref());
builder = builder.query("meta.<field>[<operator>]", args.meta_field_operator.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: ImagesImagesListResponseV2 = 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 cloudflare_images_create_authenticated_direct_upload_url_v_2_request<F>(
client: DynNetClient,
args: &CloudflareImagesCreateAuthenticatedDirectUploadUrlV2Args,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ImagesImageDirectUploadResponseV2>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/images/v2/direct_upload",
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()))?;
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: ImagesImageDirectUploadResponseV2 = 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 get_apps_request<F>(
client: DynNetClient,
args: &GetAppsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetAppsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/apps",
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: GetAppsResponse = 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 create_app_request<F>(
client: DynNetClient,
args: &CreateAppArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateAppResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/apps",
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()))?;
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: CreateAppResponse = 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 get_org_analytics_request<F>(
client: DynNetClient,
args: &GetOrgAnalyticsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetOrgAnalyticsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/analytics/daywise",
args.account_id,
args.app_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("start_date", args.start_date.as_deref());
builder = builder.query("end_date", args.end_date.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: GetOrgAnalyticsResponse = 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 get_livestream_analytics_complete_request<F>(
client: DynNetClient,
args: &GetLivestreamAnalyticsCompleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetLivestreamAnalyticsCompleteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/analytics/livestreams/overall",
args.account_id,
args.app_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("start_time", args.start_time.as_deref());
builder = builder.query("end_time", args.end_time.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: GetLivestreamAnalyticsCompleteResponse = 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 fetch_all_livestreams_request<F>(
client: DynNetClient,
args: &FetchAllLivestreamsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<FetchAllLivestreamsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/livestreams",
args.account_id,
args.app_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("exclude_meetings", args.exclude_meetings.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page_no", args.page_no.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("start_time", args.start_time.as_deref());
builder = builder.query("end_time", args.end_time.as_deref());
builder = builder.query("sort_order", args.sort_order.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: FetchAllLivestreamsResponse = 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 get_v2_livestreams_livestream_session_id_request<F>(
client: DynNetClient,
args: &GetV2LivestreamsLivestreamSessionIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV2LivestreamsLivestreamSessionIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/livestreams/sessions/{}",
args.account_id,
args.app_id,
args.livestream_session_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: GetV2LivestreamsLivestreamSessionIdResponse = 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 get_v2_livestream_session_livestream_id_request<F>(
client: DynNetClient,
args: &GetV2LivestreamSessionLivestreamIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV2LivestreamSessionLivestreamIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/livestreams/{}",
args.account_id,
args.app_id,
args.livestream_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("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.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: GetV2LivestreamSessionLivestreamIdResponse = 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 get_v2_active_livestream_session_details_request<F>(
client: DynNetClient,
args: &GetV2ActiveLivestreamSessionDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV2ActiveLivestreamSessionDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/livestreams/{}/active-livestream-session",
args.account_id,
args.app_id,
args.livestream_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: GetV2ActiveLivestreamSessionDetailsResponse = 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 get_all_meetings_request<F>(
client: DynNetClient,
args: &GetAllMeetingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetAllMeetingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings",
args.account_id,
args.app_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("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("start_time", args.start_time.as_deref());
builder = builder.query("end_time", args.end_time.as_deref());
builder = builder.query("search", args.search.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: RealtimekitGetAllMeetingsResponse = 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 create_meeting_request<F>(
client: DynNetClient,
args: &CreateMeetingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetMeetingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings",
args.account_id,
args.app_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: RealtimekitGetMeetingResponse = 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 get_meeting_request<F>(
client: DynNetClient,
args: &GetMeetingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetMeetingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}",
args.meeting_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("name", args.name.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: RealtimekitGetMeetingResponse = 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 replace_meeting_request<F>(
client: DynNetClient,
args: &ReplaceMeetingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetMeetingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}",
args.meeting_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()))?;
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: RealtimekitGetMeetingResponse = 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 update_meeting_request<F>(
client: DynNetClient,
args: &UpdateMeetingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetMeetingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}",
args.meeting_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()))?;
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: RealtimekitGetMeetingResponse = 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 get_v2_meetings_meeting_id_active_livestream_request<F>(
client: DynNetClient,
args: &GetV2MeetingsMeetingIdActiveLivestreamArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV2MeetingsMeetingIdActiveLivestreamResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/active-livestream",
args.meeting_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: GetV2MeetingsMeetingIdActiveLivestreamResponse = 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 stop_livestreaming_request<F>(
client: DynNetClient,
args: &StopLivestreamingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<StopLivestreamingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/active-livestream/stop",
args.meeting_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: StopLivestreamingResponse = 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 get_active_session_request<F>(
client: DynNetClient,
args: &GetActiveSessionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetActiveSessionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/active-session",
args.meeting_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: RealtimekitGetActiveSessionResponse = 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 kick_partcipants_request<F>(
client: DynNetClient,
args: &KickPartcipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitKickParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/active-session/kick",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitKickParticipantsResponse = 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 kick_all_participants_request<F>(
client: DynNetClient,
args: &KickAllParticipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitKickAllParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/active-session/kick-all",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitKickAllParticipantsResponse = 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 mute_participants_request<F>(
client: DynNetClient,
args: &MuteParticipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitMuteParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/active-session/mute",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitMuteParticipantsResponse = 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 mute_all_participants_request<F>(
client: DynNetClient,
args: &MuteAllParticipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitMuteAllParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/active-session/mute-all",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitMuteAllParticipantsResponse = 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 create_poll_request<F>(
client: DynNetClient,
args: &CreatePollArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitCreatePollResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/active-session/poll",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitCreatePollResponse = 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 livestream_session_details_request<F>(
client: DynNetClient,
args: &LivestreamSessionDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LivestreamSessionDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/livestream",
args.meeting_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("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.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: LivestreamSessionDetailsResponse = 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 start_livestreaming_request<F>(
client: DynNetClient,
args: &StartLivestreamingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<StartLivestreamingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/livestreams",
args.meeting_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: StartLivestreamingResponse = 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 get_meeting_participants_request<F>(
client: DynNetClient,
args: &GetMeetingParticipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetAllParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/participants",
args.account_id,
args.app_id,
args.meeting_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("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.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: RealtimekitGetAllParticipantsResponse = 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 add_participant_request<F>(
client: DynNetClient,
args: &AddParticipantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitAddParticipantResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/participants",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitAddParticipantResponse = 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 get_meeting_participant_request<F>(
client: DynNetClient,
args: &GetMeetingParticipantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetParticipantResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/participants/{}",
args.meeting_id,
args.participant_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: RealtimekitGetParticipantResponse = 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 edit_participant_request<F>(
client: DynNetClient,
args: &EditParticipantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitAddParticipantResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/participants/{}",
args.meeting_id,
args.participant_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()))?;
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: RealtimekitAddParticipantResponse = 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 delete_meeting_participant_request<F>(
client: DynNetClient,
args: &DeleteMeetingParticipantArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitDeleteParticipantResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{{account_id}}/realtime/kit/{{app_id}}/meetings/{}/participants/{}",
args.meeting_id,
args.participant_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: RealtimekitDeleteParticipantResponse = 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 regenerate_token_request<F>(
client: DynNetClient,
args: &RegenerateTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitRegenTokenResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/meetings/{}/participants/{}/token",
args.account_id,
args.app_id,
args.meeting_id,
args.participant_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: RealtimekitRegenTokenResponse = 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 get_presets_request<F>(
client: DynNetClient,
args: &GetPresetsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetAllPresetsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/presets",
args.account_id,
args.app_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("per_page", args.per_page.as_deref());
builder = builder.query("page_no", args.page_no.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: RealtimekitGetAllPresetsResponse = 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 post_presets_request<F>(
client: DynNetClient,
args: &PostPresetsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetPresetBodyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/presets",
args.account_id,
args.app_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: RealtimekitGetPresetBodyResponse = 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 get_presets_preset_id_request<F>(
client: DynNetClient,
args: &GetPresetsPresetIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetPresetBodyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/presets/{}",
args.account_id,
args.app_id,
args.preset_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: RealtimekitGetPresetBodyResponse = 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 patch_presets_preset_id_request<F>(
client: DynNetClient,
args: &PatchPresetsPresetIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetPresetBodyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/presets/{}",
args.account_id,
args.app_id,
args.preset_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()))?;
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: RealtimekitGetPresetBodyResponse = 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 delete_presets_preset_id_request<F>(
client: DynNetClient,
args: &DeletePresetsPresetIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetPresetBodyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/presets/{}",
args.account_id,
args.app_id,
args.preset_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: RealtimekitGetPresetBodyResponse = 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 get_all_recordings_request<F>(
client: DynNetClient,
args: &GetAllRecordingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetRecordingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings",
args.account_id,
args.app_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("meeting_id", args.meeting_id.as_deref());
builder = builder.query("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("expired", args.expired.as_deref());
builder = builder.query("search", args.search.as_deref());
builder = builder.query("sort_by", args.sort_by.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
builder = builder.query("start_time", args.start_time.as_deref());
builder = builder.query("end_time", args.end_time.as_deref());
builder = builder.query("status", args.status.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: RealtimekitGetRecordingsResponse = 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 start_recording_request<F>(
client: DynNetClient,
args: &StartRecordingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetRecordingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings",
args.account_id,
args.app_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: RealtimekitGetRecordingResponse = 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 get_active_recording_request<F>(
client: DynNetClient,
args: &GetActiveRecordingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetActiveRecordingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings/active-recording/{}",
args.account_id,
args.app_id,
args.meeting_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: RealtimekitGetActiveRecordingResponse = 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 start_track_recording_for_a_meeting_request<F>(
client: DynNetClient,
args: &StartTrackRecordingForAMeetingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings/track",
args.account_id,
args.app_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 });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn get_one_recording_request<F>(
client: DynNetClient,
args: &GetOneRecordingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetRecordingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings/{}",
args.account_id,
args.app_id,
args.recording_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: RealtimekitGetRecordingResponse = 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 pause_resume_stop_recording_request<F>(
client: DynNetClient,
args: &PauseResumeStopRecordingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetRecordingResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/recordings/{}",
args.account_id,
args.app_id,
args.recording_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: RealtimekitGetRecordingResponse = 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 get_sessions_request<F>(
client: DynNetClient,
args: &GetSessionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetSessionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions",
args.account_id,
args.app_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("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("sort_by", args.sort_by.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
builder = builder.query("start_time", args.start_time.as_deref());
builder = builder.query("end_time", args.end_time.as_deref());
builder = builder.query("participants", args.participants.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("search", args.search.as_deref());
builder = builder.query("associated_id", args.associated_id.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: RealtimekitGetSessionsResponse = 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 get_participant_data_from_peer_id_request<F>(
client: DynNetClient,
args: &GetParticipantDataFromPeerIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetParticipantDataFromPeerIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/peer-report/{}",
args.account_id,
args.app_id,
args.peer_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("filters", args.filters.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: RealtimekitGetParticipantDataFromPeerIdResponse = 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 get_session_details_request<F>(
client: DynNetClient,
args: &GetSessionDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetSessionDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}",
args.account_id,
args.app_id,
args.session_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("include_breakout_rooms", args.include_breakout_rooms.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: RealtimekitGetSessionDetailsResponse = 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 get_v2_livestreamsession_session_meeting_id_active_livestream_request<F>(
client: DynNetClient,
args: &GetV2LivestreamsessionSessionMeetingIdActiveLivestreamArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/livestream-sessions",
args.account_id,
args.app_id,
args.session_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("per_page", args.per_page.as_deref());
builder = builder.query("page_no", args.page_no.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: GetV2LivestreamsessionSessionMeetingIdActiveLivestreamResponse = 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 get_session_participants_request<F>(
client: DynNetClient,
args: &GetSessionParticipantsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetSessionParticipantsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/participants",
args.account_id,
args.app_id,
args.session_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("search", args.search.as_deref());
builder = builder.query("page_no", args.page_no.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
builder = builder.query("sort_by", args.sort_by.as_deref());
builder = builder.query("include_peer_events", args.include_peer_events.as_deref());
builder = builder.query("view", args.view.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: RealtimekitGetSessionParticipantsResponse = 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 get_participant_details_request<F>(
client: DynNetClient,
args: &GetParticipantDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetParticipantDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/participants/{}",
args.account_id,
args.app_id,
args.session_id,
args.participant_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("filters", args.filters.as_deref());
builder = builder.query("include_peer_events", args.include_peer_events.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: RealtimekitGetParticipantDetailsResponse = 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 get_session_summary_request<F>(
client: DynNetClient,
args: &GetSessionSummaryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetSessionTranscriptSummaryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/summary",
args.account_id,
args.app_id,
args.session_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: RealtimekitGetSessionTranscriptSummaryResponse = 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 post_sessions_session_id_summary_request<F>(
client: DynNetClient,
args: &PostSessionsSessionIdSummaryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PostSessionsSessionIdSummaryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/summary",
args.account_id,
args.app_id,
args.session_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: PostSessionsSessionIdSummaryResponse = 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 get_session_transcript_request<F>(
client: DynNetClient,
args: &GetSessionTranscriptArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitGetSessionTranscriptResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/sessions/{}/transcript",
args.account_id,
args.app_id,
args.session_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: RealtimekitGetSessionTranscriptResponse = 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 get_all_webhooks_request<F>(
client: DynNetClient,
args: &GetAllWebhooksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhooksListSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks",
args.account_id,
args.app_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: RealtimekitWebhooksListSuccessResponse = 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 add_webhook_request<F>(
client: DynNetClient,
args: &AddWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhookSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks",
args.account_id,
args.app_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: RealtimekitWebhookSuccessResponse = 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 get_webhook_request<F>(
client: DynNetClient,
args: &GetWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhookSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks/{}",
args.account_id,
args.app_id,
args.webhook_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: RealtimekitWebhookSuccessResponse = 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 replace_webhook_request<F>(
client: DynNetClient,
args: &ReplaceWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhookSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks/{}",
args.account_id,
args.app_id,
args.webhook_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: RealtimekitWebhookSuccessResponse = 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 edit_webhook_request<F>(
client: DynNetClient,
args: &EditWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhookSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks/{}",
args.account_id,
args.app_id,
args.webhook_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: RealtimekitWebhookSuccessResponse = 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 delete_webhook_request<F>(
client: DynNetClient,
args: &DeleteWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RealtimekitWebhookSuccessResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/realtime/kit/{}/webhooks/{}",
args.account_id,
args.app_id,
args.webhook_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: RealtimekitWebhookSuccessResponse = 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 stream_videos_list_videos_request<F>(
client: DynNetClient,
args: &StreamVideosListVideosArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<StreamVideoResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/stream",
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("status", args.status.as_deref());
builder = builder.query("creator", args.creator.as_deref());
builder = builder.query("type", args.r#type.as_deref());
builder = builder.query("asc", args.asc.as_deref());
builder = builder.query("video_name", args.video_name.as_deref());
builder = builder.query("search", args.search.as_deref());
builder = builder.query("start", args.start.as_deref());
builder = builder.query("end", args.end.as_deref());
builder = builder.query("include_counts", args.include_counts.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: StreamVideoResponseCollection = 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 stream_videos_initiate_video_uploads_using_tus_request<F>(
client: DynNetClient,
args: &StreamVideosInitiateVideoUploadsUsingTusArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/stream",
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.query("direct_user", args.direct_user.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 });
}
Ok(ApiResponse { status: status as u16, headers, body: () })
}
pub async fn radar_get_bgp_routes_realtime_request<F>(
client: DynNetClient,
args: &RadarGetBgpRoutesRealtimeArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRoutesRealtimeResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/routes/realtime",
);
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("prefix", args.prefix.as_deref());
builder = builder.query("format", args.format.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: RadarGetBgpRoutesRealtimeResponse = 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 })
}