diff options
author | Timo Kösters <timo@koesters.xyz> | 2022-10-09 13:15:26 +0200 |
---|---|---|
committer | Nyaaori <+@nyaaori.cat> | 2022-10-10 14:02:03 +0200 |
commit | 1a7893dbbd22f311d9cbce071d77d5990a8a1711 (patch) | |
tree | 354e6751453d3de4932775c66de4f882ddfa137c /src/database | |
parent | 5a04559cb47ed14ce23f1a88a52c8c908a45001a (diff) | |
download | conduit-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.rs | 6 |
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) })) |