backups/grapevine
1
0
Fork 0
mirror of https://gitlab.computer.surgery/matrix/grapevine.git synced 2025-12-18 16:21:24 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

MSC3575: allow empty conn_id

Browse source
This commit is contained in:
Lambda 2025-08-10 18:53:10 +00:00
parent 64ad940bad
commit ede39370a4
2 changed files with 13 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

32
src/api/client_server/sync/msc3575.rs
View file

@ -83,9 +83,7 @@ pub(crate) async fn sync_events_v4_route(
}; };
if globalsince == 0 { if globalsince == 0 {
if body.conn_id.is_some() { services().users.forget_sync_request_connection(&connection_key);
services().users.forget_sync_request_connection(&connection_key);
}
} }
let known_rooms = let known_rooms =
@ -377,14 +375,12 @@ pub(crate) async fn sync_events_v4_route(
}, },
); );
if body.conn_id.is_some() { services().users.update_sync_known_rooms(
services().users.update_sync_known_rooms( connection_key.clone(),
connection_key.clone(), list_id,
list_id, new_known_rooms,
new_known_rooms, globalsince,
globalsince, );
);
}
} }
let mut known_subscription_rooms = BTreeSet::new(); let mut known_subscription_rooms = BTreeSet::new();
@ -405,14 +401,12 @@ pub(crate) async fn sync_events_v4_route(
known_subscription_rooms.remove(&r); known_subscription_rooms.remove(&r);
} }
if body.conn_id.is_some() { services().users.update_sync_known_rooms(
services().users.update_sync_known_rooms( connection_key.clone(),
connection_key.clone(), "subscriptions".to_owned(),
"subscriptions".to_owned(), known_subscription_rooms,
known_subscription_rooms, globalsince,
globalsince, );
);
}
let mut rooms = BTreeMap::new(); let mut rooms = BTreeMap::new();
for ( for (

4
src/service/users.rs
View file

@ -70,10 +70,6 @@ impl Service {
&self, &self,
connection_key: ConnectionKey, connection_key: ConnectionKey,
) -> BTreeMap<String, BTreeMap<OwnedRoomId, u64>> { ) -> BTreeMap<String, BTreeMap<OwnedRoomId, u64>> {
if connection_key.connection.is_none() {
return BTreeMap::new();
};
let cached = self.get_cache_entry(connection_key); let cached = self.get_cache_entry(connection_key);
let cached = cached.lock().unwrap(); let cached = cached.lock().unwrap();