Merge pull request #3455 from autonomys/transporter_emit_amount

Add transfer amount to outgoing and incoming Transporter Events

Author: vedhavyas

domains/pallets/messenger/src/tests.rs

@@ -882,6 +882,7 @@ fn initiate_transfer_on_chain(chain_a_ext: &mut TestExternalities) {
             pallet_transporter::Event::<chain_a::Runtime>::OutgoingTransferInitiated {
                 chain_id: chain_b::SelfChainId::get(),
                 message_id: (U256::zero(), U256::one()),
+                amount: 500,
             },
         ));
         chain_a::System::assert_has_event(chain_a::RuntimeEvent::Messenger(crate::Event::<
@@ -931,6 +932,7 @@ fn verify_transfer_on_chain(
             pallet_transporter::Event::<chain_b::Runtime>::IncomingTransferSuccessful {
                 chain_id: chain_a::SelfChainId::get(),
                 message_id: (U256::zero(), U256::one()),
+                amount: 500,
             },
         ));
         chain_b::System::assert_has_event(chain_b::RuntimeEvent::Messenger(crate::Event::<

domains/pallets/transporter/src/lib.rs

@@ -168,6 +168,8 @@ mod pallet {
             chain_id: ChainId,
             /// Id of the transfer.
             message_id: MessageIdOf<T>,
+            /// Amount transferred from this chain
+            amount: BalanceOf<T>,
         },
 
         /// Emits when a given outgoing transfer was failed on dst_chain.
@@ -194,6 +196,8 @@ mod pallet {
             chain_id: ChainId,
             /// Id of the transfer.
             message_id: MessageIdOf<T>,
+            /// Amount transferred to this chain.
+            amount: BalanceOf<T>,
         },
     }
 
@@ -273,6 +277,7 @@ mod pallet {
             Self::deposit_event(Event::<T>::OutgoingTransferInitiated {
                 chain_id: dst_chain_id,
                 message_id,
+                amount,
             });
 
             // if this is consensus chain, then note the transfer
@@ -592,6 +597,7 @@ impl<T: Config> Pallet<T> {
             Event::<T>::IncomingTransferSuccessful {
                 chain_id: src_chain_id,
                 message_id,
+                amount: req.amount,
             },
         ));
         Ok(vec![])

domains/pallets/transporter/src/tests.rs

@@ -59,6 +59,7 @@ fn test_initiate_transfer() {
             crate::Event::<MockRuntime>::OutgoingTransferInitiated {
                 chain_id: dst_chain_id,
                 message_id: MESSAGE_ID,
+                amount: 500,
             },
         ));
         assert_eq!(
@@ -113,6 +114,7 @@ fn initiate_transfer(dst_chain_id: ChainId, account: AccountId, amount: Balance)
         crate::Event::<MockRuntime>::OutgoingTransferInitiated {
             chain_id: dst_chain_id,
             message_id: MESSAGE_ID,
+            amount,
         },
     ));
 }