#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::{CowStr, BosStr, DefaultStr, FromStaticStr};
#[allow(unused_imports)]
use jacquard_common::deps::codegen::unicode_segmentation::UnicodeSegmentation;
use jacquard_common::deps::smol_str::SmolStr;
use jacquard_common::types::value::Data;
use jacquard_derive::IntoStatic;
use jacquard_lexicon::lexicon::LexiconDoc;
use jacquard_lexicon::schema::LexiconSchema;
#[allow(unused_imports)]
use jacquard_lexicon::validation::{ConstraintError, ValidationPath};
use serde::{Serialize, Deserialize};
use crate::chat_bsky::convo::MessageInput;
use crate::chat_bsky::convo::MessageView;
use crate::chat_bsky::convo::send_message_batch;
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase", bound(deserialize = "S: Deserialize<'de> + BosStr"))]
pub struct BatchItem<S: BosStr = DefaultStr> {
pub convo_id: S,
pub message: MessageInput<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 SendMessageBatch<S: BosStr = DefaultStr> {
pub items: Vec<send_message_batch::BatchItem<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 SendMessageBatchOutput<S: BosStr = DefaultStr> {
pub items: Vec<MessageView<S>>,
#[serde(flatten, default, skip_serializing_if = "Option::is_none")]
pub extra_data: Option<BTreeMap<SmolStr, Data<S>>>,
}
impl<S: BosStr> LexiconSchema for BatchItem<S> {
fn nsid() -> &'static str {
"chat.bsky.convo.sendMessageBatch"
}
fn def_name() -> &'static str {
"batchItem"
}
fn lexicon_doc() -> LexiconDoc<'static> {
lexicon_doc_chat_bsky_convo_sendMessageBatch()
}
fn validate(&self) -> Result<(), ConstraintError> {
Ok(())
}
}
pub struct SendMessageBatchResponse;
impl jacquard_common::xrpc::XrpcResp for SendMessageBatchResponse {
const NSID: &'static str = "chat.bsky.convo.sendMessageBatch";
const ENCODING: &'static str = "application/json";
type Output<S: BosStr> = SendMessageBatchOutput<S>;
type Err = jacquard_common::xrpc::GenericError;
}
impl<S: BosStr> jacquard_common::xrpc::XrpcRequest for SendMessageBatch<S> {
const NSID: &'static str = "chat.bsky.convo.sendMessageBatch";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Response = SendMessageBatchResponse;
}
pub struct SendMessageBatchRequest;
impl jacquard_common::xrpc::XrpcEndpoint for SendMessageBatchRequest {
const PATH: &'static str = "/xrpc/chat.bsky.convo.sendMessageBatch";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Request<S: BosStr> = SendMessageBatch<S>;
type Response = SendMessageBatchResponse;
}
pub mod batch_item_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 ConvoId;
type Message;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type ConvoId = Unset;
type Message = Unset;
}
pub struct SetConvoId<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetConvoId<St> {}
impl<St: State> State for SetConvoId<St> {
type ConvoId = Set<members::convo_id>;
type Message = St::Message;
}
pub struct SetMessage<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetMessage<St> {}
impl<St: State> State for SetMessage<St> {
type ConvoId = St::ConvoId;
type Message = Set<members::message>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct convo_id(());
pub struct message(());
}
}
pub struct BatchItemBuilder<S: BosStr, St: batch_item_state::State> {
_state: PhantomData<fn() -> St>,
_fields: (Option<S>, Option<MessageInput<S>>),
_type: PhantomData<fn() -> S>,
}
impl<S: BosStr> BatchItem<S> {
pub fn new() -> BatchItemBuilder<S, batch_item_state::Empty> {
BatchItemBuilder::new()
}
}
impl<S: BosStr> BatchItemBuilder<S, batch_item_state::Empty> {
pub fn new() -> Self {
BatchItemBuilder {
_state: PhantomData,
_fields: (None, None),
_type: PhantomData,
}
}
}
impl<S: BosStr, St> BatchItemBuilder<S, St>
where
St: batch_item_state::State,
St::ConvoId: batch_item_state::IsUnset,
{
pub fn convo_id(
mut self,
value: impl Into<S>,
) -> BatchItemBuilder<S, batch_item_state::SetConvoId<St>> {
self._fields.0 = Option::Some(value.into());
BatchItemBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> BatchItemBuilder<S, St>
where
St: batch_item_state::State,
St::Message: batch_item_state::IsUnset,
{
pub fn message(
mut self,
value: impl Into<MessageInput<S>>,
) -> BatchItemBuilder<S, batch_item_state::SetMessage<St>> {
self._fields.1 = Option::Some(value.into());
BatchItemBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> BatchItemBuilder<S, St>
where
St: batch_item_state::State,
St::ConvoId: batch_item_state::IsSet,
St::Message: batch_item_state::IsSet,
{
pub fn build(self) -> BatchItem<S> {
BatchItem {
convo_id: self._fields.0.unwrap(),
message: self._fields.1.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: BTreeMap<SmolStr, Data<S>>,
) -> BatchItem<S> {
BatchItem {
convo_id: self._fields.0.unwrap(),
message: self._fields.1.unwrap(),
extra_data: Some(extra_data),
}
}
}
fn lexicon_doc_chat_bsky_convo_sendMessageBatch() -> LexiconDoc<'static> {
#[allow(unused_imports)]
use jacquard_common::{CowStr, deps::smol_str::SmolStr, types::blob::MimeType};
use jacquard_lexicon::lexicon::*;
use alloc::collections::BTreeMap;
LexiconDoc {
lexicon: Lexicon::Lexicon1,
id: CowStr::new_static("chat.bsky.convo.sendMessageBatch"),
defs: {
let mut map = BTreeMap::new();
map.insert(
SmolStr::new_static("batchItem"),
LexUserType::Object(LexObject {
required: Some(
vec![
SmolStr::new_static("convoId"),
SmolStr::new_static("message")
],
),
properties: {
#[allow(unused_mut)]
let mut map = BTreeMap::new();
map.insert(
SmolStr::new_static("convoId"),
LexObjectProperty::String(LexString { ..Default::default() }),
);
map.insert(
SmolStr::new_static("message"),
LexObjectProperty::Ref(LexRef {
r#ref: CowStr::new_static(
"chat.bsky.convo.defs#messageInput",
),
..Default::default()
}),
);
map
},
..Default::default()
}),
);
map.insert(
SmolStr::new_static("main"),
LexUserType::XrpcProcedure(LexXrpcProcedure {
input: Some(LexXrpcBody {
encoding: CowStr::new_static("application/json"),
schema: Some(
LexXrpcBodySchema::Object(LexObject {
required: Some(vec![SmolStr::new_static("items")]),
properties: {
#[allow(unused_mut)]
let mut map = BTreeMap::new();
map.insert(
SmolStr::new_static("items"),
LexObjectProperty::Array(LexArray {
items: LexArrayItem::Ref(LexRef {
r#ref: CowStr::new_static("#batchItem"),
..Default::default()
}),
max_length: Some(100usize),
..Default::default()
}),
);
map
},
..Default::default()
}),
),
..Default::default()
}),
..Default::default()
}),
);
map
},
..Default::default()
}
}
pub mod send_message_batch_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 Items;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type Items = Unset;
}
pub struct SetItems<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetItems<St> {}
impl<St: State> State for SetItems<St> {
type Items = Set<members::items>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct items(());
}
}
pub struct SendMessageBatchBuilder<S: BosStr, St: send_message_batch_state::State> {
_state: PhantomData<fn() -> St>,
_fields: (Option<Vec<send_message_batch::BatchItem<S>>>,),
_type: PhantomData<fn() -> S>,
}
impl<S: BosStr> SendMessageBatch<S> {
pub fn new() -> SendMessageBatchBuilder<S, send_message_batch_state::Empty> {
SendMessageBatchBuilder::new()
}
}
impl<S: BosStr> SendMessageBatchBuilder<S, send_message_batch_state::Empty> {
pub fn new() -> Self {
SendMessageBatchBuilder {
_state: PhantomData,
_fields: (None,),
_type: PhantomData,
}
}
}
impl<S: BosStr, St> SendMessageBatchBuilder<S, St>
where
St: send_message_batch_state::State,
St::Items: send_message_batch_state::IsUnset,
{
pub fn items(
mut self,
value: impl Into<Vec<send_message_batch::BatchItem<S>>>,
) -> SendMessageBatchBuilder<S, send_message_batch_state::SetItems<St>> {
self._fields.0 = Option::Some(value.into());
SendMessageBatchBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> SendMessageBatchBuilder<S, St>
where
St: send_message_batch_state::State,
St::Items: send_message_batch_state::IsSet,
{
pub fn build(self) -> SendMessageBatch<S> {
SendMessageBatch {
items: self._fields.0.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: BTreeMap<SmolStr, Data<S>>,
) -> SendMessageBatch<S> {
SendMessageBatch {
items: self._fields.0.unwrap(),
extra_data: Some(extra_data),
}
}
}