feat: Add config option for receiving read receipts

Adds an option for ignoring incoming read receipts over federation

src/api/server_server.rs

@@ -746,43 +746,45 @@ pub async fn send_transaction_message_route(
         match edu {
             Edu::Presence(_) => {}
             Edu::Receipt(receipt) => {
-                for (room_id, room_updates) in receipt.receipts {
+                if services().globals.allow_receiving_read_receipts() {
-                    for (user_id, user_updates) in room_updates.read {
+                    for (room_id, room_updates) in receipt.receipts {
-                        if let Some((event_id, _)) = user_updates
+                        for (user_id, user_updates) in room_updates.read {
-                            .event_ids
+                            if let Some((event_id, _)) = user_updates
-                            .iter()
+                                .event_ids
-                            .filter_map(|id| {
+                                .iter()
+                                .filter_map(|id| {
+                                    services()
+                                        .rooms
+                                        .timeline
+                                        .get_pdu_count(id)
+                                        .ok()
+                                        .flatten()
+                                        .map(|r| (id, r))
+                                })
+                                .max_by_key(|(_, count)| *count)
+                            {
+                                let mut user_receipts = BTreeMap::new();
+                                user_receipts.insert(user_id.clone(), user_updates.data);
+
+                                let mut receipts = BTreeMap::new();
+                                receipts.insert(ReceiptType::Read, user_receipts);
+
+                                let mut receipt_content = BTreeMap::new();
+                                receipt_content.insert(event_id.to_owned(), receipts);
+
+                                let event = ReceiptEvent {
+                                    content: ReceiptEventContent(receipt_content),
+                                    room_id: room_id.clone(),
+                                };
                                 services()
                                     .rooms
-                                    .timeline
+                                    .edus
-                                    .get_pdu_count(id)
+                                    .read_receipt
-                                    .ok()
+                                    .readreceipt_update(&user_id, &room_id, event)?;
-                                    .flatten()
+                            } else {
-                                    .map(|r| (id, r))
+                                // TODO fetch missing events
-                            })
+                                info!("No known event ids in read receipt: {:?}", user_updates);
-                            .max_by_key(|(_, count)| *count)
+                            }
-                        {
-                            let mut user_receipts = BTreeMap::new();
-                            user_receipts.insert(user_id.clone(), user_updates.data);
-
-                            let mut receipts = BTreeMap::new();
-                            receipts.insert(ReceiptType::Read, user_receipts);
-
-                            let mut receipt_content = BTreeMap::new();
-                            receipt_content.insert(event_id.to_owned(), receipts);
-
-                            let event = ReceiptEvent {
-                                content: ReceiptEventContent(receipt_content),
-                                room_id: room_id.clone(),
-                            };
-                            services()
-                                .rooms
-                                .edus
-                                .read_receipt
-                                .readreceipt_update(&user_id, &room_id, event)?;
-                        } else {
-                            // TODO fetch missing events
-                            info!("No known event ids in read receipt: {:?}", user_updates);
                         }
                     }
                 }

src/config/mod.rs

@@ -49,6 +49,8 @@ pub struct Config {
     #[serde(default = "true_fn")]
     pub allow_public_read_receipts: bool,
     #[serde(default = "true_fn")]
+    pub allow_receiving_read_receipts: bool,
+    #[serde(default = "true_fn")]
     pub allow_room_creation: bool,
     #[serde(default = "true_fn")]
     pub allow_unstable_room_versions: bool,

src/service/globals/mod.rs

@@ -238,6 +238,10 @@ impl Service {
         self.config.allow_public_read_receipts
     }
 
+    pub fn allow_receiving_read_receipts(&self) -> bool {
+        self.config.allow_receiving_read_receipts
+    }
+
     pub fn allow_room_creation(&self) -> bool {
         self.config.allow_room_creation
     }