magmaus3/continuwuity
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update ruwuma

Browse source
This commit is contained in:
Jade Ellis 2024-12-19 20:19:05 +00:00 • committed by June Clementine Strawberry 🍓🦴
parent 025950139e
commit 5b5735f653
3 changed files with 20 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/service/sending/sender.rs
View file

@ -21,7 +21,7 @@ use futures::{
};
use ruma::{
api::{
appservice::event::push_events::v1::Edu as RumaEdu,
appservice::event::push_events::v1::EphemeralData,
federation::transactions::{
edu::{
DeviceListUpdateContent, Edu, PresenceContent, PresenceUpdate, ReceiptContent,
@ -587,7 +587,7 @@ impl Service {
.filter(|event| matches!(event, SendingEvent::Pdu(_)))
.count(),
);
let mut edu_jsons: Vec<RumaEdu> = Vec::with_capacity(
let mut edu_jsons: Vec<EphemeralData> = Vec::with_capacity(
events
.iter()
.filter(|event| matches!(event, SendingEvent::Edu(_)))
@ -600,16 +600,12 @@ impl Service {
pdu_jsons.push(pdu.to_room_event());
}
},
| SendingEvent::Edu(edu) => {
if appservice
.receive_ephemeral
.is_some_and(|receive_edus| receive_edus)
{
| SendingEvent::Edu(edu) =>
if appservice.receive_ephemeral {
if let Ok(edu) = serde_json::from_slice(edu) {
edu_jsons.push(edu);
}
}
},
},
| SendingEvent::Flush => {}, // flush only; no new content
}
}