use std::io::{self, Cursor, Write}; use azalea_buf::{AzBuf, AzaleaRead, AzaleaReadVar, AzaleaWrite, AzaleaWriteVar, BufReadError}; use azalea_chat::{ FormattedText, translatable_component::{StringOrComponent, TranslatableComponent}, }; use azalea_core::bitset::BitSet; use azalea_crypto::MessageSignature; use azalea_protocol_macros::ClientboundGamePacket; use azalea_registry::Holder; use simdnbt::owned::NbtCompound; use uuid::Uuid; #[derive(Clone, Debug, AzBuf, ClientboundGamePacket, PartialEq)] pub struct ClientboundPlayerChat { #[var] pub global_index: u32, pub sender: Uuid, #[var] pub index: u32, pub signature: Option, pub body: PackedSignedMessageBody, pub unsigned_content: Option, pub filter_mask: FilterMask, pub chat_type: ChatTypeBound, } #[derive(Clone, Debug, PartialEq, AzBuf)] pub struct PackedSignedMessageBody { // the error is here, for some reason it skipped a byte earlier and here // it's reading `0` when it should be `11` pub content: String, pub timestamp: u64, pub salt: u64, pub last_seen: PackedLastSeenMessages, } #[derive(Clone, Debug, PartialEq, AzBuf)] pub struct PackedLastSeenMessages { pub entries: Vec, } /// Messages can be deleted by either their signature or message id. #[derive(Clone, Debug, PartialEq)] pub enum PackedMessageSignature { Signature(Box), Id(u32), } #[derive(Clone, Debug, PartialEq, AzBuf)] pub enum FilterMask { PassThrough, FullyFiltered, PartiallyFiltered(BitSet), } #[derive(Clone, Debug, PartialEq, AzBuf)] pub struct ChatTypeBound { pub chat_type: Holder, pub name: FormattedText, pub target_name: Option, } #[derive(Clone, Debug, PartialEq, AzBuf)] pub struct DirectChatType { pub chat: ChatTypeDecoration, pub narration: ChatTypeDecoration, } #[derive(Clone, Debug, PartialEq, AzBuf)] pub struct ChatTypeDecoration { pub translation_key: String, pub parameters: Vec, pub style: NbtCompound, } #[derive(Clone, Copy, Debug, PartialEq, AzBuf)] pub enum ChatTypeDecorationParameter { Sender = 0, Target = 1, Content = 2, } // must be in Client #[derive(Clone, Debug, PartialEq)] pub struct MessageSignatureCache { pub entries: Vec>, } impl ClientboundPlayerChat { /// Returns the content of the message. If you want to get the FormattedText /// for the whole message including the sender part, use /// [`ClientboundPlayerChat::message`]. #[must_use] pub fn content(&self) -> FormattedText { self.unsigned_content .clone() .unwrap_or_else(|| FormattedText::from(self.body.content.clone())) } /// Get the full message, including the sender part. #[must_use] pub fn message(&self) -> FormattedText { let sender = self.chat_type.name.clone(); let content = self.content(); let target = self.chat_type.target_name.clone(); let mut args = vec![ StringOrComponent::FormattedText(sender), StringOrComponent::FormattedText(content), ]; if let Some(target) = target { args.push(StringOrComponent::FormattedText(target)); } let translation_key = self.chat_type.translation_key(); let component = TranslatableComponent::new(translation_key.to_string(), args); FormattedText::Translatable(component) } } impl ChatTypeBound { pub fn translation_key(&self) -> &str { match &self.chat_type { Holder::Reference(r) => r.chat_translation_key(), Holder::Direct(d) => d.chat.translation_key.as_str(), } } } impl AzaleaRead for PackedMessageSignature { fn azalea_read(buf: &mut Cursor<&[u8]>) -> Result { let id = u32::azalea_read_var(buf)?; if id == 0 { let full_signature = MessageSignature::azalea_read(buf)?; Ok(PackedMessageSignature::Signature(Box::new(full_signature))) } else { Ok(PackedMessageSignature::Id(id - 1)) } } } impl AzaleaWrite for PackedMessageSignature { fn azalea_write(&self, buf: &mut impl Write) -> io::Result<()> { match self { PackedMessageSignature::Signature(full_signature) => { 0u32.azalea_write_var(buf)?; full_signature.azalea_write(buf)?; } PackedMessageSignature::Id(id) => { (id + 1).azalea_write_var(buf)?; } } Ok(()) } }