foundation_deployment_cloudflare 0.1.3

//! Auto-generated API module for cloudflare stream.
//!
//! Generated by `cargo run --bin ewe_platform gen_api`.
//! DO NOT EDIT MANUALLY.
//!
//! Feature flag: `cloudflare_stream `

#![cfg(feature = "cloudflare_stream")]
#![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;

// =============================================================================
// TYPE DECLARATIONS
// =============================================================================

/// `StreamAccessRules` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamAccessRules {
    /// `action` property.
    pub action: Option<String>,
    /// `country` property.
    pub country: Option<Vec<String>>,
    /// `ip` property.
    pub ip: Option<Vec<String>>,
    /// `type` property.
    #[serde(rename = "type")]
    pub r#type: Option<String>,
}

/// `StreamAddAudioTrackResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamAdditionalAudio>>`.
pub type StreamAddAudioTrackResponse = super::shared::ApiEnvelope<Option<StreamAdditionalAudio>>;

/// `StreamAdditionalAudio` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamAdditionalAudio {
    /// `default` property.
    pub default: Option<bool>,
    /// `label` property.
    pub label: Option<String>,
    /// `status` property.
    pub status: Option<String>,
    /// `uid` property.
    pub uid: Option<String>,
}

/// `StreamAllowedOrigins` type.
pub type StreamAllowedOrigins = Vec<String>;

/// `StreamApiResponseCommon` type.
///
/// Same shape as `super::shared::ErrorsMessagesSuccessObject`.
pub type StreamApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;

/// `StreamApiResponseSingle` type.
///
/// Same shape as `super::shared::ErrorsMessagesSuccessObject`.
pub type StreamApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;

/// `StreamAudioDefault` type.
pub type StreamAudioDefault = bool;

/// `StreamAudioLabel` type.
pub type StreamAudioLabel = String;

/// `StreamAudioState` type.
pub type StreamAudioState = String;

/// `StreamCaptionStatus` type.
pub type StreamCaptionStatus = String;

/// `StreamCaptions` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamCaptions {
    /// `generated` property.
    pub generated: Option<bool>,
    /// `label` property.
    pub label: Option<String>,
    /// `language` property.
    pub language: Option<String>,
    /// `status` property.
    pub status: Option<String>,
}

/// `StreamClipResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamClipping>>`.
pub type StreamClipResponseSingle = super::shared::ApiEnvelope<Option<StreamClipping>>;

/// `StreamClippedFromVideoUid` type.
pub type StreamClippedFromVideoUid = String;

/// `StreamClipping` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamClipping {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `clippedFromVideoUID` property.
    #[serde(rename = "clippedFromVideoUID")]
    pub clipped_from_video_uid: Option<String>,
    /// `created` property.
    pub created: Option<String>,
    /// `creator` property.
    pub creator: Option<String>,
    /// `endTimeSeconds` property.
    #[serde(rename = "endTimeSeconds")]
    pub end_time_seconds: Option<i64>,
    /// `maxDurationSeconds` property.
    #[serde(rename = "maxDurationSeconds")]
    pub max_duration_seconds: Option<i64>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `modified` property.
    pub modified: Option<String>,
    /// `playback` property.
    pub playback: Option<StreamPlayback>,
    /// `preview` property.
    pub preview: Option<String>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `startTimeSeconds` property.
    #[serde(rename = "startTimeSeconds")]
    pub start_time_seconds: Option<i64>,
    /// `status` property.
    pub status: Option<String>,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `watermark` property.
    pub watermark: Option<StreamWatermarkAtUpload>,
}

/// `StreamClippingCreated` type.
pub type StreamClippingCreated = String;

/// `StreamCopyAudioTrack` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamCopyAudioTrack {
    /// `label` property.
    pub label: String,
    /// `url` property.
    pub url: Option<String>,
}

/// `StreamCreateInputRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamCreateInputRequest {
    /// `defaultCreator` property.
    #[serde(rename = "defaultCreator")]
    pub default_creator: Option<String>,
    /// `deleteRecordingAfterDays` property.
    #[serde(rename = "deleteRecordingAfterDays")]
    pub delete_recording_after_days: Option<f64>,
    /// `enabled` property.
    pub enabled: Option<bool>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `recording` property.
    pub recording: Option<StreamLiveInputRecordingSettings>,
}

/// `StreamCreateOutputRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamCreateOutputRequest {
    /// `enabled` property.
    pub enabled: Option<bool>,
    /// `streamKey` property.
    #[serde(rename = "streamKey")]
    pub stream_key: String,
    /// `url` property.
    pub url: String,
}

/// `StreamCreated` type.
pub type StreamCreated = String;

/// `StreamCreator` type.
pub type StreamCreator = String;

/// `StreamDeletedResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<String>>`.
pub type StreamDeletedResponse = super::shared::ApiEnvelope<Option<String>>;

/// `StreamDirectUploadRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamDirectUploadRequest {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `creator` property.
    pub creator: Option<String>,
    /// `expiry` property.
    pub expiry: Option<String>,
    /// `maxDurationSeconds` property.
    #[serde(rename = "maxDurationSeconds")]
    pub max_duration_seconds: i64,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `scheduledDeletion` property.
    #[serde(rename = "scheduledDeletion")]
    pub scheduled_deletion: Option<String>,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `watermark` property.
    pub watermark: Option<StreamWatermarkAtUpload>,
}

/// `StreamDirectUploadResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>`.
pub type StreamDirectUploadResponse =
    super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;

/// `StreamDownloadPercentComplete` type.
pub type StreamDownloadPercentComplete = f64;

/// `StreamDownloadStatus` type.
pub type StreamDownloadStatus = String;

/// `StreamDownloadUrl` type.
pub type StreamDownloadUrl = String;

/// `StreamDownloadedFrom` type.
pub type StreamDownloadedFrom = String;

/// `StreamDownloads` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamDownloads {
    /// `percentComplete` property.
    #[serde(rename = "percentComplete")]
    pub percent_complete: Option<f64>,
    /// `status` property.
    pub status: Option<String>,
    /// `url` property.
    pub url: Option<String>,
}

/// `StreamDownloadsResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>`.
pub type StreamDownloadsResponse =
    super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;

/// `StreamDownloadsResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamDownloads>>`.
pub type StreamDownloadsResponseSingle = super::shared::ApiEnvelope<Option<StreamDownloads>>;

/// `StreamDuration` type.
pub type StreamDuration = f64;

/// `StreamEditAudioTrack` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamEditAudioTrack {
    /// `default` property.
    pub default: Option<bool>,
    /// `label` property.
    pub label: Option<String>,
}

/// `StreamEndTimeSeconds` type.
pub type StreamEndTimeSeconds = i64;

/// `StreamErrorReasonCode` type.
pub type StreamErrorReasonCode = String;

/// `StreamErrorReasonText` type.
pub type StreamErrorReasonText = String;

/// `StreamGeneratedCaption` type.
pub type StreamGeneratedCaption = bool;

/// `StreamHeight` type.
pub type StreamHeight = i64;

/// `StreamIdentifier` type.
pub type StreamIdentifier = String;

/// `StreamInput` type.
///
/// Same shape as `super::shared::HeightWidthObject`.
pub type StreamInput = super::shared::HeightWidthObject;

/// `StreamInputRtmps` type.
///
/// Same shape as `super::shared::StreamKeyUrlObject`.
pub type StreamInputRtmps = super::shared::StreamKeyUrlObject;

/// `StreamInputRtmpsStreamKey` type.
pub type StreamInputRtmpsStreamKey = String;

/// `StreamInputRtmpsUrl` type.
pub type StreamInputRtmpsUrl = String;

/// `StreamInputSrt` type.
///
/// Same shape as `super::shared::PassphraseStreamIdUrlObject`.
pub type StreamInputSrt = super::shared::PassphraseStreamIdUrlObject;

/// `StreamInputSrtStreamId` type.
pub type StreamInputSrtStreamId = String;

/// `StreamInputSrtStreamPassphrase` type.
pub type StreamInputSrtStreamPassphrase = String;

/// `StreamInputSrtUrl` type.
pub type StreamInputSrtUrl = String;

/// `StreamInputWebrtc` type.
///
/// Same shape as `super::shared::UrlObject`.
pub type StreamInputWebrtc = super::shared::UrlObject;

/// `StreamInputWebrtcUrl` type.
pub type StreamInputWebrtcUrl = String;

/// `StreamJwk` type.
pub type StreamJwk = String;

/// `StreamKeyGenerationResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamKeys>>`.
pub type StreamKeyGenerationResponse = super::shared::ApiEnvelope<Option<StreamKeys>>;

/// `StreamKeyResponseCollection` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<Vec<std::collections::HashMap<String, serde_json::Value>>>>`.
pub type StreamKeyResponseCollection =
    super::shared::ApiEnvelope<Option<Vec<std::collections::HashMap<String, serde_json::Value>>>>;

/// `StreamKeys` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamKeys {
    /// `created` property.
    pub created: Option<String>,
    /// `id` property.
    pub id: Option<String>,
    /// `jwk` property.
    pub jwk: Option<String>,
    /// `pem` property.
    pub pem: Option<String>,
}

/// `StreamLabel` type.
pub type StreamLabel = String;

/// `StreamLanguage` type.
pub type StreamLanguage = String;

/// `StreamLanguageResponseCollection` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<Vec<StreamCaptions>>>`.
pub type StreamLanguageResponseCollection = super::shared::ApiEnvelope<Option<Vec<StreamCaptions>>>;

/// `StreamLanguageResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamCaptions>>`.
pub type StreamLanguageResponseSingle = super::shared::ApiEnvelope<Option<StreamCaptions>>;

/// `StreamListAudioTrackResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<Vec<StreamAdditionalAudio>>>`.
pub type StreamListAudioTrackResponse =
    super::shared::ApiEnvelope<Option<Vec<StreamAdditionalAudio>>>;

/// `StreamLiveInput` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInput {
    /// `created` property.
    pub created: Option<String>,
    /// `deleteRecordingAfterDays` property.
    #[serde(rename = "deleteRecordingAfterDays")]
    pub delete_recording_after_days: Option<f64>,
    /// `enabled` property.
    pub enabled: Option<bool>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `modified` property.
    pub modified: Option<String>,
    /// `recording` property.
    pub recording: Option<StreamLiveInputRecordingSettings>,
    /// `rtmps` property.
    pub rtmps: Option<StreamInputRtmps>,
    /// `rtmpsPlayback` property.
    #[serde(rename = "rtmpsPlayback")]
    pub rtmps_playback: Option<StreamPlaybackRtmps>,
    /// `srt` property.
    pub srt: Option<StreamInputSrt>,
    /// `srtPlayback` property.
    #[serde(rename = "srtPlayback")]
    pub srt_playback: Option<StreamPlaybackSrt>,
    /// `status` property.
    pub status: Option<String>,
    /// `uid` property.
    pub uid: Option<String>,
    /// `webRTC` property.
    #[serde(rename = "webRTC")]
    pub web_rtc: Option<StreamInputWebrtc>,
    /// `webRTCPlayback` property.
    #[serde(rename = "webRTCPlayback")]
    pub web_rtc_playback: Option<StreamPlaybackWebrtc>,
}

/// `StreamLiveInputCreated` type.
pub type StreamLiveInputCreated = String;

/// `StreamLiveInputDefaultCreator` type.
pub type StreamLiveInputDefaultCreator = String;

/// `StreamLiveInputEnabled` type.
pub type StreamLiveInputEnabled = bool;

/// `StreamLiveInputIdentifier` type.
pub type StreamLiveInputIdentifier = String;

/// `StreamLiveInputMetadata` type.
pub type StreamLiveInputMetadata = serde_json::Value;

/// `StreamLiveInputModified` type.
pub type StreamLiveInputModified = String;

/// `StreamLiveInputObjectWithoutUrl` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamLiveInputObjectWithoutUrl {
    /// `created` property.
    pub created: Option<String>,
    /// `deleteRecordingAfterDays` property.
    #[serde(rename = "deleteRecordingAfterDays")]
    pub delete_recording_after_days: Option<f64>,
    /// `enabled` property.
    pub enabled: Option<bool>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `modified` property.
    pub modified: Option<String>,
    /// `uid` property.
    pub uid: Option<String>,
}

/// `StreamLiveInputRecordingAllowedOrigins` type.
pub type StreamLiveInputRecordingAllowedOrigins = Vec<String>;

/// `StreamLiveInputRecordingDeletion` type.
pub type StreamLiveInputRecordingDeletion = f64;

/// `StreamLiveInputRecordingHideLiveViewerCount` type.
pub type StreamLiveInputRecordingHideLiveViewerCount = bool;

/// `StreamLiveInputRecordingMode` type.
pub type StreamLiveInputRecordingMode = String;

/// `StreamLiveInputRecordingRequireSignedURLs` type.
pub type StreamLiveInputRecordingRequireSignedURLs = bool;

/// `StreamLiveInputRecordingSettings` type.
///
/// Same shape as `super::shared::StreamLiveInputRecordingSettingsShape`.
pub type StreamLiveInputRecordingSettings = super::shared::StreamLiveInputRecordingSettingsShape;

/// `StreamLiveInputRecordingTimeoutSeconds` type.
pub type StreamLiveInputRecordingTimeoutSeconds = i64;

/// `StreamLiveInputResponseCollection` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>`.
pub type StreamLiveInputResponseCollection =
    super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;

/// `StreamLiveInputResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamLiveInput>>`.
pub type StreamLiveInputResponseSingle = super::shared::ApiEnvelope<Option<StreamLiveInput>>;

/// `StreamLiveInputStatus` type.
pub type StreamLiveInputStatus = String;

/// `StreamMaxDurationSeconds` type.
pub type StreamMaxDurationSeconds = i64;

/// `StreamMediaMetadata` type.
pub type StreamMediaMetadata = serde_json::Value;

/// `StreamMediaState` type.
pub type StreamMediaState = String;

/// `StreamMediaStatus` type.
///
/// Same shape as `super::shared::StreamMediaStatusShape`.
pub type StreamMediaStatus = super::shared::StreamMediaStatusShape;

/// `StreamMessages` type.
pub type StreamMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;

/// `StreamModified` type.
pub type StreamModified = String;

/// `StreamName` type.
pub type StreamName = String;

/// `StreamNotificationUrl` type.
pub type StreamNotificationUrl = String;

/// `StreamOneTimeUploadExpiry` type.
pub type StreamOneTimeUploadExpiry = String;

/// `StreamOpacity` type.
pub type StreamOpacity = f64;

/// `StreamOutput` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamOutput {
    /// `enabled` property.
    pub enabled: Option<bool>,
    /// `streamKey` property.
    #[serde(rename = "streamKey")]
    pub stream_key: Option<String>,
    /// `uid` property.
    pub uid: Option<String>,
    /// `url` property.
    pub url: Option<String>,
}

/// `StreamOutputEnabled` type.
pub type StreamOutputEnabled = bool;

/// `StreamOutputIdentifier` type.
pub type StreamOutputIdentifier = String;

/// `StreamOutputResponseCollection` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<Vec<StreamOutput>>>`.
pub type StreamOutputResponseCollection = super::shared::ApiEnvelope<Option<Vec<StreamOutput>>>;

/// `StreamOutputResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamOutput>>`.
pub type StreamOutputResponseSingle = super::shared::ApiEnvelope<Option<StreamOutput>>;

/// `StreamOutputStreamKey` type.
pub type StreamOutputStreamKey = String;

/// `StreamOutputUrl` type.
pub type StreamOutputUrl = String;

/// `StreamPadding` type.
pub type StreamPadding = f64;

/// `StreamPctComplete` type.
pub type StreamPctComplete = String;

/// `StreamPem` type.
pub type StreamPem = String;

/// `StreamPlayback` type.
///
/// Same shape as `super::shared::DashHlsObject`.
pub type StreamPlayback = super::shared::DashHlsObject;

/// `StreamPlaybackRtmps` type.
///
/// Same shape as `super::shared::StreamKeyUrlObject`.
pub type StreamPlaybackRtmps = super::shared::StreamKeyUrlObject;

/// `StreamPlaybackRtmpsStreamKey` type.
pub type StreamPlaybackRtmpsStreamKey = String;

/// `StreamPlaybackRtmpsUrl` type.
pub type StreamPlaybackRtmpsUrl = String;

/// `StreamPlaybackSrt` type.
///
/// Same shape as `super::shared::PassphraseStreamIdUrlObject`.
pub type StreamPlaybackSrt = super::shared::PassphraseStreamIdUrlObject;

/// `StreamPlaybackSrtStreamId` type.
pub type StreamPlaybackSrtStreamId = String;

/// `StreamPlaybackSrtStreamPassphrase` type.
pub type StreamPlaybackSrtStreamPassphrase = String;

/// `StreamPlaybackSrtUrl` type.
pub type StreamPlaybackSrtUrl = String;

/// `StreamPlaybackWebrtc` type.
///
/// Same shape as `super::shared::UrlObject`.
pub type StreamPlaybackWebrtc = super::shared::UrlObject;

/// `StreamPlaybackWebrtcUrl` type.
pub type StreamPlaybackWebrtcUrl = String;

/// `StreamPosition` type.
pub type StreamPosition = String;

/// `StreamPreview` type.
pub type StreamPreview = String;

/// `StreamReadyToStream` type.
pub type StreamReadyToStream = bool;

/// `StreamReadyToStreamAt` type.
pub type StreamReadyToStreamAt = String;

/// `StreamRequireSignedURLs` type.
pub type StreamRequireSignedURLs = bool;

/// `StreamScale` type.
pub type StreamScale = f64;

/// `StreamScheduledDeletion` type.
pub type StreamScheduledDeletion = String;

/// `StreamSchemasIdentifier` type.
pub type StreamSchemasIdentifier = String;

/// `StreamSignedTokenRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamSignedTokenRequest {
    /// `accessRules` property.
    #[serde(rename = "accessRules")]
    pub access_rules: Option<Vec<StreamAccessRules>>,
    /// `downloadable` property.
    pub downloadable: Option<bool>,
    /// `exp` property.
    pub exp: Option<i64>,
    /// `id` property.
    pub id: Option<String>,
    /// `nbf` property.
    pub nbf: Option<i64>,
    /// `pem` property.
    pub pem: Option<String>,
}

/// `StreamSignedTokenResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>`.
pub type StreamSignedTokenResponse =
    super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;

/// `StreamSigningKeyCreated` type.
pub type StreamSigningKeyCreated = String;

/// `StreamSize` type.
pub type StreamSize = f64;

/// `StreamStartTimeSeconds` type.
pub type StreamStartTimeSeconds = i64;

/// `StreamStorageUseResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>`.
pub type StreamStorageUseResponse =
    super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;

/// `StreamSubtitlesCaptionsDeleteCaptionsOrSubtitlesResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<String>>`.
pub type StreamSubtitlesCaptionsDeleteCaptionsOrSubtitlesResponse =
    super::shared::ApiEnvelope<Option<String>>;

/// `StreamThumbnailTimestampPct` type.
pub type StreamThumbnailTimestampPct = f64;

/// `StreamThumbnailUrl` type.
pub type StreamThumbnailUrl = String;

/// `StreamUpdateInputRequest` type.
///
/// Same shape as `StreamCreateInputRequest`.
pub type StreamUpdateInputRequest = StreamCreateInputRequest;

/// `StreamUpdateOutputRequest` type.
///
/// Same shape as `super::shared::EnabledObject`.
pub type StreamUpdateOutputRequest = super::shared::EnabledObject;

/// `StreamUploaded` type.
pub type StreamUploaded = String;

/// `StreamVideoClipStandard` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideoClipStandard {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `clippedFromVideoUID` property.
    #[serde(rename = "clippedFromVideoUID")]
    pub clipped_from_video_uid: String,
    /// `creator` property.
    pub creator: Option<String>,
    /// `endTimeSeconds` property.
    #[serde(rename = "endTimeSeconds")]
    pub end_time_seconds: i64,
    /// `maxDurationSeconds` property.
    #[serde(rename = "maxDurationSeconds")]
    pub max_duration_seconds: Option<i64>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `startTimeSeconds` property.
    #[serde(rename = "startTimeSeconds")]
    pub start_time_seconds: i64,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `watermark` property.
    pub watermark: Option<StreamWatermarkAtUpload>,
}

/// `StreamVideoCopyRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideoCopyRequest {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `creator` property.
    pub creator: Option<String>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `scheduledDeletion` property.
    #[serde(rename = "scheduledDeletion")]
    pub scheduled_deletion: Option<String>,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `url` property.
    pub url: String,
    /// `watermark` property.
    pub watermark: Option<StreamWatermarkAtUpload>,
}

/// `StreamVideoResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamVideos>>`.
pub type StreamVideoResponseSingle = super::shared::ApiEnvelope<Option<StreamVideos>>;

/// `StreamVideoUpdate` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideoUpdate {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `creator` property.
    pub creator: Option<String>,
    /// `maxDurationSeconds` property.
    #[serde(rename = "maxDurationSeconds")]
    pub max_duration_seconds: Option<i64>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `scheduledDeletion` property.
    #[serde(rename = "scheduledDeletion")]
    pub scheduled_deletion: Option<String>,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `uploadExpiry` property.
    #[serde(rename = "uploadExpiry")]
    pub upload_expiry: Option<String>,
}

/// `StreamVideos` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamVideos {
    /// `allowedOrigins` property.
    #[serde(rename = "allowedOrigins")]
    pub allowed_origins: Option<Vec<String>>,
    /// `created` property.
    pub created: Option<String>,
    /// `creator` property.
    pub creator: Option<String>,
    /// `duration` property.
    pub duration: Option<f64>,
    /// `input` property.
    pub input: Option<StreamInput>,
    /// `liveInput` property.
    #[serde(rename = "liveInput")]
    pub live_input: Option<String>,
    /// `maxDurationSeconds` property.
    #[serde(rename = "maxDurationSeconds")]
    pub max_duration_seconds: Option<i64>,
    /// `meta` property.
    pub meta: Option<serde_json::Value>,
    /// `modified` property.
    pub modified: Option<String>,
    /// `playback` property.
    pub playback: Option<StreamPlayback>,
    /// `preview` property.
    pub preview: Option<String>,
    /// `readyToStream` property.
    #[serde(rename = "readyToStream")]
    pub ready_to_stream: Option<bool>,
    /// `readyToStreamAt` property.
    #[serde(rename = "readyToStreamAt")]
    pub ready_to_stream_at: Option<String>,
    /// `requireSignedURLs` property.
    #[serde(rename = "requireSignedURLs")]
    pub require_signed_ur_ls: Option<bool>,
    /// `scheduledDeletion` property.
    #[serde(rename = "scheduledDeletion")]
    pub scheduled_deletion: Option<String>,
    /// `size` property.
    pub size: Option<f64>,
    /// `status` property.
    pub status: Option<StreamMediaStatus>,
    /// `thumbnail` property.
    pub thumbnail: Option<String>,
    /// `thumbnailTimestampPct` property.
    #[serde(rename = "thumbnailTimestampPct")]
    pub thumbnail_timestamp_pct: Option<f64>,
    /// `uid` property.
    pub uid: Option<String>,
    /// `uploadExpiry` property.
    #[serde(rename = "uploadExpiry")]
    pub upload_expiry: Option<String>,
    /// `uploaded` property.
    pub uploaded: Option<String>,
    /// `watermark` property.
    pub watermark: Option<StreamWatermarks>,
}

/// `StreamWatermarkAtUpload` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWatermarkAtUpload {
    /// `uid` property.
    pub uid: Option<String>,
}

/// `StreamWatermarkCreated` type.
pub type StreamWatermarkCreated = String;

/// `StreamWatermarkIdentifier` type.
pub type StreamWatermarkIdentifier = String;

/// `StreamWatermarkProfileDeleteWatermarkProfilesResponse` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<String>>`.
pub type StreamWatermarkProfileDeleteWatermarkProfilesResponse =
    super::shared::ApiEnvelope<Option<String>>;

/// `StreamWatermarkResponseCollection` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<Vec<StreamWatermarks>>>`.
pub type StreamWatermarkResponseCollection =
    super::shared::ApiEnvelope<Option<Vec<StreamWatermarks>>>;

/// `StreamWatermarkResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<StreamWatermarks>>`.
pub type StreamWatermarkResponseSingle = super::shared::ApiEnvelope<Option<StreamWatermarks>>;

/// `StreamWatermarkSize` type.
pub type StreamWatermarkSize = f64;

/// `StreamWatermarks` type.
///
/// Same shape as `super::shared::StreamWatermarksShape`.
pub type StreamWatermarks = super::shared::StreamWatermarksShape;

/// `StreamWebhookRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct StreamWebhookRequest {
    /// `notificationUrl` property.
    #[serde(rename = "notificationUrl")]
    pub notification_url: String,
}

/// `StreamWebhookResponseSingle` type.
///
/// Same shape as `super::shared::ApiEnvelope<Option<serde_json::Value>>`.
pub type StreamWebhookResponseSingle = super::shared::ApiEnvelope<Option<serde_json::Value>>;

/// `StreamWidth` type.
pub type StreamWidth = i64;

// =============================================================================
// ARGS TYPES (per-endpoint)
// =============================================================================

/// Arguments for [`stream-video-clipping-clip-videos-given-a-start-and-end-time_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideoClippingClipVideosGivenAStartAndEndTimeArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamVideoClipStandard,
}

/// Arguments for [`stream-videos-upload-videos-from-a-url_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosUploadVideosFromAUrlArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamVideoCopyRequest,
}

/// Arguments for [`stream-videos-upload-videos-via-direct-upload-ur-ls_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosUploadVideosViaDirectUploadUrLsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamDirectUploadRequest,
}

/// Arguments for [`stream-signing-keys-list-signing-keys_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamSigningKeysListSigningKeysArgs = super::shared::AccountIdArgs;

/// Arguments for [`stream-signing-keys-create-signing-keys_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamSigningKeysCreateSigningKeysArgs = super::shared::AccountIdArgs;

/// Arguments for [`stream-signing-keys-delete-signing-keys_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamSigningKeysDeleteSigningKeysArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-list-live-inputs_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsListLiveInputsArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `include_counts`.
    pub include_counts: Option<String>,
}

/// Arguments for [`stream-live-inputs-create-a-live-input_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsCreateALiveInputArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamCreateInputRequest,
}

/// Arguments for [`stream-live-inputs-retrieve-a-live-input_request`].
///
/// Same shape as `super::shared::LiveInputIdentifierAccountIdArgs`.
pub type StreamLiveInputsRetrieveALiveInputArgs = super::shared::LiveInputIdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-update-a-live-input_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsUpdateALiveInputArgs {
    /// Path parameter: `live_input_identifier`.
    pub live_input_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamUpdateInputRequest,
}

/// Arguments for [`stream-live-inputs-delete-a-live-input_request`].
///
/// Same shape as `super::shared::LiveInputIdentifierAccountIdArgs`.
pub type StreamLiveInputsDeleteALiveInputArgs = super::shared::LiveInputIdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-disable-a-live-input_request`].
///
/// Same shape as `super::shared::LiveInputIdentifierAccountIdArgs`.
pub type StreamLiveInputsDisableALiveInputArgs = super::shared::LiveInputIdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-enable-a-live-input_request`].
///
/// Same shape as `super::shared::LiveInputIdentifierAccountIdArgs`.
pub type StreamLiveInputsEnableALiveInputArgs = super::shared::LiveInputIdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-list-all-outputs-associated-with-a-specified-live-input_request`].
///
/// Same shape as `super::shared::LiveInputIdentifierAccountIdArgs`.
pub type StreamLiveInputsListAllOutputsAssociatedWithASpecifiedLiveInputArgs =
    super::shared::LiveInputIdentifierAccountIdArgs;

/// Arguments for [`stream-live-inputs-create-a-new-output,-connected-to-a-live-input_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsCreateANewOutputConnectedToALiveInputArgs {
    /// Path parameter: `live_input_identifier`.
    pub live_input_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamCreateOutputRequest,
}

/// Arguments for [`stream-live-inputs-update-an-output_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsUpdateAnOutputArgs {
    /// Path parameter: `output_identifier`.
    pub output_identifier: String,
    /// Path parameter: `live_input_identifier`.
    pub live_input_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamUpdateOutputRequest,
}

/// Arguments for [`stream-live-inputs-delete-an-output_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamLiveInputsDeleteAnOutputArgs {
    /// Path parameter: `output_identifier`.
    pub output_identifier: String,
    /// Path parameter: `live_input_identifier`.
    pub live_input_identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`stream-videos-storage-usage_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosStorageUsageArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `creator`.
    pub creator: Option<String>,
}

/// Arguments for [`stream-watermark-profile-list-watermark-profiles_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamWatermarkProfileListWatermarkProfilesArgs = super::shared::AccountIdArgs;

/// Arguments for [`stream-watermark-profile-create-watermark-profiles-via-basic-upload_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamWatermarkProfileCreateWatermarkProfilesViaBasicUploadArgs =
    super::shared::AccountIdArgs;

/// Arguments for [`stream-watermark-profile-watermark-profile-details_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamWatermarkProfileWatermarkProfileDetailsArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-watermark-profile-delete-watermark-profiles_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamWatermarkProfileDeleteWatermarkProfilesArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-webhook-view-webhooks_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamWebhookViewWebhooksArgs = super::shared::AccountIdArgs;

/// Arguments for [`stream-webhook-create-webhooks_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamWebhookCreateWebhooksArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamWebhookRequest,
}

/// Arguments for [`stream-webhook-delete-webhooks_request`].
///
/// Same shape as `super::shared::AccountIdArgs`.
pub type StreamWebhookDeleteWebhooksArgs = super::shared::AccountIdArgs;

/// Arguments for [`stream-videos-retrieve-video-details_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamVideosRetrieveVideoDetailsArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-videos-update-video-details_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosUpdateVideoDetailsArgs {
    /// Path parameter: `identifier`.
    pub identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamVideoUpdate,
}

/// Arguments for [`stream-videos-delete-video_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamVideosDeleteVideoArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`list-audio-tracks_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListAudioTracksArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `identifier`.
    pub identifier: String,
}

/// Arguments for [`add-audio-track_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AddAudioTrackArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `identifier`.
    pub identifier: String,
    /// Request body.
    pub body: StreamCopyAudioTrack,
}

/// Arguments for [`edit-audio-tracks_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct EditAudioTracksArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `identifier`.
    pub identifier: String,
    /// Path parameter: `audio_identifier`.
    pub audio_identifier: String,
    /// Request body.
    pub body: StreamEditAudioTrack,
}

/// Arguments for [`delete-audio-tracks_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAudioTracksArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `identifier`.
    pub identifier: String,
    /// Path parameter: `audio_identifier`.
    pub audio_identifier: String,
}

/// Arguments for [`stream-subtitles/-captions-list-captions-or-subtitles_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsListCaptionsOrSubtitlesArgs =
    super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-subtitles/-captions-get-caption-or-subtitle-for-language_request`].
///
/// Same shape as `super::shared::LanguageIdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsGetCaptionOrSubtitleForLanguageArgs =
    super::shared::LanguageIdentifierAccountIdArgs;

/// Arguments for [`stream-subtitles/-captions-upload-captions-or-subtitles_request`].
///
/// Same shape as `super::shared::LanguageIdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsUploadCaptionsOrSubtitlesArgs =
    super::shared::LanguageIdentifierAccountIdArgs;

/// Arguments for [`stream-subtitles/-captions-delete-captions-or-subtitles_request`].
///
/// Same shape as `super::shared::LanguageIdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsDeleteCaptionsOrSubtitlesArgs =
    super::shared::LanguageIdentifierAccountIdArgs;

/// Arguments for [`stream-subtitles/-captions-generate-caption-or-subtitle-for-language_request`].
///
/// Same shape as `super::shared::LanguageIdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsGenerateCaptionOrSubtitleForLanguageArgs =
    super::shared::LanguageIdentifierAccountIdArgs;

/// Arguments for [`stream-subtitles/-captions-get-vtt-caption-or-subtitle_request`].
///
/// Same shape as `super::shared::LanguageIdentifierAccountIdArgs`.
pub type StreamSubtitlesCaptionsGetVttCaptionOrSubtitleArgs =
    super::shared::LanguageIdentifierAccountIdArgs;

/// Arguments for [`stream-m-p-4-downloads-list-downloads_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamMP4DownloadsListDownloadsArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-m-p-4-downloads-create-downloads_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamMP4DownloadsCreateDownloadsArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-m-p-4-downloads-delete-downloads_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamMP4DownloadsDeleteDownloadsArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-downloads-create-type-specific-downloads_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdDownloadTypeArgs`.
pub type StreamDownloadsCreateTypeSpecificDownloadsArgs =
    super::shared::IdentifierAccountIdDownloadTypeArgs;

/// Arguments for [`stream-downloads-delete-type-specific-downloads_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdDownloadTypeArgs`.
pub type StreamDownloadsDeleteTypeSpecificDownloadsArgs =
    super::shared::IdentifierAccountIdDownloadTypeArgs;

/// Arguments for [`stream-videos-retreieve-embed-code-html_request`].
///
/// Same shape as `super::shared::IdentifierAccountIdArgs`.
pub type StreamVideosRetreieveEmbedCodeHtmlArgs = super::shared::IdentifierAccountIdArgs;

/// Arguments for [`stream-videos-create-signed-url-tokens-for-videos_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct StreamVideosCreateSignedUrlTokensForVideosArgs {
    /// Path parameter: `identifier`.
    pub identifier: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: StreamSignedTokenRequest,
}

// =============================================================================
// CLIENT FUNCTIONS (per-endpoint)
// =============================================================================

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/clip
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/clip.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_video_clipping_clip_videos_given_a_start_and_end_time_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_video_clipping_clip_videos_given_a_start_and_end_time_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideoClippingClipVideosGivenAStartAndEndTimeArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamClipResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/clip", 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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/copy
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/copy.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_upload_videos_from_a_url_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_upload_videos_from_a_url_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosUploadVideosFromAUrlArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamVideoResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/copy", 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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/direct_upload
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/direct_upload.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_upload_videos_via_direct_upload_ur_ls_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_upload_videos_via_direct_upload_ur_ls_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosUploadVideosViaDirectUploadUrLsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDirectUploadResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/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()))?;

    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/keys
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/keys.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_signing_keys_list_signing_keys_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_signing_keys_list_signing_keys_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSigningKeysListSigningKeysArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamKeyResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/keys
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/keys.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_signing_keys_create_signing_keys_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_signing_keys_create_signing_keys_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSigningKeysCreateSigningKeysArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamKeyGenerationResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/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()))?;

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    super::shared::send_json(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/keys/{identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/keys/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_signing_keys_delete_signing_keys_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_signing_keys_delete_signing_keys_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSigningKeysDeleteSigningKeysArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDeletedResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/keys/{}",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/live_inputs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/live_inputs.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_list_live_inputs_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_list_live_inputs_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsListLiveInputsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/live_inputs", 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("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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/live_inputs
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/live_inputs.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_create_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_create_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsCreateALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/live_inputs", 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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/live_inputs/{live_input_identifier}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/live_inputs/{live_input_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_retrieve_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_retrieve_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsRetrieveALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/stream/live_inputs/{live_input_identifier}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/stream/live_inputs/{live_input_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_update_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_update_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsUpdateALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/live_inputs/{live_input_identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/live_inputs/{live_input_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_delete_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_delete_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsDeleteALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}",
        args.account_id, args.live_input_identifier,
    );
    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/disable
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/disable.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_disable_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_disable_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsDisableALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/disable",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/enable
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/enable.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_enable_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_enable_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsEnableALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLiveInputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/enable",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_list_all_outputs_associated_with_a_specified_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_list_all_outputs_associated_with_a_specified_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsListAllOutputsAssociatedWithASpecifiedLiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamOutputResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/outputs",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_create_a_new_output_connected_to_a_live_input_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_create_a_new_output_connected_to_a_live_input_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsCreateANewOutputConnectedToALiveInputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamOutputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/outputs",
        args.account_id, args.live_input_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs/{output_identifier}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs/{output_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_update_an_output_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_update_an_output_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsUpdateAnOutputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamOutputResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/outputs/{}",
        args.account_id, args.live_input_identifier, args.output_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs/{output_identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/live_inputs/{live_input_identifier}/outputs/{output_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_live_inputs_delete_an_output_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_live_inputs_delete_an_output_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamLiveInputsDeleteAnOutputArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/live_inputs/{}/outputs/{}",
        args.account_id, args.live_input_identifier, args.output_identifier,
    );
    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/storage-usage
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/storage-usage.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_storage_usage_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_storage_usage_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosStorageUsageArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamStorageUseResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/storage-usage", 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("creator", args.creator.as_deref());

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    super::shared::send_json(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/watermarks
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/watermarks.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_watermark_profile_list_watermark_profiles_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_watermark_profile_list_watermark_profiles_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWatermarkProfileListWatermarkProfilesArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamWatermarkResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/watermarks", 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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/watermarks
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/watermarks.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_watermark_profile_create_watermark_profiles_via_basic_upload_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_watermark_profile_create_watermark_profiles_via_basic_upload_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWatermarkProfileCreateWatermarkProfilesViaBasicUploadArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamWatermarkResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/watermarks", 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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/watermarks/{identifier}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/watermarks/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_watermark_profile_watermark_profile_details_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_watermark_profile_watermark_profile_details_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWatermarkProfileWatermarkProfileDetailsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamWatermarkResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/watermarks/{}",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/watermarks/{identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/watermarks/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_watermark_profile_delete_watermark_profiles_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_watermark_profile_delete_watermark_profiles_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWatermarkProfileDeleteWatermarkProfilesArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<
    ApiResponse<StreamWatermarkProfileDeleteWatermarkProfilesResponse>,
    super::shared::ApiError,
>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/watermarks/{}",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/webhook
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/webhook.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_webhook_view_webhooks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_webhook_view_webhooks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWebhookViewWebhooksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamWebhookResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/webhook", 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
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/stream/webhook
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/stream/webhook.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_webhook_create_webhooks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_webhook_create_webhooks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWebhookCreateWebhooksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamWebhookResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/webhook", args.account_id,);
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::put(&endpoint_url)
        .map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;

    builder = builder
        .body_json(&args.body)
        .map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    super::shared::send_json(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/webhook
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/webhook.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_webhook_delete_webhooks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_webhook_delete_webhooks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamWebhookDeleteWebhooksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDeletedResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/webhook", args.account_id,);
    let endpoint_url = format!("{}{}", base_url, path);

    let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
        .map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    super::shared::send_json(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_retrieve_video_details_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_retrieve_video_details_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosRetrieveVideoDetailsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamVideoResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/{}", args.account_id, args.identifier,);
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_update_video_details_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_update_video_details_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosUpdateVideoDetailsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamVideoResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/accounts/{}/stream/{}", args.account_id, args.identifier,);
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/{identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/{identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_delete_video_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_delete_video_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosDeleteVideoArgs,
    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, args.identifier,);
    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_without_body(client.into(), builder.build()).await
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/audio
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/audio.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = list_audio_tracks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn list_audio_tracks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &ListAudioTracksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamListAudioTrackResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/audio",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}/audio/copy
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}/audio/copy.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = add_audio_track_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn add_audio_track_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &AddAudioTrackArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamAddAudioTrackResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/audio/copy",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// PATCH /accounts/{account_id}/stream/{identifier}/audio/{audio_identifier}
// -----------------------------------------------------------------------------

/// PATCH /accounts/{account_id}/stream/{identifier}/audio/{audio_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = edit_audio_tracks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn edit_audio_tracks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &EditAudioTracksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamAddAudioTrackResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/audio/{}",
        args.account_id, args.identifier, args.audio_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/{identifier}/audio/{audio_identifier}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/{identifier}/audio/{audio_identifier}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = delete_audio_tracks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn delete_audio_tracks_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &DeleteAudioTracksArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDeletedResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/audio/{}",
        args.account_id, args.identifier, args.audio_identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/captions
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/captions.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_list_captions_or_subtitles_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_list_captions_or_subtitles_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsListCaptionsOrSubtitlesArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLanguageResponseCollection>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/captions/{language}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/captions/{language}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_get_caption_or_subtitle_for_language_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_get_caption_or_subtitle_for_language_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsGetCaptionOrSubtitleForLanguageArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLanguageResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions/{}",
        args.account_id, args.identifier, args.language,
    );
    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
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/stream/{identifier}/captions/{language}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/stream/{identifier}/captions/{language}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_upload_captions_or_subtitles_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_upload_captions_or_subtitles_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsUploadCaptionsOrSubtitlesArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLanguageResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions/{}",
        args.account_id, args.identifier, args.language,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/{identifier}/captions/{language}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/{identifier}/captions/{language}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_delete_captions_or_subtitles_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_delete_captions_or_subtitles_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsDeleteCaptionsOrSubtitlesArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<
    ApiResponse<StreamSubtitlesCaptionsDeleteCaptionsOrSubtitlesResponse>,
    super::shared::ApiError,
>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions/{}",
        args.account_id, args.identifier, args.language,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}/captions/{language}/generate
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}/captions/{language}/generate.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_generate_caption_or_subtitle_for_language_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_generate_caption_or_subtitle_for_language_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsGenerateCaptionOrSubtitleForLanguageArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamLanguageResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions/{}/generate",
        args.account_id, args.identifier, args.language,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/captions/{language}/vtt
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/captions/{language}/vtt.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Response body
///
/// Returned unread, as a stream of byte chunks: read it with `.next().await`.
/// The status is checked before the body is touched.
///
/// # Example
///
/// ```ignore
/// let response = stream_subtitles_captions_get_vtt_caption_or_subtitle_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_subtitles_captions_get_vtt_caption_or_subtitle_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamSubtitlesCaptionsGetVttCaptionOrSubtitleArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/captions/{}/vtt",
        args.account_id, args.identifier, args.language,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/downloads
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/downloads.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_m_p_4_downloads_list_downloads_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_m_p_4_downloads_list_downloads_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamMP4DownloadsListDownloadsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDownloadsResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/downloads",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}/downloads
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}/downloads.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_m_p_4_downloads_create_downloads_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_m_p_4_downloads_create_downloads_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamMP4DownloadsCreateDownloadsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDownloadsResponseSingle>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/downloads",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/{identifier}/downloads
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/{identifier}/downloads.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_m_p_4_downloads_delete_downloads_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_m_p_4_downloads_delete_downloads_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamMP4DownloadsDeleteDownloadsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDeletedResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/downloads",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}/downloads/{download_type}
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}/downloads/{download_type}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_downloads_create_type_specific_downloads_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_downloads_create_type_specific_downloads_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamDownloadsCreateTypeSpecificDownloadsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDownloadsResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/downloads/{}",
        args.account_id, args.identifier, args.download_type,
    );
    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
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/stream/{identifier}/downloads/{download_type}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/stream/{identifier}/downloads/{download_type}.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_downloads_delete_type_specific_downloads_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_downloads_delete_type_specific_downloads_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamDownloadsDeleteTypeSpecificDownloadsArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamDeletedResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/downloads/{}",
        args.account_id, args.identifier, args.download_type,
    );
    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
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/stream/{identifier}/embed
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/stream/{identifier}/embed.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_retreieve_embed_code_html_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_retreieve_embed_code_html_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosRetreieveEmbedCodeHtmlArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<serde_json::Value>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/embed",
        args.account_id, args.identifier,
    );
    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
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/stream/{identifier}/token
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/stream/{identifier}/token.
///
/// Takes a client and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request: a `DynNetClient`, or an `ApiClient` carrying the `BodyLimits` the response is read under
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = stream_videos_create_signed_url_tokens_for_videos_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn stream_videos_create_signed_url_tokens_for_videos_request<F>(
    client: impl Into<super::shared::ApiClient>,
    args: &StreamVideosCreateSignedUrlTokensForVideosArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<StreamSignedTokenResponse>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!(
        "/accounts/{}/stream/{}/token",
        args.account_id, args.identifier,
    );
    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
}