mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-16 12:43:01 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore(sdk): Rename a variable in SlidingSync::handle_response.

Browse Source
This commit is contained in:
Ivan Enderlin
2023-02-23 16:09:00 +01:00
parent 3b01e4f9a6
commit fcfdf5c57c
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
crates/matrix-sdk/src/sliding_sync/mod.rs
View File

@@ -1002,31 +1002,37 @@ impl SlidingSync {
let mut rooms = Vec::new();
let mut rooms_map = self.rooms.write().unwrap();
for (id, mut room_data) in sliding_sync_response.rooms.into_iter() {
for (room_id, mut room_data) in sliding_sync_response.rooms.into_iter() {
// `sync_response` contains the rooms with decrypted events if any, so look at
// the timeline events here first if the room exists.
// Otherwise, let's look at the timeline inside the `sliding_sync_response`.
let timeline = if let Some(joined_room) = sync_response.rooms.join.remove(&id) {
let timeline = if let Some(joined_room) = sync_response.rooms.join.remove(&room_id)
{
joined_room.timeline.events
} else {
room_data.timeline.drain(..).map(Into::into).collect()
};
if let Some(mut room) = rooms_map.remove(&id) {
if let Some(mut room) = rooms_map.remove(&room_id) {
// The room existed before, let's update it.
room.update(room_data, timeline);
rooms_map.insert(id.clone(), room);
rooms_map.insert(room_id.clone(), room);
} else {
// First time we need this room, let's create it.
rooms_map.insert(
id.clone(),
SlidingSyncRoom::new(self.client.clone(), id.clone(), room_data, timeline),
room_id.clone(),
SlidingSyncRoom::new(
self.client.clone(),
room_id.clone(),
room_data,
timeline,
),
);
}
rooms.push(id);
rooms.push(room_id);
}
let mut updated_views = Vec::new();