diff options
author | Timo Kösters <timo@koesters.xyz> | 2022-10-05 20:34:31 +0200 |
---|---|---|
committer | Nyaaori <+@nyaaori.cat> | 2022-10-10 14:02:01 +0200 |
commit | a4637e2ba1093065a6fda3fa2ad2b2b9f30eea63 (patch) | |
tree | 2d31313957d699875fc61f570686318b523ae0f1 /src/database/key_value/rooms/search.rs | |
parent | 33a2b2b7729bb40253fd174d99ad773869b5ecfe (diff) | |
download | conduit-a4637e2ba1093065a6fda3fa2ad2b2b9f30eea63.zip |
cargo fmt
Diffstat (limited to 'src/database/key_value/rooms/search.rs')
-rw-r--r-- | src/database/key_value/rooms/search.rs | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/src/database/key_value/rooms/search.rs b/src/database/key_value/rooms/search.rs index 41df544..79e6a32 100644 --- a/src/database/key_value/rooms/search.rs +++ b/src/database/key_value/rooms/search.rs @@ -2,7 +2,7 @@ use std::mem::size_of; use ruma::RoomId; -use crate::{service, database::KeyValueDatabase, utils, Result, services}; +use crate::{database::KeyValueDatabase, service, services, utils, Result}; impl service::rooms::search::Data for KeyValueDatabase { fn index_pdu<'a>(&self, shortroomid: u64, pdu_id: &[u8], message_body: String) -> Result<()> { @@ -27,7 +27,9 @@ impl service::rooms::search::Data for KeyValueDatabase { room_id: &RoomId, search_string: &str, ) -> Result<Option<(Box<dyn Iterator<Item = Vec<u8>>>, Vec<String>)>> { - let prefix = services().rooms.short + let prefix = services() + .rooms + .short .get_shortroomid(room_id)? .expect("room exists") .to_be_bytes() @@ -63,10 +65,10 @@ impl service::rooms::search::Data for KeyValueDatabase { }; let mapped = common_elements.map(move |id| { - let mut pduid = prefix_clone.clone(); - pduid.extend_from_slice(&id); - pduid - }); + let mut pduid = prefix_clone.clone(); + pduid.extend_from_slice(&id); + pduid + }); Ok(Some((Box::new(mapped), words))) } |