pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-20 23:21:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Deposit XCM execution success and fail events. (#338)

Browse Source
This commit is contained in:
Shaun Wang
2021-02-23 21:27:47 +13:00
committed by GitHub
parent 2c771e2cae
commit f82489dbee
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cumulus/pallets/xcm-handler/src/lib.rs
+12 -10
View File
@@ -103,16 +103,17 @@ impl<T: Config> DownwardMessageHandler for Module<T> {
fn handle_downward_message(msg: InboundDownwardMessage) { fn handle_downward_message(msg: InboundDownwardMessage) {
let hash = msg.using_encoded(T::Hashing::hash); let hash = msg.using_encoded(T::Hashing::hash);
frame_support::debug::print!("Processing Downward XCM: {:?}", &hash); frame_support::debug::print!("Processing Downward XCM: {:?}", &hash);
match VersionedXcm::decode(&mut &msg.msg[..]).map(Xcm::try_from) { let event = match VersionedXcm::decode(&mut &msg.msg[..]).map(Xcm::try_from) {
Ok(Ok(xcm)) => { Ok(Ok(xcm)) => {
match T::XcmExecutor::execute_xcm(Junction::Parent.into(), xcm) { match T::XcmExecutor::execute_xcm(Junction::Parent.into(), xcm) {
Ok(..) => RawEvent::Success(hash), Ok(..) => RawEvent::Success(hash),
Err(e) => RawEvent::Fail(hash, e), Err(e) => RawEvent::Fail(hash, e),
}; }
} }
Ok(Err(..)) => Self::deposit_event(RawEvent::BadVersion(hash)), Ok(Err(..)) => RawEvent::BadVersion(hash),
Err(..) => Self::deposit_event(RawEvent::BadFormat(hash)), Err(..) => RawEvent::BadFormat(hash),
} };
Self::deposit_event(event);
} }
} }
@@ -120,7 +121,7 @@ impl<T: Config> HrmpMessageHandler for Module<T> {
fn handle_hrmp_message(sender: ParaId, msg: InboundHrmpMessage) { fn handle_hrmp_message(sender: ParaId, msg: InboundHrmpMessage) {
let hash = msg.using_encoded(T::Hashing::hash); let hash = msg.using_encoded(T::Hashing::hash);
frame_support::debug::print!("Processing HRMP XCM: {:?}", &hash); frame_support::debug::print!("Processing HRMP XCM: {:?}", &hash);
match VersionedXcm::decode(&mut &msg.data[..]).map(Xcm::try_from) { let event = match VersionedXcm::decode(&mut &msg.data[..]).map(Xcm::try_from) {
Ok(Ok(xcm)) => { Ok(Ok(xcm)) => {
let location = ( let location = (
Junction::Parent, Junction::Parent,
@@ -129,11 +130,12 @@ impl<T: Config> HrmpMessageHandler for Module<T> {
match T::XcmExecutor::execute_xcm(location.into(), xcm) { match T::XcmExecutor::execute_xcm(location.into(), xcm) {
Ok(..) => RawEvent::Success(hash), Ok(..) => RawEvent::Success(hash),
Err(e) => RawEvent::Fail(hash, e), Err(e) => RawEvent::Fail(hash, e),
}; }
} }
Ok(Err(..)) => Self::deposit_event(RawEvent::BadVersion(hash)), Ok(Err(..)) => RawEvent::BadVersion(hash),
Err(..) => Self::deposit_event(RawEvent::BadFormat(hash)), Err(..) => RawEvent::BadFormat(hash),
} };
Self::deposit_event(event);
} }
} }