#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::{CowStr, BosStr, DefaultStr, FromStaticStr};
use jacquard_common::deps::smol_str::SmolStr;
use jacquard_common::types::value::Data;
use jacquard_derive::{IntoStatic, open_union};
use serde::{Serialize, Deserialize};
use crate::place_stream::multistream::TargetView;
use crate::place_stream::multistream::target::Target;
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase", bound(deserialize = "S: Deserialize<'de> + BosStr"))]
pub struct CreateTarget<S: BosStr = DefaultStr> {
pub multistream_target: Target<S>,
#[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 CreateTargetOutput<S: BosStr = DefaultStr> {
#[serde(flatten)]
pub value: TargetView<S>,
#[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 CreateTargetError {
#[serde(rename = "InvalidTargetUrl")]
InvalidTargetUrl(Option<SmolStr>),
#[serde(untagged)]
Other { error: SmolStr, message: Option<SmolStr> },
}
impl core::fmt::Display for CreateTargetError {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
match self {
Self::InvalidTargetUrl(msg) => {
write!(f, "InvalidTargetUrl")?;
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 CreateTargetResponse;
impl jacquard_common::xrpc::XrpcResp for CreateTargetResponse {
const NSID: &'static str = "place.stream.multistream.createTarget";
const ENCODING: &'static str = "application/json";
type Output<S: BosStr> = CreateTargetOutput<S>;
type Err = CreateTargetError;
}
impl<S: BosStr> jacquard_common::xrpc::XrpcRequest for CreateTarget<S> {
const NSID: &'static str = "place.stream.multistream.createTarget";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Response = CreateTargetResponse;
}
pub struct CreateTargetRequest;
impl jacquard_common::xrpc::XrpcEndpoint for CreateTargetRequest {
const PATH: &'static str = "/xrpc/place.stream.multistream.createTarget";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Request<S: BosStr> = CreateTarget<S>;
type Response = CreateTargetResponse;
}
pub mod create_target_state {
pub use crate::builder_types::{Set, Unset, IsSet, IsUnset};
#[allow(unused)]
use ::core::marker::PhantomData;
mod sealed {
pub trait Sealed {}
}
pub trait State: sealed::Sealed {
type MultistreamTarget;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type MultistreamTarget = Unset;
}
pub struct SetMultistreamTarget<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetMultistreamTarget<St> {}
impl<St: State> State for SetMultistreamTarget<St> {
type MultistreamTarget = Set<members::multistream_target>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct multistream_target(());
}
}
pub struct CreateTargetBuilder<S: BosStr, St: create_target_state::State> {
_state: PhantomData<fn() -> St>,
_fields: (Option<Target<S>>,),
_type: PhantomData<fn() -> S>,
}
impl<S: BosStr> CreateTarget<S> {
pub fn new() -> CreateTargetBuilder<S, create_target_state::Empty> {
CreateTargetBuilder::new()
}
}
impl<S: BosStr> CreateTargetBuilder<S, create_target_state::Empty> {
pub fn new() -> Self {
CreateTargetBuilder {
_state: PhantomData,
_fields: (None,),
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CreateTargetBuilder<S, St>
where
St: create_target_state::State,
St::MultistreamTarget: create_target_state::IsUnset,
{
pub fn multistream_target(
mut self,
value: impl Into<Target<S>>,
) -> CreateTargetBuilder<S, create_target_state::SetMultistreamTarget<St>> {
self._fields.0 = Option::Some(value.into());
CreateTargetBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CreateTargetBuilder<S, St>
where
St: create_target_state::State,
St::MultistreamTarget: create_target_state::IsSet,
{
pub fn build(self) -> CreateTarget<S> {
CreateTarget {
multistream_target: self._fields.0.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: BTreeMap<SmolStr, Data<S>>,
) -> CreateTarget<S> {
CreateTarget {
multistream_target: self._fields.0.unwrap(),
extra_data: Some(extra_data),
}
}
}