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

construct private read receipt properly

Browse source 
Signed-off-by: strawberry <strawberry@puppygock.gay>
This commit is contained in:
strawberry 2024-12-11 21:25:07 -05:00
parent 66a82447da
commit 353dc17af4
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/service/rooms/read_receipt/mod.rs
View file

@ -6,7 +6,7 @@ use conduit::{debug, err, warn, PduCount, PduId, RawPduId, Result};
use futures::{try_join, Stream, TryFutureExt}; use futures::{try_join, Stream, TryFutureExt};
use ruma::{ use ruma::{
events::{ events::{
receipt::{ReceiptEvent, ReceiptEventContent}, receipt::{ReceiptEvent, ReceiptEventContent, Receipts},
AnySyncEphemeralRoomEvent, SyncEphemeralRoomEvent, AnySyncEphemeralRoomEvent, SyncEphemeralRoomEvent,
}, },
serde::Raw, serde::Raw,
@ -75,7 +75,8 @@ impl Service {
let pdu = self.services.timeline.get_pdu_from_id(&pdu_id).await?; let pdu = self.services.timeline.get_pdu_from_id(&pdu_id).await?;
let event_id: OwnedEventId = pdu.event_id.into(); let event_id: OwnedEventId = pdu.event_id.into();
let receipt_content = BTreeMap::from_iter([( let user_id: OwnedUserId = user_id.to_owned();
let content: BTreeMap<OwnedEventId, Receipts> = BTreeMap::from_iter([(
event_id, event_id,
BTreeMap::from_iter([( BTreeMap::from_iter([(
ruma::events::receipt::ReceiptType::ReadPrivate, ruma::events::receipt::ReceiptType::ReadPrivate,
@ -88,9 +89,12 @@ impl Service {
)]), )]),
)]), )]),
)]); )]);
//let receipt_json = Json let receipt_event_content = ReceiptEventContent(content);
let receipt_sync_event = SyncEphemeralRoomEvent {
content: receipt_event_content,
};
let event = serde_json::value::to_raw_value(&receipt_content).expect("receipt_content created manually"); let event = serde_json::value::to_raw_value(&receipt_sync_event).expect("receipt created manually");
Ok(Raw::from_json(event)) Ok(Raw::from_json(event))
} }