fix aliasid_alias key deserialization

Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk 2024-10-04 17:17:10 +00:00 committed by strawberry
parent bd9a9cc5f8
commit ba683cf534

View file

@ -101,9 +101,9 @@ impl Service {
let prefix = (&room_id, Interfix); let prefix = (&room_id, Interfix);
self.db self.db
.aliasid_alias .aliasid_alias
.keys_prefix(&prefix) .keys_raw_prefix(&prefix)
.ignore_err() .ignore_err()
.ready_for_each(|key: &[u8]| self.db.aliasid_alias.remove(&key)) .ready_for_each(|key| self.db.aliasid_alias.remove(key))
.await; .await;
self.db.alias_roomid.remove(alias.as_bytes()); self.db.alias_roomid.remove(alias.as_bytes());
@ -161,7 +161,7 @@ impl Service {
.aliasid_alias .aliasid_alias
.stream_prefix(&prefix) .stream_prefix(&prefix)
.ignore_err() .ignore_err()
.map(|((Ignore, Ignore), alias): ((Ignore, Ignore), &RoomAliasId)| alias) .map(|(_, alias): (Ignore, &RoomAliasId)| alias)
} }
#[tracing::instrument(skip(self), level = "debug")] #[tracing::instrument(skip(self), level = "debug")]