summaryrefslogtreecommitdiff
path: root/src/database
diff options
context:
space:
mode:
authorTimo Kösters <timo@koesters.xyz>2022-10-09 13:15:26 +0200
committerNyaaori <+@nyaaori.cat>2022-10-10 14:02:03 +0200
commit1a7893dbbd22f311d9cbce071d77d5990a8a1711 (patch)
tree354e6751453d3de4932775c66de4f882ddfa137c /src/database
parent5a04559cb47ed14ce23f1a88a52c8c908a45001a (diff)
downloadconduit-1a7893dbbd22f311d9cbce071d77d5990a8a1711.zip
fix: update state_cache on join over federation
Diffstat (limited to 'src/database')
-rw-r--r--src/database/key_value/rooms/state_accessor.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/database/key_value/rooms/state_accessor.rs b/src/database/key_value/rooms/state_accessor.rs
index 39c261f..70e59ac 100644
--- a/src/database/key_value/rooms/state_accessor.rs
+++ b/src/database/key_value/rooms/state_accessor.rs
@@ -23,7 +23,7 @@ impl service::rooms::state_accessor::Data for KeyValueDatabase {
let parsed = services()
.rooms
.state_compressor
- .parse_compressed_state_event(compressed)?;
+ .parse_compressed_state_event(&compressed)?;
result.insert(parsed.0, parsed.1);
i += 1;
@@ -52,7 +52,7 @@ impl service::rooms::state_accessor::Data for KeyValueDatabase {
let (_, eventid) = services()
.rooms
.state_compressor
- .parse_compressed_state_event(compressed)?;
+ .parse_compressed_state_event(&compressed)?;
if let Some(pdu) = services().rooms.timeline.get_pdu(&eventid)? {
result.insert(
(
@@ -104,7 +104,7 @@ impl service::rooms::state_accessor::Data for KeyValueDatabase {
services()
.rooms
.state_compressor
- .parse_compressed_state_event(compressed)
+ .parse_compressed_state_event(&compressed)
.ok()
.map(|(_, id)| id)
}))