caffeinatedgaze
/
lavina
forked from lavina/lavina
1
0
Fork 0
Code Pull Requests Activity

Compare commits

base: caffeinatedgaze:85c8d03f542bb41bbd1d7562ce65112d3aae48ec
Branches Tags
caffeinatedgaze:main
caffeinatedgaze:#39-irc-chathistory
caffeinatedgaze:feature/muc-join-messages
caffeinatedgaze:x-user-and-items
caffeinatedgaze:fix/check-if-member
caffeinatedgaze:feature-mam
caffeinatedgaze:fix-links
lavina:main
caffeinatedgaze:0.0.1
caffeinatedgaze:0.0.0
lavina:0.0.0
lavina:0.0.1
lavina:0.0.2
...
compare: caffeinatedgaze:6def71b581e829dcf33ce4820b63db5e1df2313b
Branches Tags
caffeinatedgaze:#39-irc-chathistory
caffeinatedgaze:feature/muc-join-messages
caffeinatedgaze:x-user-and-items
caffeinatedgaze:fix/check-if-member
caffeinatedgaze:feature-mam
caffeinatedgaze:main
caffeinatedgaze:fix-links
lavina:main
caffeinatedgaze:0.0.1
caffeinatedgaze:0.0.0
lavina:0.0.0
lavina:0.0.1
lavina:0.0.2

2 Commits
85c8d03f54 ... 6def71b581

Author SHA1 Message Date
Mikhail 6def71b581 Serialize delay separately 2024-05-24 11:33:45 +02:00
Mikhail 8dff974df8 Add tracing info 2024-05-24 11:03:04 +02:00
2 changed files with 37 additions and 22 deletions
Show Stats Expand all files Collapse all files

1
crates/projection-xmpp/src/presence.rs
View File

@ -130,6 +130,7 @@ impl<'a> XmppConnection<'a> {
<body></body>
</message>
*/
#[tracing::instrument(skip(self), name = "XmppConnection::retrieve_message_history")]
async fn retrieve_message_history(&self, room_name: &Name) -> Result<(Vec<XmppHistoryMessage>)> {
let room_id = RoomId::try_from(room_name.0.clone())?;
let history_messages = self.user_handle.get_room_message_history(room_id).await?;

58
crates/proto-xmpp/src/muc/mod.rs
View File

@ -268,6 +268,33 @@ impl Delay {
}
}
impl ToXml for Delay {
fn serialize(&self, events: &mut Vec<Event>) {
let mut tag = BytesStart::new("delay");
tag.push_attribute(Attribute {
key: QName(b"xmlns"),
value: self.xmlns.as_bytes().into(),
});
tag.push_attribute(Attribute {
key: QName(b"from"),
value: self.from.to_string().into_bytes().into(),
});
tag.push_attribute(Attribute {
key: QName(b"stamp"),
value: self.stamp.as_bytes().into(),
});
events.push(Event::Empty(tag));
}
}
/*
Example of an XMPP message with history stanza:
<message from="duqedadi@conference.oflor.me/misha" xml:lang="en" to="misha@oflor.me/tux" type="groupchat" id="7ca7cb14-b2af-49c9-bd90-05dabb1113a5">
<delay xmlns="urn:xmpp:delay" stamp="2024-05-17T16:05:28.440337Z" from="duqedadi@conference.oflor.me"/>
<body></body>
</message>
*/
#[derive(Debug, PartialEq, Eq)]
pub struct XmppHistoryMessage {
pub id: String,
@ -279,40 +306,27 @@ pub struct XmppHistoryMessage {
impl ToXml for XmppHistoryMessage {
fn serialize(&self, events: &mut Vec<Event<'static>>) {
let mut tag = BytesStart::new("message");
tag.push_attribute(Attribute {
let mut message_tag = BytesStart::new("message");
message_tag.push_attribute(Attribute {
key: QName(b"id"),
value: self.id.as_str().as_bytes().into(),
});
tag.push_attribute(Attribute {
message_tag.push_attribute(Attribute {
key: QName(b"to"),
value: self.to.to_string().into_bytes().into(),
});
tag.push_attribute(Attribute {
message_tag.push_attribute(Attribute {
key: QName(b"from"),
value: self.from.to_string().into_bytes().into(),
});
tag.push_attribute(Attribute {
message_tag.push_attribute(Attribute {
key: QName(b"type"),
value: b"groupchat".into(),
});
events.push(Event::Start(tag));
let mut tag = BytesStart::new("delay");
tag.push_attribute(Attribute {
key: QName(b"xmlns"),
value: self.delay.xmlns.as_bytes().into(),
});
tag.push_attribute(Attribute {
key: QName(b"from"),
value: self.delay.from.to_string().into_bytes().into(),
});
tag.push_attribute(Attribute {
key: QName(b"stamp"),
value: self.delay.stamp.as_bytes().into(),
});
events.push(Event::Empty(tag));
let mut tag = BytesStart::new("body");
events.push(Event::Start(tag));
events.push(Event::Start(message_tag));
self.delay.serialize(events);
let body_tag = BytesStart::new("body");
events.push(Event::Start(body_tag));
events.push(Event::Text(BytesText::new(self.body.to_string().as_str()).into_owned()));
events.push(Event::End(BytesEnd::new("body")));
events.push(Event::End(BytesEnd::new("message")));