forked from paritytech/polkadot-sdk
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adds transfer token test (paritytech#964)
* adds transfer token test * assert agent id is the source * complete transfer token test --------- Co-authored-by: claravanstaden <Cats 4 life!> Co-authored-by: Alistair Singh <alistair.singh7@gmail.com>
- Loading branch information
1 parent
1ffd01e
commit 5ee2f71
Showing
4 changed files
with
150 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,117 @@ | ||
| use ethers::{ | ||
| providers::{Provider, Ws}, | ||
| types::Address, | ||
| }; | ||
| use std::{sync::Arc, time::Duration}; | ||
| use ethers::prelude::Middleware; | ||
| use snowbridge_smoketest::contracts::{i_gateway::IGateway, weth9::WETH9}; | ||
| use subxt::{ | ||
| tx::{PairSigner}, | ||
| OnlineClient, | ||
| }; | ||
| use snowbridge_smoketest::constants::{ASSET_HUB_WS_URL, ETHEREUM_API, GATEWAY_PROXY_CONTRACT, WETH_CONTRACT, ASSET_HUB_AGENT_ID}; | ||
| use sp_core::{sr25519::Pair, Pair as PairT}; | ||
| use snowbridge_smoketest::{ | ||
| contracts::weth9::{TransferFilter}, | ||
| parachains::{ | ||
| assethub::api::runtime_types::xcm::{ | ||
| v3::{ | ||
| junction::{Junction, NetworkId}, | ||
| junctions::Junctions, | ||
| multiasset::{AssetId, Fungibility, MultiAsset, MultiAssets}, | ||
| multilocation::MultiLocation, | ||
| }, | ||
| VersionedMultiAssets, VersionedMultiLocation, | ||
| }, | ||
| assethub::{self}, | ||
| }, | ||
| }; | ||
| use hex_literal::hex; | ||
| use assethub::api::bridge_transfer::calls::TransactionApi; | ||
| use futures::StreamExt; | ||
| use snowbridge_smoketest::helper::AssetHubConfig; | ||
|
|
||
| const DESTINATION_ADDRESS: [u8; 20] = hex!("44a57ee2f2FCcb85FDa2B0B18EBD0D8D2333700e"); | ||
|
|
||
| #[tokio::test] | ||
| async fn transfer_token() { | ||
| let ethereum_provider = Provider::<Ws>::connect(ETHEREUM_API) | ||
| .await | ||
| .unwrap() | ||
| .interval(Duration::from_millis(10u64)); | ||
|
|
||
|
|
||
| let ethereum_client = Arc::new(ethereum_provider); | ||
|
|
||
| let weth_addr: Address = WETH_CONTRACT.into(); | ||
| let weth = WETH9::new(weth_addr, ethereum_client.clone()); | ||
|
|
||
| let gateway = IGateway::new(GATEWAY_PROXY_CONTRACT, ethereum_client.clone()); | ||
| let agent_src = gateway.agent_of(ASSET_HUB_AGENT_ID) | ||
| .await | ||
| .expect("could not get agent address"); | ||
|
|
||
| let assethub: OnlineClient<AssetHubConfig> = | ||
| OnlineClient::from_url(ASSET_HUB_WS_URL).await.unwrap(); | ||
|
|
||
| let keypair: Pair = Pair::from_string("//Ferdie", None).expect("cannot create keypair"); | ||
|
|
||
| let signer: PairSigner<AssetHubConfig, _> = PairSigner::new(keypair); | ||
|
|
||
| let amount: u128 = 1_000_000_000; | ||
| let assets = VersionedMultiAssets::V3(MultiAssets(vec![MultiAsset { | ||
| id: AssetId::Concrete(MultiLocation { | ||
| parents: 2, | ||
| interior: Junctions::X3( | ||
| Junction::GlobalConsensus(NetworkId::Ethereum { chain_id: 15 }), | ||
| Junction::AccountKey20 { network: None, key: GATEWAY_PROXY_CONTRACT.into() }, | ||
| Junction::AccountKey20 { network: None, key: WETH_CONTRACT.into() }, | ||
| ), | ||
| }), | ||
| fun: Fungibility::Fungible(amount), | ||
| }])); | ||
|
|
||
| let destination = VersionedMultiLocation::V3(MultiLocation { | ||
| parents: 2, | ||
| interior: Junctions::X2( | ||
| Junction::GlobalConsensus(NetworkId::Ethereum { chain_id: 15 }), | ||
| Junction::AccountKey20 { network: None, key: DESTINATION_ADDRESS.into() }, | ||
| ), | ||
| }); | ||
|
|
||
| let bridge_transfer_call = TransactionApi.transfer_asset_via_bridge(assets, destination); | ||
|
|
||
| let result = assethub | ||
| .tx() | ||
| .sign_and_submit_then_watch_default(&bridge_transfer_call, &signer) | ||
| .await | ||
| .expect("send through call.") | ||
| .wait_for_finalized_success() | ||
| .await | ||
| .expect("call success"); | ||
|
|
||
| println!("bridge_transfer call issued at assethub block hash {:?}", result.block_hash()); | ||
|
|
||
| let wait_for_blocks = 50; | ||
| let mut stream = ethereum_client.subscribe_blocks().await.unwrap().take(wait_for_blocks); | ||
|
|
||
| let mut transfer_event_found = false; | ||
| while let Some(block) = stream.next().await { | ||
| println!("Polling ethereum block {:?} for transfer event", block.number.unwrap()); | ||
| if let Ok(transfers) = | ||
| weth.event::<TransferFilter>().at_block_hash(block.hash.unwrap()).query().await | ||
| { | ||
| for transfer in transfers { | ||
| println!("Transfer event found at ethereum block {:?}", block.number.unwrap()); | ||
| assert_eq!(transfer.src, agent_src.into()); | ||
| assert_eq!(transfer.dst, DESTINATION_ADDRESS.into()); | ||
| assert_eq!(transfer.wad, amount.into()); | ||
| transfer_event_found = true; | ||
| } | ||
| } | ||
| if transfer_event_found { | ||
| break; | ||
| } | ||
| } | ||
| assert!(transfer_event_found); | ||
| } |