mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-15 11:36:07 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore(sdk): Move FrozenSlidingSyncList lower in the file.

Browse Source
This commit is contained in:
Ivan Enderlin
2023-03-01 13:58:55 +01:00
parent 5377bb7ecf
commit cf83112bf0
1 changed files with 35 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
crates/matrix-sdk/src/sliding_sync/list.rs
View File

@@ -64,7 +64,6 @@ pub struct SlidingSyncList {
/// The maximum number of timeline events to query for
pub timeline_limit: Arc<StdRwLock<Observable<Option<UInt>>>>,
// ----- Public state
/// Name of this view to easily recognize them
pub name: String,
@@ -90,41 +89,6 @@ pub struct SlidingSyncList {
is_cold: Arc<AtomicBool>,
}
#[derive(Serialize, Deserialize)]
pub(super) struct FrozenSlidingSyncList {
#[serde(default, skip_serializing_if = "Option::is_none")]
pub(super) rooms_count: Option<u32>,
#[serde(default, skip_serializing_if = "Vector::is_empty")]
pub(super) rooms_list: Vector<RoomListEntry>,
#[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
pub(super) rooms: BTreeMap<OwnedRoomId, FrozenSlidingSyncRoom>,
}
impl FrozenSlidingSyncList {
pub(super) fn freeze(
source_view: &SlidingSyncList,
rooms_map: &BTreeMap<OwnedRoomId, SlidingSyncRoom>,
) -> Self {
let mut rooms = BTreeMap::new();
let mut rooms_list = Vector::new();
for entry in source_view.rooms_list.read().unwrap().iter() {
match entry {
RoomListEntry::Filled(o) | RoomListEntry::Invalidated(o) => {
rooms.insert(o.clone(), rooms_map.get(o).expect("rooms always exists").into());
}
_ => {}
};
rooms_list.push_back(entry.freeze());
}
FrozenSlidingSyncList {
rooms_count: **source_view.rooms_count.read().unwrap(),
rooms_list,
rooms,
}
}
}
impl SlidingSyncList {
pub(crate) fn set_from_cold(
&mut self,
@@ -397,6 +361,41 @@ impl SlidingSyncList {
}
}
#[derive(Serialize, Deserialize)]
pub(super) struct FrozenSlidingSyncList {
#[serde(default, skip_serializing_if = "Option::is_none")]
pub(super) rooms_count: Option<u32>,
#[serde(default, skip_serializing_if = "Vector::is_empty")]
pub(super) rooms_list: Vector<RoomListEntry>,
#[serde(default, skip_serializing_if = "BTreeMap::is_empty")]
pub(super) rooms: BTreeMap<OwnedRoomId, FrozenSlidingSyncRoom>,
}
impl FrozenSlidingSyncList {
pub(super) fn freeze(
source_view: &SlidingSyncList,
rooms_map: &BTreeMap<OwnedRoomId, SlidingSyncRoom>,
) -> Self {
let mut rooms = BTreeMap::new();
let mut rooms_list = Vector::new();
for entry in source_view.rooms_list.read().unwrap().iter() {
match entry {
RoomListEntry::Filled(o) | RoomListEntry::Invalidated(o) => {
rooms.insert(o.clone(), rooms_map.get(o).expect("rooms always exists").into());
}
_ => {}
};
rooms_list.push_back(entry.freeze());
}
FrozenSlidingSyncList {
rooms_count: **source_view.rooms_count.read().unwrap(),
rooms_list,
rooms,
}
}
}
/// the default name for the full sync view
pub const FULL_SYNC_VIEW_NAME: &str = "full-sync";