Remove unneeded intermediary container collection

merge-requests/183/head
Jonas Platte 3 years ago
parent 27788af022
commit 487601a249
No known key found for this signature in database
GPG Key ID: CC154DE0E30B7C67

@ -1397,39 +1397,34 @@ async fn upgrade_outlier_to_timeline_pdu(
extremity_sstatehashes.insert(sstatehash, prev_event); extremity_sstatehashes.insert(sstatehash, prev_event);
} }
let mut fork_states = Vec::new();
if okay { if okay {
for (sstatehash, prev_event) in extremity_sstatehashes { let fork_states: Vec<_> = extremity_sstatehashes
let mut leaf_state = db .into_iter()
.rooms .map(|(sstatehash, prev_event)| {
.state_full_ids(sstatehash) let mut leaf_state = db
.map_err(|_| "Failed to ask db for room state.".to_owned())?;
if let Some(state_key) = &prev_event.state_key {
let shortstatekey = db
.rooms .rooms
.get_or_create_shortstatekey(&prev_event.kind, state_key, &db.globals) .state_full_ids(sstatehash)
.map_err(|_| "Failed to create shortstatekey.".to_owned())?; .map_err(|_| "Failed to ask db for room state.".to_owned())?;
leaf_state.insert(shortstatekey, Arc::new(prev_event.event_id.clone()));
// Now it's the state after the pdu if let Some(state_key) = &prev_event.state_key {
} let shortstatekey = db
.rooms
fork_states.push(leaf_state); .get_or_create_shortstatekey(&prev_event.kind, state_key, &db.globals)
} .map_err(|_| "Failed to create shortstatekey.".to_owned())?;
leaf_state.insert(shortstatekey, Arc::new(prev_event.event_id.clone()));
// Now it's the state after the pdu
}
let fork_states = &fork_states leaf_state
.into_iter() .into_iter()
.map(|map| {
map.into_iter()
.map(|(k, id)| (db.rooms.get_statekey_from_short(k).map(|k| (k, id)))) .map(|(k, id)| (db.rooms.get_statekey_from_short(k).map(|k| (k, id))))
.collect::<Result<StateMap<_>>>() .collect::<Result<StateMap<_>>>()
.map_err(|_| "Failed to get_statekey_from_short.".to_owned())
}) })
.collect::<Result<Vec<_>>>() .collect::<StdResult<_, _>>()?;
.map_err(|_| "Failed to get_statekey_from_short.".to_owned())?;
let mut auth_chain_sets = Vec::new(); let mut auth_chain_sets = Vec::new();
for state in fork_states { for state in &fork_states {
auth_chain_sets.push( auth_chain_sets.push(
get_auth_chain( get_auth_chain(
&room_id, &room_id,

Loading…
Cancel
Save