Fix the accidentally dual-keyspaced cf from conduit.
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
@@ -200,6 +200,10 @@ pub(super) static MAPS: &[Descriptor] = &[
|
|||||||
name: "roomuserid_lastprivatereadupdate",
|
name: "roomuserid_lastprivatereadupdate",
|
||||||
..descriptor::RANDOM_SMALL
|
..descriptor::RANDOM_SMALL
|
||||||
},
|
},
|
||||||
|
Descriptor {
|
||||||
|
name: "roomuserid_lastnotificationread",
|
||||||
|
..descriptor::RANDOM_SMALL
|
||||||
|
},
|
||||||
Descriptor {
|
Descriptor {
|
||||||
name: "roomuserid_leftcount",
|
name: "roomuserid_leftcount",
|
||||||
val_size_hint: Some(8),
|
val_size_hint: Some(8),
|
||||||
|
|||||||
@@ -24,7 +24,8 @@ impl crate::Service for Service {
|
|||||||
db: Data {
|
db: Data {
|
||||||
userroomid_notificationcount: args.db["userroomid_notificationcount"].clone(),
|
userroomid_notificationcount: args.db["userroomid_notificationcount"].clone(),
|
||||||
userroomid_highlightcount: args.db["userroomid_highlightcount"].clone(),
|
userroomid_highlightcount: args.db["userroomid_highlightcount"].clone(),
|
||||||
roomuserid_lastnotificationread: args.db["userroomid_highlightcount"].clone(),
|
roomuserid_lastnotificationread: args.db["roomuserid_lastnotificationread"]
|
||||||
|
.clone(),
|
||||||
},
|
},
|
||||||
services: args.services.clone(),
|
services: args.services.clone(),
|
||||||
}))
|
}))
|
||||||
|
|||||||
@@ -37,6 +37,7 @@ pub struct Data {
|
|||||||
roomusertype_roomuserdataid: Arc<Map>,
|
roomusertype_roomuserdataid: Arc<Map>,
|
||||||
readreceiptid_readreceipt: Arc<Map>,
|
readreceiptid_readreceipt: Arc<Map>,
|
||||||
userid_lastonetimekeyupdate: Arc<Map>,
|
userid_lastonetimekeyupdate: Arc<Map>,
|
||||||
|
roomuserid_lastnotificationread: Arc<Map>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Default)]
|
#[derive(Debug, Default)]
|
||||||
@@ -81,6 +82,8 @@ impl crate::Service for Service {
|
|||||||
roomusertype_roomuserdataid: args.db["roomusertype_roomuserdataid"].clone(),
|
roomusertype_roomuserdataid: args.db["roomusertype_roomuserdataid"].clone(),
|
||||||
readreceiptid_readreceipt: args.db["readreceiptid_readreceipt"].clone(),
|
readreceiptid_readreceipt: args.db["readreceiptid_readreceipt"].clone(),
|
||||||
userid_lastonetimekeyupdate: args.db["userid_lastonetimekeyupdate"].clone(),
|
userid_lastonetimekeyupdate: args.db["userid_lastonetimekeyupdate"].clone(),
|
||||||
|
roomuserid_lastnotificationread: args.db["roomuserid_lastnotificationread"]
|
||||||
|
.clone(),
|
||||||
},
|
},
|
||||||
services: args.services.clone(),
|
services: args.services.clone(),
|
||||||
connections: Default::default(),
|
connections: Default::default(),
|
||||||
|
|||||||
@@ -85,6 +85,11 @@ where
|
|||||||
let roomuser_prefix = (room_id, user_id);
|
let roomuser_prefix = (room_id, user_id);
|
||||||
let typing_room_id = room_id.to_owned();
|
let typing_room_id = room_id.to_owned();
|
||||||
let watchers = [
|
let watchers = [
|
||||||
|
// Notification clearance
|
||||||
|
self.db
|
||||||
|
.roomuserid_lastnotificationread
|
||||||
|
.watch_prefix(&roomuser_prefix)
|
||||||
|
.boxed(),
|
||||||
// Key changes
|
// Key changes
|
||||||
self.db
|
self.db
|
||||||
.keychangeid_userid
|
.keychangeid_userid
|
||||||
|
|||||||
Reference in New Issue
Block a user