mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-14 08:41:07 +00:00
Fix run_to_block functions (#2258)
This commit is contained in:
@@ -236,14 +236,14 @@ mod tests {
|
|||||||
while System::block_number() < to {
|
while System::block_number() < to {
|
||||||
let b = System::block_number();
|
let b = System::block_number();
|
||||||
Dmp::initializer_finalize();
|
Dmp::initializer_finalize();
|
||||||
|
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
||||||
|
Dmp::initializer_on_new_session(&Default::default());
|
||||||
|
}
|
||||||
System::on_finalize(b);
|
System::on_finalize(b);
|
||||||
|
|
||||||
System::on_initialize(b + 1);
|
System::on_initialize(b + 1);
|
||||||
System::set_block_number(b + 1);
|
System::set_block_number(b + 1);
|
||||||
|
|
||||||
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
|
||||||
Dmp::initializer_on_new_session(&Default::default());
|
|
||||||
}
|
|
||||||
Dmp::initializer_initialize(b + 1);
|
Dmp::initializer_initialize(b + 1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1101,17 +1101,17 @@ mod tests {
|
|||||||
Hrmp::initializer_finalize();
|
Hrmp::initializer_finalize();
|
||||||
Paras::initializer_finalize();
|
Paras::initializer_finalize();
|
||||||
|
|
||||||
System::on_finalize(b);
|
|
||||||
|
|
||||||
System::on_initialize(b + 1);
|
|
||||||
System::set_block_number(b + 1);
|
|
||||||
|
|
||||||
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
||||||
// NOTE: this is in initialization order.
|
// NOTE: this is in initialization order.
|
||||||
Paras::initializer_on_new_session(&Default::default());
|
Paras::initializer_on_new_session(&Default::default());
|
||||||
Hrmp::initializer_on_new_session(&Default::default());
|
Hrmp::initializer_on_new_session(&Default::default());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
System::on_finalize(b);
|
||||||
|
|
||||||
|
System::on_initialize(b + 1);
|
||||||
|
System::set_block_number(b + 1);
|
||||||
|
|
||||||
// NOTE: this is in initialization order.
|
// NOTE: this is in initialization order.
|
||||||
Paras::initializer_initialize(b + 1);
|
Paras::initializer_initialize(b + 1);
|
||||||
Hrmp::initializer_initialize(b + 1);
|
Hrmp::initializer_initialize(b + 1);
|
||||||
|
|||||||
@@ -1036,16 +1036,16 @@ mod tests {
|
|||||||
Inclusion::initializer_finalize();
|
Inclusion::initializer_finalize();
|
||||||
Paras::initializer_finalize();
|
Paras::initializer_finalize();
|
||||||
|
|
||||||
System::on_finalize(b);
|
|
||||||
|
|
||||||
System::on_initialize(b + 1);
|
|
||||||
System::set_block_number(b + 1);
|
|
||||||
|
|
||||||
if let Some(notification) = new_session(b + 1) {
|
if let Some(notification) = new_session(b + 1) {
|
||||||
Paras::initializer_on_new_session(¬ification);
|
Paras::initializer_on_new_session(¬ification);
|
||||||
Inclusion::initializer_on_new_session(¬ification);
|
Inclusion::initializer_on_new_session(¬ification);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
System::on_finalize(b);
|
||||||
|
|
||||||
|
System::on_initialize(b + 1);
|
||||||
|
System::set_block_number(b + 1);
|
||||||
|
|
||||||
Paras::initializer_initialize(b + 1);
|
Paras::initializer_initialize(b + 1);
|
||||||
Inclusion::initializer_initialize(b + 1);
|
Inclusion::initializer_initialize(b + 1);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -578,14 +578,14 @@ mod tests {
|
|||||||
while System::block_number() < to {
|
while System::block_number() < to {
|
||||||
let b = System::block_number();
|
let b = System::block_number();
|
||||||
Paras::initializer_finalize();
|
Paras::initializer_finalize();
|
||||||
|
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
||||||
|
Paras::initializer_on_new_session(&Default::default());
|
||||||
|
}
|
||||||
System::on_finalize(b);
|
System::on_finalize(b);
|
||||||
|
|
||||||
System::on_initialize(b + 1);
|
System::on_initialize(b + 1);
|
||||||
System::set_block_number(b + 1);
|
System::set_block_number(b + 1);
|
||||||
|
|
||||||
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
|
|
||||||
Paras::initializer_on_new_session(&Default::default());
|
|
||||||
}
|
|
||||||
Paras::initializer_initialize(b + 1);
|
Paras::initializer_initialize(b + 1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -1059,8 +1059,8 @@ mod tests {
|
|||||||
assert_eq!(<Paras as Store>::Heads::get(¶_id), Some(Default::default()));
|
assert_eq!(<Paras as Store>::Heads::get(¶_id), Some(Default::default()));
|
||||||
}
|
}
|
||||||
|
|
||||||
// run to block, with a session change at that block.
|
// run to block №4, with a session change at the end of the block 3.
|
||||||
run_to_block(3, Some(vec![3]));
|
run_to_block(4, Some(vec![4]));
|
||||||
|
|
||||||
// cleaning up the parachain should place the current parachain code
|
// cleaning up the parachain should place the current parachain code
|
||||||
// into the past code buffer & schedule cleanup.
|
// into the past code buffer & schedule cleanup.
|
||||||
|
|||||||
@@ -183,16 +183,16 @@ mod tests {
|
|||||||
SessionInfo::initializer_finalize();
|
SessionInfo::initializer_finalize();
|
||||||
Configuration::initializer_finalize();
|
Configuration::initializer_finalize();
|
||||||
|
|
||||||
System::on_finalize(b);
|
|
||||||
|
|
||||||
System::on_initialize(b + 1);
|
|
||||||
System::set_block_number(b + 1);
|
|
||||||
|
|
||||||
if let Some(notification) = new_session(b + 1) {
|
if let Some(notification) = new_session(b + 1) {
|
||||||
Configuration::initializer_on_new_session(¬ification.validators, ¬ification.queued);
|
Configuration::initializer_on_new_session(¬ification.validators, ¬ification.queued);
|
||||||
SessionInfo::initializer_on_new_session(¬ification);
|
SessionInfo::initializer_on_new_session(¬ification);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
System::on_finalize(b);
|
||||||
|
|
||||||
|
System::on_initialize(b + 1);
|
||||||
|
System::set_block_number(b + 1);
|
||||||
|
|
||||||
Configuration::initializer_initialize(b + 1);
|
Configuration::initializer_initialize(b + 1);
|
||||||
SessionInfo::initializer_initialize(b + 1);
|
SessionInfo::initializer_initialize(b + 1);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user