#![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_macros::JsonHash;
use foundation_netio::shared::client::http_client::HttpClient;
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use serde::{Deserialize, Serialize};
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,
}
pub type BrapiDeleteCancelCrawlResponseErrorsItem = super::shared::CodeMessageObject;
#[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,
}
pub type BrapiGetCrawlResultResponseErrorsItem = super::shared::CodeMessageObject;
#[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,
}
pub type BrapiPostContentRequest = super::shared::EmptyObject;
#[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,
}
pub type BrapiPostContentResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostContentResponseMeta = super::shared::StatusTitleObject;
pub type BrapiPostCrawlRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostCrawlResponse {
pub errors: Option<Vec<BrapiPostCrawlResponseErrorsItem>>,
pub result: String,
pub success: bool,
}
pub type BrapiPostCrawlResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostJsonRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostJsonResponse {
pub errors: Option<Vec<BrapiPostJsonResponseErrorsItem>>,
pub result: serde_json::Value,
pub success: bool,
}
pub type BrapiPostJsonResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostLinksRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostLinksResponse {
pub errors: Option<Vec<BrapiPostLinksResponseErrorsItem>>,
pub result: Vec<String>,
pub success: bool,
}
pub type BrapiPostLinksResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostMarkdownRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostMarkdownResponse {
pub errors: Option<Vec<BrapiPostMarkdownResponseErrorsItem>>,
pub result: Option<String>,
pub success: bool,
}
pub type BrapiPostMarkdownResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostPdfRequest = super::shared::EmptyObject;
pub type BrapiPostScrapeRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScrapeResponse {
pub errors: Option<Vec<BrapiPostScrapeResponseErrorsItem>>,
pub result: Vec<BrapiPostScrapeResponseResultItem>,
pub success: bool,
}
pub type BrapiPostScrapeResponseErrorsItem = super::shared::CodeMessageObject;
#[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,
}
pub type BrapiPostScrapeResponseResultItemResultsAttributesItem = super::shared::NameValueObject;
pub type BrapiPostScreenshotRequest = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostScreenshotResponse {
pub errors: Option<Vec<BrapiPostScreenshotResponseErrorsItem>>,
pub success: bool,
}
pub type BrapiPostScreenshotResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostSnapshotRequest = super::shared::EmptyObject;
#[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,
}
pub type BrapiPostSnapshotResponseErrorsItem = super::shared::CodeMessageObject;
pub type BrapiPostSnapshotResponseMeta = super::shared::StatusTitleObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BrapiPostSnapshotResponseResult {
pub content: String,
pub screenshot: String,
}
pub type CallsApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type CallsApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type CallsApp = super::shared::CallsAppShape;
pub type CallsAppEditableFields = super::shared::NameObject2;
pub type CallsAppResponseCollection = super::shared::ApiEnvelope<Option<Vec<CallsApp>>>;
pub type CallsAppResponseSingle = super::shared::ApiEnvelope<Option<CallsApp>>;
pub type CallsAppResponseSingleWithSecret = super::shared::ApiEnvelope<Option<CallsAppWithSecret>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsAppWithSecret {
pub created: Option<String>,
pub modified: Option<String>,
pub name: Option<String>,
pub secret: Option<String>,
pub uid: Option<String>,
}
pub type CallsCreated = String;
pub type CallsIdentifier = String;
pub type CallsMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type CallsModified = String;
pub type CallsName = String;
pub type CallsSecret = String;
pub type CallsTurnKey = String;
pub type CallsTurnKeyCollection = super::shared::ApiEnvelope<Option<Vec<CallsTurnKeyObject>>>;
pub type CallsTurnKeyEditableFields = super::shared::NameObject2;
pub type CallsTurnKeyName = String;
pub type CallsTurnKeyObject = super::shared::CallsAppShape;
pub type CallsTurnKeyResponseSingle = super::shared::ApiEnvelope<Option<CallsTurnKeyObject>>;
pub type CallsTurnKeySingleWithSecret = super::shared::ApiEnvelope<Option<CallsTurnKeyWithKey>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CallsTurnKeyWithKey {
pub created: Option<String>,
pub key: Option<String>,
pub modified: Option<String>,
pub name: Option<String>,
pub uid: Option<String>,
}
#[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>,
}
pub type CreateAppResponseDataApp = super::shared::CreatedAtIdNameObject;
#[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>,
}
pub type FetchAllLivestreamsResponseDataPaging =
super::shared::EndOffsetStartOffsetTotalCountObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetAppsResponse {
pub data: Option<Vec<GetAppsResponseDataItem>>,
pub success: Option<bool>,
}
pub type GetAppsResponseDataItem = super::shared::CreatedAtIdNameObject;
#[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>,
}
pub type GetV2ActiveLivestreamSessionDetailsResponseDataLivestream =
super::shared::GetV2ActiveLivestreamSessionDetailsResponseDataLivestreamShape;
#[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>,
}
pub type GetV2LivestreamSessionLivestreamIdResponseDataLivestream =
super::shared::GetV2ActiveLivestreamSessionDetailsResponseDataLivestreamShape;
pub type GetV2LivestreamSessionLivestreamIdResponseDataPaging =
super::shared::EndOffsetStartOffsetTotalCountObject;
#[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>,
}
pub type GetV2MeetingsMeetingIdActiveLivestreamResponseData =
super::shared::GetV2ActiveLivestreamSessionDetailsResponseDataLivestreamShape;
pub type ImagesApiResponseCollectionV2 =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type ImagesApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type ImagesApiResponseSingle = super::shared::ApiEnvelope<serde_json::Value>;
pub type ImagesDeletedResponse = super::shared::ApiEnvelope<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImage {
pub creator: Option<String>,
pub filename: Option<String>,
pub id: Option<String>,
pub meta: Option<serde_json::Value>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<bool>,
pub uploaded: Option<String>,
pub variants: Option<Vec<serde_json::Value>>,
}
pub type ImagesImageCreator = String;
pub type ImagesImageDirectUploadResponseV2 = super::shared::ApiEnvelope<serde_json::Value>;
pub type ImagesImageFilename = String;
pub type ImagesImageHeroUrl = String;
pub type ImagesImageIdentifier = String;
pub type ImagesImageKeyName = String;
pub type ImagesImageKeyResponseCollection = super::shared::ApiEnvelope<ImagesImageKeysResponse>;
pub type ImagesImageKeyValue = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeys {
pub name: Option<String>,
pub value: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageKeysResponse {
pub keys: Option<Vec<ImagesImageKeys>>,
}
pub type ImagesImageMetadata = serde_json::Value;
pub type ImagesImageOriginalUrl = String;
#[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>,
}
pub type ImagesImageRequireSignedURLs = bool;
pub type ImagesImageResponseSingle = super::shared::ApiEnvelope<ImagesImage>;
pub type ImagesImageThumbnailUrl = String;
pub type ImagesImageUploaded = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantDefinition {
pub id: String,
#[serde(rename = "neverRequireSignedURLs")]
pub never_require_signed_ur_ls: Option<bool>,
pub options: ImagesImageVariantOptions,
}
pub type ImagesImageVariantFit = String;
pub type ImagesImageVariantFlatResponse = super::shared::ApiEnvelope<ImagesImageVariantDefinition>;
pub type ImagesImageVariantHeight = f64;
pub type ImagesImageVariantIdentifier = String;
pub type ImagesImageVariantListResponse = super::shared::ApiEnvelope<ImagesImageVariantsResponse>;
pub type ImagesImageVariantNeverRequireSignedURLs = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantOptions {
pub fit: String,
pub height: f64,
pub metadata: String,
pub width: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantPatchRequest {
#[serde(rename = "neverRequireSignedURLs")]
pub never_require_signed_ur_ls: Option<bool>,
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>,
}
pub type ImagesImageVariantSchemasMetadata = String;
pub type ImagesImageVariantSimpleResponse = super::shared::ApiEnvelope<ImagesImageVariantResponse>;
pub type ImagesImageVariantWidth = f64;
pub type ImagesImageVariants = Vec<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImageVariantsResponse {
pub variants: Option<ImagesImageVariantPublicRequest>,
}
pub type ImagesImagesListContinuationToken = String;
pub type ImagesImagesListResponseV2 =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStats {
pub count: Option<ImagesImagesStatsCount>,
}
pub type ImagesImagesStatsAllowed = f64;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ImagesImagesStatsCount {
pub allowed: Option<f64>,
pub current: Option<f64>,
}
pub type ImagesImagesStatsCurrent = f64;
pub type ImagesImagesStatsResponse = super::shared::ApiEnvelope<ImagesImagesStats>;
pub type ImagesMessages = Vec<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>,
}
pub type LivestreamSessionDetailsResponseDataPaging =
super::shared::EndOffsetStartOffsetTotalCountObject;
#[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>,
}
pub type PauseResumeStopRecordingRequest = super::shared::ActionObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostSessionsSessionIdSummaryResponse {
pub data: Option<PostSessionsSessionIdSummaryResponseData>,
pub success: Option<bool>,
}
pub type PostSessionsSessionIdSummaryResponseData = super::shared::MessageSuccessObject;
pub type RadarGetBgpRoutesRealtimeResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRoutesRealtimeResponseResult>;
#[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,
}
pub type RealtimekitAddParticipantResponse = super::shared::DataSuccessObject;
#[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>,
}
pub type RealtimekitDeleteParticipantResponse = super::shared::DataSuccessObject2;
pub type RealtimekitGenericSuccessResponse = super::shared::DataSuccessObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetActiveRecordingResponse {
pub data: RealtimekitRecording,
pub success: bool,
}
#[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: Vec<RealtimekitMeeting>,
pub paging: std::collections::HashMap<String, serde_json::Value>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetAllParticipantsResponse {
pub data: Vec<RealtimekitParticipant>,
pub paging: std::collections::HashMap<String, serde_json::Value>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetAllPresetsResponse {
pub data: Vec<RealtimekitPresetListItem>,
pub paging: std::collections::HashMap<String, serde_json::Value>,
pub success: bool,
}
pub type RealtimekitGetMeetingResponse = super::shared::DataSuccessObject2;
#[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>,
}
pub type RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerReportMetadataIpInformationAsn =
super::shared::AsnObject;
#[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>,
}
pub type RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsEventsItemMetadataConnectionInfoIpDetailsAsn =
super::shared::AsnObject;
#[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>,
}
pub type RealtimekitGetParticipantDataFromPeerIdResponseDataParticipantPeerStatsIpInformationAsn =
super::shared::AsnObject;
#[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,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RealtimekitGetPresetBodyResponse {
pub data: serde_json::Value,
pub success: bool,
}
pub type RealtimekitGetRecordingResponse = super::shared::DataSuccessObject;
pub type RealtimekitGetRecordingsResponse = super::shared::DataPagingSuccessObject;
#[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>,
}
pub type RealtimekitMuteParticipantsResponseData = RealtimekitKickParticipantsResponseData;
pub type RealtimekitPagingResponse = super::shared::DataPagingSuccessObject;
#[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>,
}
pub type RealtimekitRealtimekitBucketConfig = super::shared::EnabledObject;
#[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>,
pub success: bool,
}
#[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>,
}
pub type StartLivestreamingRequestVideoConfig = super::shared::HeightWidthObject;
#[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>,
}
pub type StreamAllowedOrigins = Vec<String>;
pub type StreamApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type StreamCreated = String;
pub type StreamCreator = String;
pub type StreamDownloadedFrom = String;
pub type StreamDuration = f64;
pub type StreamErrorReasonCode = String;
pub type StreamErrorReasonText = String;
pub type StreamHeight = i64;
pub type StreamIdentifier = String;
pub type StreamInput = super::shared::HeightWidthObject;
pub type StreamInputRtmps = super::shared::StreamKeyUrlObject;
pub type StreamInputRtmpsStreamKey = String;
pub type StreamInputRtmpsUrl = String;
pub type StreamInputSrt = super::shared::PassphraseStreamIdUrlObject;
pub type StreamInputSrtStreamId = String;
pub type StreamInputSrtStreamPassphrase = String;
pub type StreamInputSrtUrl = String;
pub type StreamInputWebrtc = super::shared::UrlObject;
pub type StreamInputWebrtcUrl = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInput {
pub created: Option<String>,
#[serde(rename = "deleteRecordingAfterDays")]
pub delete_recording_after_days: Option<f64>,
pub enabled: Option<bool>,
pub meta: Option<serde_json::Value>,
pub modified: Option<String>,
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<String>,
pub uid: Option<String>,
#[serde(rename = "webRTC")]
pub web_rtc: Option<StreamInputWebrtc>,
#[serde(rename = "webRTCPlayback")]
pub web_rtc_playback: Option<StreamPlaybackWebrtc>,
}
pub type StreamLiveInputCreated = String;
pub type StreamLiveInputEnabled = bool;
pub type StreamLiveInputIdentifier = String;
pub type StreamLiveInputMetadata = serde_json::Value;
pub type StreamLiveInputModified = String;
pub type StreamLiveInputRecordingAllowedOrigins = Vec<String>;
pub type StreamLiveInputRecordingDeletion = f64;
pub type StreamLiveInputRecordingHideLiveViewerCount = bool;
pub type StreamLiveInputRecordingMode = String;
pub type StreamLiveInputRecordingRequireSignedURLs = bool;
pub type StreamLiveInputRecordingSettings = super::shared::StreamLiveInputRecordingSettingsShape;
pub type StreamLiveInputRecordingTimeoutSeconds = i64;
pub type StreamLiveInputStatus = String;
pub type StreamMaxDurationSeconds = i64;
pub type StreamMediaMetadata = serde_json::Value;
pub type StreamMediaState = String;
pub type StreamMediaStatus = super::shared::StreamMediaStatusShape;
pub type StreamMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type StreamModified = String;
pub type StreamName = String;
pub type StreamOneTimeUploadExpiry = String;
pub type StreamOpacity = f64;
pub type StreamPadding = f64;
pub type StreamPctComplete = String;
pub type StreamPlayback = super::shared::DashHlsObject;
pub type StreamPlaybackRtmps = super::shared::StreamKeyUrlObject;
pub type StreamPlaybackRtmpsStreamKey = String;
pub type StreamPlaybackRtmpsUrl = String;
pub type StreamPlaybackSrt = super::shared::PassphraseStreamIdUrlObject;
pub type StreamPlaybackSrtStreamId = String;
pub type StreamPlaybackSrtStreamPassphrase = String;
pub type StreamPlaybackSrtUrl = String;
pub type StreamPlaybackWebrtc = super::shared::UrlObject;
pub type StreamPlaybackWebrtcUrl = String;
pub type StreamPosition = String;
pub type StreamPreview = String;
pub type StreamReadyToStream = bool;
pub type StreamReadyToStreamAt = String;
pub type StreamRequireSignedURLs = bool;
pub type StreamScale = f64;
pub type StreamScheduledDeletion = String;
pub type StreamSize = f64;
pub type StreamThumbnailTimestampPct = f64;
pub type StreamThumbnailUrl = String;
pub type StreamUploaded = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideoResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub range: Option<i64>,
pub result: Option<Vec<StreamVideos>>,
pub success: bool,
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<String>,
pub creator: Option<String>,
pub duration: Option<f64>,
pub input: Option<StreamInput>,
#[serde(rename = "liveInput")]
pub live_input: Option<String>,
#[serde(rename = "maxDurationSeconds")]
pub max_duration_seconds: Option<i64>,
pub meta: Option<serde_json::Value>,
pub modified: Option<String>,
pub playback: Option<StreamPlayback>,
pub preview: Option<String>,
#[serde(rename = "readyToStream")]
pub ready_to_stream: Option<bool>,
#[serde(rename = "readyToStreamAt")]
pub ready_to_stream_at: Option<String>,
#[serde(rename = "requireSignedURLs")]
pub require_signed_ur_ls: Option<bool>,
#[serde(rename = "scheduledDeletion")]
pub scheduled_deletion: Option<String>,
pub size: Option<f64>,
pub status: Option<StreamMediaStatus>,
pub thumbnail: Option<String>,
#[serde(rename = "thumbnailTimestampPct")]
pub thumbnail_timestamp_pct: Option<f64>,
pub uid: Option<String>,
#[serde(rename = "uploadExpiry")]
pub upload_expiry: Option<String>,
pub uploaded: Option<String>,
pub watermark: Option<StreamWatermarks>,
}
pub type StreamWatermarkCreated = String;
pub type StreamWatermarkIdentifier = String;
pub type StreamWatermarkSize = f64;
pub type StreamWatermarks = super::shared::StreamWatermarksShape;
pub type StreamWidth = i64;
#[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>,
}
pub type BrapiDeleteCancelCrawlArgs = super::shared::AccountIdJobIdArgs;
#[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,
}
pub type CallsAppsListArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsCreateANewAppArgs {
pub account_id: String,
pub body: CallsAppEditableFields,
}
pub type CallsAppsRetrieveAppDetailsArgs = super::shared::AppIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsAppsUpdateAppDetailsArgs {
pub app_id: String,
pub account_id: String,
pub body: CallsAppEditableFields,
}
pub type CallsAppsDeleteAppArgs = super::shared::AppIdAccountIdArgs;
pub type CallsTurnKeyListArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsTurnKeyCreateArgs {
pub account_id: String,
pub body: CallsTurnKeyEditableFields,
}
pub type CallsRetrieveTurnKeyDetailsArgs = super::shared::KeyIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CallsUpdateTurnKeyArgs {
pub key_id: String,
pub account_id: String,
pub body: CallsTurnKeyEditableFields,
}
pub type CallsDeleteTurnKeyArgs = super::shared::KeyIdAccountIdArgs;
pub type CloudflareImagesUploadAnImageViaUrlArgs = super::shared::AccountIdArgs;
pub type CloudflareImagesKeysListSigningKeysArgs = super::shared::AccountIdArgs;
pub type CloudflareImagesKeysAddSigningKeyArgs = super::shared::SigningKeyNameAccountIdArgs;
pub type CloudflareImagesKeysDeleteSigningKeyArgs = super::shared::SigningKeyNameAccountIdArgs;
pub type CloudflareImagesImagesUsageStatisticsArgs = super::shared::AccountIdArgs;
pub type CloudflareImagesVariantsListVariantsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsCreateAVariantArgs {
pub account_id: String,
pub body: ImagesImageVariantDefinition,
}
pub type CloudflareImagesVariantsVariantDetailsArgs = super::shared::VariantIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesVariantsUpdateAVariantArgs {
pub variant_id: String,
pub account_id: String,
pub body: ImagesImageVariantPatchRequest,
}
pub type CloudflareImagesVariantsDeleteAVariantArgs = super::shared::VariantIdAccountIdArgs;
pub type CloudflareImagesVariantsVariantDetailsFlatArgs = super::shared::VariantIdAccountIdArgs;
pub type CloudflareImagesImageDetailsArgs = super::shared::ImageIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareImagesUpdateImageArgs {
pub image_id: String,
pub account_id: String,
pub body: ImagesImagePatchRequest,
}
pub type CloudflareImagesDeleteImageArgs = super::shared::ImageIdAccountIdArgs;
pub type CloudflareImagesBaseImageArgs = super::shared::ImageIdAccountIdArgs;
#[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>,
}
pub type CloudflareImagesCreateAuthenticatedDirectUploadUrlV2Args = super::shared::AccountIdArgs;
pub type GetAppsArgs = super::shared::AccountIdArgs;
pub type CreateAppArgs = super::shared::AccountIdArgs;
#[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>,
}
pub type CreateMeetingArgs = super::shared::AccountIdAppIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetMeetingArgs {
pub meeting_id: String,
pub name: Option<String>,
}
pub type ReplaceMeetingArgs = super::shared::MeetingIdArgs;
pub type UpdateMeetingArgs = super::shared::MeetingIdArgs;
pub type GetV2MeetingsMeetingIdActiveLivestreamArgs = super::shared::MeetingIdArgs;
pub type StopLivestreamingArgs = super::shared::MeetingIdArgs;
pub type GetActiveSessionArgs = super::shared::MeetingIdArgs;
pub type KickPartcipantsArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type KickAllParticipantsArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type MuteParticipantsArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type MuteAllParticipantsArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type CreatePollArgs = super::shared::AccountIdAppIdMeetingIdArgs;
#[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>,
}
pub type AddParticipantArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type GetMeetingParticipantArgs = super::shared::MeetingIdParticipantIdArgs;
pub type EditParticipantArgs = super::shared::MeetingIdParticipantIdArgs;
pub type DeleteMeetingParticipantArgs = super::shared::MeetingIdParticipantIdArgs;
#[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>,
}
pub type PostPresetsArgs = super::shared::AccountIdAppIdArgs;
pub type GetPresetsPresetIdArgs = super::shared::AccountIdAppIdPresetIdArgs;
pub type PatchPresetsPresetIdArgs = super::shared::AccountIdAppIdPresetIdArgs;
pub type DeletePresetsPresetIdArgs = super::shared::AccountIdAppIdPresetIdArgs;
#[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: Vec<String>,
}
pub type StartRecordingArgs = super::shared::AccountIdAppIdArgs;
pub type GetActiveRecordingArgs = super::shared::AccountIdAppIdMeetingIdArgs;
pub type StartTrackRecordingForAMeetingArgs = super::shared::AccountIdAppIdArgs;
#[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>,
}
pub type GetSessionSummaryArgs = super::shared::AccountIdAppIdSessionIdArgs;
pub type PostSessionsSessionIdSummaryArgs = super::shared::AccountIdAppIdSessionIdArgs;
pub type GetSessionTranscriptArgs = super::shared::AccountIdAppIdSessionIdArgs;
pub type GetAllWebhooksArgs = super::shared::AccountIdAppIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AddWebhookArgs {
pub account_id: String,
pub app_id: String,
pub body: RealtimekitWebhookRequest,
}
pub type GetWebhookArgs = super::shared::AccountIdAppIdWebhookIdArgs;
#[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,
}
pub type DeleteWebhookArgs = super::shared::AccountIdAppIdWebhookIdArgs;
#[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: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_crawl_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_get_crawl_result_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_delete_cancel_crawl_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_json_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_links_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_markdown_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_pdf_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &BrapiPostPdfArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, 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);
}
super::shared::send_bytes(client.into(), builder.build()).await
}
pub async fn brapi_post_scrape_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_screenshot_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn brapi_post_snapshot_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_apps_list_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_apps_create_a_new_app_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_apps_retrieve_app_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_apps_update_app_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_apps_delete_app_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_turn_key_list_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_turn_key_create_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_retrieve_turn_key_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_update_turn_key_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn calls_delete_turn_key_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_upload_an_image_via_url_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_keys_list_signing_keys_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_keys_add_signing_key_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_keys_delete_signing_key_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_images_usage_statistics_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_list_variants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_create_a_variant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_variant_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_update_a_variant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_delete_a_variant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_variants_variant_details_flat_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_image_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_update_image_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_delete_image_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_base_image_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareImagesBaseImageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, 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);
}
super::shared::send_bytes(client.into(), builder.build()).await
}
pub async fn cloudflare_images_list_images_v2_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_images_create_authenticated_direct_upload_url_v_2_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_apps_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_app_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_org_analytics_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_livestream_analytics_complete_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn fetch_all_livestreams_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_v2_livestreams_livestream_session_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_v2_livestream_session_livestream_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_v2_active_livestream_session_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_all_meetings_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_meeting_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_meeting_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn replace_meeting_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn update_meeting_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_v2_meetings_meeting_id_active_livestream_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn stop_livestreaming_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_active_session_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn kick_partcipants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn kick_all_participants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn mute_participants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn mute_all_participants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_poll_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn livestream_session_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn start_livestreaming_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_meeting_participants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn add_participant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_meeting_participant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn edit_participant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn delete_meeting_participant_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn regenerate_token_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_presets_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn post_presets_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_presets_preset_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn patch_presets_preset_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn delete_presets_preset_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_all_recordings_request<F>(
client: impl Into<super::shared::ApiClient>,
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());
for value in &args.status {
builder = builder.query("status", Some(value.as_str()));
}
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn start_recording_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_active_recording_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn start_track_recording_for_a_meeting_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn get_one_recording_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn pause_resume_stop_recording_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_sessions_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_participant_data_from_peer_id_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_session_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_v2_livestreamsession_session_meeting_id_active_livestream_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_session_participants_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_participant_details_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_session_summary_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn post_sessions_session_id_summary_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_session_transcript_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_all_webhooks_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn add_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn replace_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn edit_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn delete_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn stream_videos_list_videos_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn stream_videos_initiate_video_uploads_using_tus_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_routes_realtime_request<F>(
client: impl Into<super::shared::ApiClient>,
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);
}
super::shared::send_json(client.into(), builder.build()).await
}