#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::CowStr;
use jacquard_derive::{IntoStatic, lexicon, open_union};
use serde::{Serialize, Deserialize};
use crate::chat_bsky::convo::MessageView;
#[lexicon]
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic, Default)]
#[serde(rename_all = "camelCase")]
pub struct AddReaction<'a> {
#[serde(borrow)]
pub convo_id: CowStr<'a>,
#[serde(borrow)]
pub message_id: CowStr<'a>,
#[serde(borrow)]
pub value: CowStr<'a>,
}
#[lexicon]
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase")]
pub struct AddReactionOutput<'a> {
#[serde(borrow)]
pub message: MessageView<'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 AddReactionError<'a> {
#[serde(rename = "ReactionMessageDeleted")]
ReactionMessageDeleted(Option<CowStr<'a>>),
#[serde(rename = "ReactionLimitReached")]
ReactionLimitReached(Option<CowStr<'a>>),
#[serde(rename = "ReactionInvalidValue")]
ReactionInvalidValue(Option<CowStr<'a>>),
}
impl core::fmt::Display for AddReactionError<'_> {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
match self {
Self::ReactionMessageDeleted(msg) => {
write!(f, "ReactionMessageDeleted")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::ReactionLimitReached(msg) => {
write!(f, "ReactionLimitReached")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::ReactionInvalidValue(msg) => {
write!(f, "ReactionInvalidValue")?;
if let Some(msg) = msg {
write!(f, ": {}", msg)?;
}
Ok(())
}
Self::Unknown(err) => write!(f, "Unknown error: {:?}", err),
}
}
}
pub struct AddReactionResponse;
impl jacquard_common::xrpc::XrpcResp for AddReactionResponse {
const NSID: &'static str = "chat.bsky.convo.addReaction";
const ENCODING: &'static str = "application/json";
type Output<'de> = AddReactionOutput<'de>;
type Err<'de> = AddReactionError<'de>;
}
impl<'a> jacquard_common::xrpc::XrpcRequest for AddReaction<'a> {
const NSID: &'static str = "chat.bsky.convo.addReaction";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Response = AddReactionResponse;
}
pub struct AddReactionRequest;
impl jacquard_common::xrpc::XrpcEndpoint for AddReactionRequest {
const PATH: &'static str = "/xrpc/chat.bsky.convo.addReaction";
const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure(
"application/json",
);
type Request<'de> = AddReaction<'de>;
type Response = AddReactionResponse;
}