#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::deps::smol_str::SmolStr;
use jacquard_common::types::string::Did;
use jacquard_common::types::value::Data;
use jacquard_common::{BosStr, CowStr, DefaultStr, FromStaticStr};
use jacquard_derive::{IntoStatic, open_union};
use serde::{Deserialize, Serialize};
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic, Default)]
#[serde(
rename_all = "camelCase",
bound(deserialize = "S: Deserialize<'de> + BosStr")
)]
pub struct UpdateBlob<S: BosStr = DefaultStr> {
#[serde(skip_serializing_if = "Option::is_none")]
pub broadcaster: Option<Did<S>>,
pub data: S,
#[serde(skip_serializing_if = "Option::is_none")]
pub height: Option<i64>,
pub key: S,
pub mime_type: S,
#[serde(skip_serializing_if = "Option::is_none")]
pub width: Option<i64>,
#[serde(flatten, default, skip_serializing_if = "Option::is_none")]
pub extra_data: Option<BTreeMap<SmolStr, Data<S>>>,
}
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(
rename_all = "camelCase",
bound(deserialize = "S: Deserialize<'de> + BosStr")
)]
pub struct UpdateBlobOutput<S: BosStr = DefaultStr> {
pub success: bool,
#[serde(flatten, default, skip_serializing_if = "Option::is_none")]
pub extra_data: Option<BTreeMap<SmolStr, Data<S>>>,
}
#[derive(
Serialize, Deserialize, Debug, Clone, PartialEq, Eq, thiserror::Error, miette::Diagnostic,
)]
#[serde(tag = "error", content = "message")]
pub enum UpdateBlobError {
#[serde(rename = "Unauthorized")]
Unauthorized(Option<SmolStr>),
#[serde(rename = "BlobTooLarge")]
BlobTooLarge(Option<SmolStr>),
#[serde(untagged)]
Other {
error: SmolStr,
message: Option<SmolStr>,
},
}
impl core::fmt::Display for UpdateBlobError {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
match self {
Self::Unauthorized(msg) => {
write!(f, "Unauthorized")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::BlobTooLarge(msg) => {
write!(f, "BlobTooLarge")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::Other { error, message } => {
write!(f, "{}", error)?;
if let Some(msg) = message {
write!(f, ": {}", msg)?;
}
Ok(())
}
}
}
}
pub struct UpdateBlobResponse;
impl jacquard_common::xrpc::XrpcResp for UpdateBlobResponse {
const NSID: &'static str = "place.stream.branding.updateBlob";
const ENCODING: &'static str = "application/json";
type Output<S: BosStr> = UpdateBlobOutput<S>;
type Err = UpdateBlobError;
}
impl<S: BosStr> jacquard_common::xrpc::XrpcRequest for UpdateBlob<S> {
const NSID: &'static str = "place.stream.branding.updateBlob";
const METHOD: jacquard_common::xrpc::XrpcMethod =
jacquard_common::xrpc::XrpcMethod::Procedure("application/json");
type Response = UpdateBlobResponse;
}
pub struct UpdateBlobRequest;
impl jacquard_common::xrpc::XrpcEndpoint for UpdateBlobRequest {
const PATH: &'static str = "/xrpc/place.stream.branding.updateBlob";
const METHOD: jacquard_common::xrpc::XrpcMethod =
jacquard_common::xrpc::XrpcMethod::Procedure("application/json");
type Request<S: BosStr> = UpdateBlob<S>;
type Response = UpdateBlobResponse;
}