git-mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2025-07-06 22:06:11 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

revert sending edu read reciepts to appservices

Browse source
This commit is contained in:
Jade Ellis 2024-12-18 18:45:12 +00:00
parent 4dd809fdc4
commit ccdd7aefb6
No known key found for this signature in database
GPG key ID: 8705A2A3EBF77BD2
1 changed files with 1 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -2,10 +2,9 @@ mod data;
use std::{collections::BTreeMap, sync::Arc}; use std::{collections::BTreeMap, sync::Arc};
use conduwuit::{debug, err, result::LogErr, warn, PduCount, PduId, RawPduId, Result}; use conduwuit::{debug, err, warn, PduCount, PduId, RawPduId, Result};
use futures::{try_join, Stream, TryFutureExt}; use futures::{try_join, Stream, TryFutureExt};
use ruma::{ use ruma::{
api::appservice::event::push_events::v1::EphemeralData,
events::{ events::{
receipt::{ReceiptEvent, ReceiptEventContent, Receipts}, receipt::{ReceiptEvent, ReceiptEventContent, Receipts},
AnySyncEphemeralRoomEvent, SyncEphemeralRoomEvent, AnySyncEphemeralRoomEvent, SyncEphemeralRoomEvent,
@ -57,17 +56,6 @@ impl Service {
.flush_room(room_id) .flush_room(room_id)
.await .await
.expect("room flush failed"); .expect("room flush failed");
// update appservices
let edu = EphemeralData::Receipt(event);
_ = self
.services
.sending
.send_edu_appservice_room(
room_id,
serde_json::to_vec(&edu).expect("Serialized EphemeralData::Receipt"),
)
.await
.log_err();
} }
/// Gets the latest private read receipt from the user in the room /// Gets the latest private read receipt from the user in the room