#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::CowStr;
use jacquard_common::types::string::{Did, AtUri, Cid};
use jacquard_derive::{IntoStatic, lexicon, open_union};
use serde::{Serialize, Deserialize};
#[lexicon]
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase")]
pub struct CreateBlock<'a> {
#[serde(skip_serializing_if = "Option::is_none")]
#[serde(borrow)]
pub reason: Option<CowStr<'a>>,
#[serde(borrow)]
pub streamer: Did<'a>,
#[serde(borrow)]
pub subject: Did<'a>,
}
#[lexicon]
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase")]
pub struct CreateBlockOutput<'a> {
#[serde(borrow)]
pub cid: Cid<'a>,
#[serde(borrow)]
pub uri: AtUri<'a>,
}
#[open_union]
#[derive(
Serialize,
Deserialize,
Debug,
Clone,
PartialEq,
Eq,
thiserror::Error,
miette::Diagnostic,
IntoStatic
)]
#[serde(tag = "error", content = "message")]
#[serde(bound(deserialize = "'de: 'a"))]
pub enum CreateBlockError<'a> {
#[serde(rename = "Unauthorized")]
Unauthorized(Option<CowStr<'a>>),
#[serde(rename = "Forbidden")]
Forbidden(Option<CowStr<'a>>),
#[serde(rename = "SessionNotFound")]
SessionNotFound(Option<CowStr<'a>>),
}
impl core::fmt::Display for CreateBlockError<'_> {
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::Forbidden(msg) => {
write!(f, "Forbidden")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::SessionNotFound(msg) => {
write!(f, "SessionNotFound")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::Unknown(err) => write!(f, "Unknown error: {:?}", err),
}
}
}
pub struct CreateBlockResponse;
impl jacquard_common::xrpc::XrpcResp for CreateBlockResponse {
const NSID: &'static str = "place.stream.moderation.createBlock";
const ENCODING: &'static str = "application/json";
type Output<'de> = CreateBlockOutput<'de>;
type Err<'de> = CreateBlockError<'de>;
}
impl<'a> jacquard_common::xrpc::XrpcRequest for CreateBlock<'a> {
const NSID: &'static str = "place.stream.moderation.createBlock";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Response = CreateBlockResponse;
}
pub struct CreateBlockRequest;
impl jacquard_common::xrpc::XrpcEndpoint for CreateBlockRequest {
const PATH: &'static str = "/xrpc/place.stream.moderation.createBlock";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Request<'de> = CreateBlock<'de>;
type Response = CreateBlockResponse;
}
pub mod create_block_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 Streamer;
type Subject;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type Streamer = Unset;
type Subject = Unset;
}
pub struct SetStreamer<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetStreamer<S> {}
impl<S: State> State for SetStreamer<S> {
type Streamer = Set<members::streamer>;
type Subject = S::Subject;
}
pub struct SetSubject<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetSubject<S> {}
impl<S: State> State for SetSubject<S> {
type Streamer = S::Streamer;
type Subject = Set<members::subject>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct streamer(());
pub struct subject(());
}
}
pub struct CreateBlockBuilder<'a, S: create_block_state::State> {
_state: PhantomData<fn() -> S>,
_fields: (Option<CowStr<'a>>, Option<Did<'a>>, Option<Did<'a>>),
_lifetime: PhantomData<&'a ()>,
}
impl<'a> CreateBlock<'a> {
pub fn new() -> CreateBlockBuilder<'a, create_block_state::Empty> {
CreateBlockBuilder::new()
}
}
impl<'a> CreateBlockBuilder<'a, create_block_state::Empty> {
pub fn new() -> Self {
CreateBlockBuilder {
_state: PhantomData,
_fields: (None, None, None),
_lifetime: PhantomData,
}
}
}
impl<'a, S: create_block_state::State> CreateBlockBuilder<'a, S> {
pub fn reason(mut self, value: impl Into<Option<CowStr<'a>>>) -> Self {
self._fields.0 = value.into();
self
}
pub fn maybe_reason(mut self, value: Option<CowStr<'a>>) -> Self {
self._fields.0 = value;
self
}
}
impl<'a, S> CreateBlockBuilder<'a, S>
where
S: create_block_state::State,
S::Streamer: create_block_state::IsUnset,
{
pub fn streamer(
mut self,
value: impl Into<Did<'a>>,
) -> CreateBlockBuilder<'a, create_block_state::SetStreamer<S>> {
self._fields.1 = Option::Some(value.into());
CreateBlockBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S> CreateBlockBuilder<'a, S>
where
S: create_block_state::State,
S::Subject: create_block_state::IsUnset,
{
pub fn subject(
mut self,
value: impl Into<Did<'a>>,
) -> CreateBlockBuilder<'a, create_block_state::SetSubject<S>> {
self._fields.2 = Option::Some(value.into());
CreateBlockBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S> CreateBlockBuilder<'a, S>
where
S: create_block_state::State,
S::Streamer: create_block_state::IsSet,
S::Subject: create_block_state::IsSet,
{
pub fn build(self) -> CreateBlock<'a> {
CreateBlock {
reason: self._fields.0,
streamer: self._fields.1.unwrap(),
subject: self._fields.2.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: BTreeMap<
jacquard_common::deps::smol_str::SmolStr,
jacquard_common::types::value::Data<'a>,
>,
) -> CreateBlock<'a> {
CreateBlock {
reason: self._fields.0,
streamer: self._fields.1.unwrap(),
subject: self._fields.2.unwrap(),
extra_data: Some(extra_data),
}
}
}