mirror of
https://forgejo.ellis.link/continuwuation/continuwuity/
synced 2026-08-29 04:48:20 +00:00
fix: Friendly assertations
This commit is contained in:
@@ -96,6 +96,12 @@ pub(super) async fn fetch_state(
|
||||
})
|
||||
.collect()
|
||||
.await;
|
||||
assert_eq!(
|
||||
state_events.len(),
|
||||
res.pdu_ids.len(),
|
||||
"Failed to load all required state events despite allegedly knowing all of them \
|
||||
already",
|
||||
);
|
||||
} else {
|
||||
let total_count = res.pdu_ids.len();
|
||||
let missing_count = to_fetch.len();
|
||||
@@ -132,6 +138,11 @@ pub(super) async fn fetch_state(
|
||||
.await
|
||||
},
|
||||
};
|
||||
assert!(
|
||||
!fetched_state.is_empty(),
|
||||
"fetch_full_state or fetch_and_handle_missing_events returned empty state \
|
||||
map"
|
||||
);
|
||||
state_events.extend(fetched_state);
|
||||
} else {
|
||||
debug!(
|
||||
@@ -139,10 +150,14 @@ pub(super) async fn fetch_state(
|
||||
to_fetch = to_fetch.len(),
|
||||
"Fetching missing events for state from remote"
|
||||
);
|
||||
state_events.extend(
|
||||
self.fetch_and_handle_missing_events(origin, to_fetch, create_event, room_id)
|
||||
.await,
|
||||
let fetched_state = self
|
||||
.fetch_and_handle_missing_events(origin, to_fetch, create_event, room_id)
|
||||
.await;
|
||||
assert!(
|
||||
!fetched_state.is_empty(),
|
||||
"fetch_and_handle_missing_events returned empty state map"
|
||||
);
|
||||
state_events.extend(fetched_state);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user