From caf04b4431ae7dbfe61999340ecf7a810fbb5c9e Mon Sep 17 00:00:00 2001 From: NachoPal Date: Fri, 30 Jun 2023 13:40:33 +0200 Subject: [PATCH] forgot para_id --- xcm/xcm-emulator/src/lib.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/xcm/xcm-emulator/src/lib.rs b/xcm/xcm-emulator/src/lib.rs index 5a683f94023..9f1f4c1de38 100644 --- a/xcm/xcm-emulator/src/lib.rs +++ b/xcm/xcm-emulator/src/lib.rs @@ -780,6 +780,8 @@ macro_rules! decl_test_networks { while let Some((to_para_id, messages)) = $crate::DOWNWARD_MESSAGES.with(|b| b.borrow_mut().get_mut(stringify!($name)).unwrap().pop_front()) { $( + let para_id: u32 = <$parachain>::para_id().into(); + if $crate::PARA_IDS.with(|b| b.borrow_mut().get_mut(stringify!($name)).unwrap().contains(&to_para_id)) && para_id == to_para_id { let mut msg_dedup: Vec<(RelayChainBlockNumber, Vec)> = Vec::new(); for m in &messages { @@ -810,6 +812,8 @@ macro_rules! decl_test_networks { = $crate::HORIZONTAL_MESSAGES.with(|b| b.borrow_mut().get_mut(stringify!($name)).unwrap().pop_front()) { let iter = messages.iter().map(|(p, b, m)| (*p, *b, &m[..])).collect::>().into_iter(); $( + let para_id: u32 = <$parachain>::para_id().into(); + if $crate::PARA_IDS.with(|b| b.borrow_mut().get_mut(stringify!($name)).unwrap().contains(&to_para_id)) && para_id == to_para_id { <$parachain>::handle_xcmp_messages(iter.clone(), $crate::Weight::max_value()); }