logos-blockchain/logos-execution-zone
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-execution-zone.git synced 2026-08-26 20:01:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(sequencer): sort inside recorded_keys instead of a helper

Browse Source
This commit is contained in:
moudyellaz
2026-08-16 22:26:41 +02:00
parent dc2d8ac93f
commit 54c834a16c
1 changed files with 32 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lez/sequencer/core/src/cross_zone_watcher.rs
+32 -43
View File
@@ -793,17 +793,12 @@ mod tests {
/// The message keys recorded so far, sorted: the store keys each record by
/// its message key, so no insertion order survives.
fn recorded_keys(dbio: &RocksDBIO) -> Vec<[u8; 32]> {
sorted(
dbio.get_pending_cross_zone_dispatches()
.expect("pending dispatches readable")
.into_iter()
.map(|record| record.message_key)
.collect(),
)
}
/// `keys` as [`recorded_keys`] reports them.
fn sorted(mut keys: Vec<[u8; 32]>) -> Vec<[u8; 32]> {
let mut keys: Vec<[u8; 32]> = dbio
.get_pending_cross_zone_dispatches()
.expect("pending dispatches readable")
.into_iter()
.map(|record| record.message_key)
.collect();
keys.sort_unstable();
keys
}
@@ -1076,13 +1071,9 @@ mod tests {
Some(Slot::from(1)),
"the cursor must be durable, not just in memory"
);
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0)
])
);
let mut expected = vec![message_key(&PEER_ZONE, 1, 0), message_key(&PEER_ZONE, 2, 0)];
expected.sort_unstable();
assert_eq!(recorded_keys(&dbio), expected);
}
#[tokio::test]
@@ -1297,13 +1288,15 @@ mod tests {
)
.await;
let mut expected = vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0),
message_key(&PEER_ZONE, 3, 0),
];
expected.sort_unstable();
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0),
message_key(&PEER_ZONE, 3, 0)
]),
expected,
"only the unread block is recorded on the second pass"
);
assert_eq!(
@@ -1437,13 +1430,15 @@ mod tests {
.await;
assert_eq!(outcome, PassOutcome::Drained);
let mut expected = vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0),
message_key(&PEER_ZONE, 3, 0),
];
expected.sort_unstable();
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0),
message_key(&PEER_ZONE, 3, 0)
]),
expected,
"the key the peer aimed to burn is never recorded, and nothing else is held up"
);
assert_eq!(tip, Some(tip_at(3)));
@@ -1476,12 +1471,11 @@ mod tests {
PassOutcome::Drained,
"a peer equivocating about its own chain is not this node's failure"
);
let mut expected = vec![message_key(&PEER_ZONE, 1, 0), message_key(&PEER_ZONE, 2, 0)];
expected.sort_unstable();
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0)
]),
expected,
"one delivery per id, whatever the peer publishes under it"
);
assert_eq!(tip, Some(tip_at(2)));
@@ -1510,12 +1504,11 @@ mod tests {
.await;
assert_eq!(outcome, PassOutcome::Drained);
let mut expected = vec![message_key(&PEER_ZONE, 1, 0), message_key(&PEER_ZONE, 2, 0)];
expected.sort_unstable();
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0)
]),
expected,
"the fork is passed over and the peer's own chain continues"
);
assert_eq!(tip, Some(tip_at(2)));
@@ -1572,13 +1565,9 @@ mod tests {
.await;
assert_eq!(outcome, PassOutcome::Drained);
assert_eq!(
recorded_keys(&dbio),
sorted(vec![
message_key(&PEER_ZONE, 1, 0),
message_key(&PEER_ZONE, 2, 0)
])
);
let mut expected = vec![message_key(&PEER_ZONE, 1, 0), message_key(&PEER_ZONE, 2, 0)];
expected.sort_unstable();
assert_eq!(recorded_keys(&dbio), expected);
assert_eq!(tip, Some(tip_at(2)));
}