@@ -59,0 +67,4 @@
+		let mut is_dup = false;
+
+		for key in keys {
+			if let Ok(val) = self.readreceiptid_readreceipt.get(&key).await {

@@ -30,0 +36,6 @@
+		return Err!(Request(Forbidden("You are not in this room.")));
+	}
+
+	if services.users.is_suspended(sender_user).await? {
+		return Err!(Request(Forbidden("User is suspended.")));
+	}

@@ -48,2 +48,2 @@
-	) {
-		// Remove old entry
+	) -> bool {
+		let new_target = event.content.0.iter().find_map(|(ev_id, types)| {

@@ -59,0 +69,4 @@
+		for key in keys {
+			if let Ok(val) = self.readreceiptid_readreceipt.get(&key).await {
+				if let Ok(existing) = serde_json::from_slice::<ReceiptEvent>(&val) {
+					let existing_target = existing.content.0.iter().find_map(|(ev_id, types)| {

@@ -59,0 +75,4 @@
+						})
+					});
+
+					if let (Some(new_t), Some(old_t)) = (new_target, existing_target) {

@@ -59,0 +76,4 @@
+					});
+
+					if let (Some(new_t), Some(old_t)) = (new_target, existing_target) {
+						if new_t.1 == old_t.1 && new_t.2 == old_t.2 {

@@ -59,0 +79,4 @@
+						if new_t.1 == old_t.1 && new_t.2 == old_t.2 {
+							if new_t.0 == old_t.0 {
+								is_dup = true;
+							} else {