Skip to content

Commit

Permalink
fix: clean up warnings
Browse files Browse the repository at this point in the history
  • Loading branch information
andygolay committed Oct 16, 2024
1 parent 461262a commit c69fc5a
Show file tree
Hide file tree
Showing 7 changed files with 17 additions and 36 deletions.
4 changes: 2 additions & 2 deletions protocol-units/bridge/integration-tests/src/utils.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#![allow(dead_code)]
use crate::{HarnessMvtClient, HarnessMvtClientFramework, MovementToEthCallArgs};
use crate::{HarnessMvtClient, HarnessMvtClientFramework};
use alloy::hex;
use anyhow::Result;
use aptos_sdk::{
Expand All @@ -12,7 +12,7 @@ use bridge_service::chains::movement::utils::{
};
use bridge_service::types::{Amount, AssetType, BridgeAddress, BridgeTransferDetails, HashLock};
use serde_json::Value;
use tracing::{debug, info};
use tracing::debug;

const FRAMEWORK_ADDRESS: AccountAddress = AccountAddress::new([
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ async fn test_bridge_transfer_eth_movement_happy_path() -> Result<(), anyhow::Er
)
.init();

let (eth_client_harness, mut mvt_client_harness, config) =
let (_eth_client_harness, mut mvt_client_harness, config) =
TestHarness::new_with_eth_and_movement().await?;

tracing::info!("Init initiator and counter part test account.");
Expand Down Expand Up @@ -126,7 +126,7 @@ async fn test_bridge_transfer_eth_movement_happy_path() -> Result<(), anyhow::Er

//send counter complete event.
tracing::info!("Call counterparty_complete_bridge_transfer on MVT.");
let tx = mvt_client_harness
mvt_client_harness
.counterparty_complete_bridge_transfer(
recipient_privkey,
bridge_tranfer_id,
Expand All @@ -148,7 +148,6 @@ async fn test_bridge_transfer_eth_movement_happy_path() -> Result<(), anyhow::Er
Ok(())
}

use aptos_sdk::crypto::ed25519::Ed25519PublicKey;
#[tokio::test]
async fn test_movement_event() -> Result<(), anyhow::Error> {
tracing_subscriber::fmt()
Expand Down
Original file line number Diff line number Diff line change
@@ -1,24 +1,18 @@
use alloy::{
primitives::{address, keccak256},
providers::Provider,
};
use alloy::primitives::{address, keccak256};
use anyhow::Result;
use aptos_sdk::types::account_address::AccountAddress;
use aptos_sdk::coin_client::CoinClient;
use aptos_types::PeerId;
use bridge_config::Config;
use bridge_integration_tests::utils as test_utils;
use bridge_integration_tests::EthToMovementCallArgs;
use bridge_integration_tests::HarnessMvtClient;
use bridge_integration_tests::{TestHarness, TestHarnessFramework};
use bridge_service::chains::{ethereum::types::EthAddress, movement::client_framework::MovementClientFramework};
use bridge_service::chains::{
bridge_contracts::{BridgeContract, BridgeContractEvent}, ethereum::types::EthHash, movement::{event_monitoring::MovementMonitoring, utils::MovementHash}
bridge_contracts::BridgeContract, ethereum::types::EthHash
};
use bridge_service::types::{
Amount, AssetType, BridgeAddress, BridgeTransferId, HashLock, HashLockPreImage,
};
use futures::StreamExt;
use tokio::time::{sleep, Duration};
use tokio::{self};
use tracing::info;
Expand All @@ -29,7 +23,7 @@ async fn test_movement_client_lock_transfer(
let _ = tracing_subscriber::fmt().with_max_level(tracing::Level::DEBUG).try_init();
MovementClientFramework::bridge_setup_scripts().await?;
let config: Config = Config::suzuka();
let (mut mvt_client_harness, config) = TestHarnessFramework::new_with_suzuka(config).await;
let (mut mvt_client_harness, _config) = TestHarnessFramework::new_with_suzuka(config).await;
let args = EthToMovementCallArgs::default();
let test_result = async {
let coin_client = CoinClient::new(&mvt_client_harness.rest_client);
Expand Down Expand Up @@ -82,7 +76,7 @@ async fn test_movement_client_complete_transfer(
let _ = tracing_subscriber::fmt().with_max_level(tracing::Level::DEBUG).try_init();
MovementClientFramework::bridge_setup_scripts().await?;
let config: Config = Config::suzuka();
let (mut mvt_client_harness, config) = TestHarnessFramework::new_with_suzuka(config).await;
let (mut mvt_client_harness, _config) = TestHarnessFramework::new_with_suzuka(config).await;
let args = EthToMovementCallArgs::default();
let test_result = async {
let coin_client = CoinClient::new(&mvt_client_harness.rest_client);
Expand Down Expand Up @@ -172,7 +166,7 @@ async fn test_movement_client_abort_transfer(
let _ = tracing_subscriber::fmt().with_max_level(tracing::Level::DEBUG).try_init();
MovementClientFramework::bridge_setup_scripts().await?;
let config: Config = Config::suzuka();
let (mut mvt_client_harness, config) = TestHarnessFramework::new_with_suzuka(config).await;
let (mut mvt_client_harness, _config) = TestHarnessFramework::new_with_suzuka(config).await;
let args = EthToMovementCallArgs::default();
let test_result = async {
let coin_client = CoinClient::new(&mvt_client_harness.rest_client);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,21 +1,17 @@
use alloy::primitives::keccak256;
use anyhow::Result;
use bridge_config::Config;
use bridge_integration_tests::utils;
use bridge_integration_tests::utils as test_utils;
use bridge_integration_tests::{MovementToEthCallArgs, TestHarness, TestHarnessFramework};
use bridge_service::chains::bridge_contracts::{BridgeContractError, BridgeContractEvent};
use bridge_integration_tests::{MovementToEthCallArgs, TestHarnessFramework};
use bridge_service::chains::movement::client_framework::MovementClientFramework;
use bridge_service::types::AssetType;
use bridge_service::{
chains::{
bridge_contracts::BridgeContract,
movement::{event_monitoring::MovementMonitoring, utils::MovementHash},
movement::utils::MovementHash,
},
types::{BridgeTransferId, HashLockPreImage},
};
use chrono::Utc;
use futures::StreamExt;
use tokio::time::{sleep, Duration};
use tokio::{self};
use tracing::info;
Expand All @@ -25,11 +21,10 @@ async fn test_movement_client_initiate_transfer() -> Result<(), anyhow::Error> {
let _ = tracing_subscriber::fmt().with_max_level(tracing::Level::DEBUG).try_init();
MovementClientFramework::bridge_setup_scripts().await?;
let config: Config = Config::suzuka();
let (mut mvt_client_harness, config) = TestHarnessFramework::new_with_suzuka(config).await;
let (mut mvt_client_harness, _config) = TestHarnessFramework::new_with_suzuka(config).await;
let args = MovementToEthCallArgs::default();

let test_result = async {
let sender_address = mvt_client_harness.movement_client.signer().address();
test_utils::fund_and_check_balance_framework(&mut mvt_client_harness, 100_000_000_000)
.await?;
test_utils::initiate_bridge_transfer_helper_framework(
Expand Down Expand Up @@ -170,12 +165,11 @@ async fn test_movement_client_refund_transfer() -> Result<(), anyhow::Error> {

let config: Config = Config::suzuka();

let (mut mvt_client_harness, config) = TestHarnessFramework::new_with_suzuka(config).await;
let (mut mvt_client_harness, _config) = TestHarnessFramework::new_with_suzuka(config).await;

let args = MovementToEthCallArgs::default();

let test_result = async {
let sender_address = mvt_client_harness.movement_client.signer().address();
test_utils::fund_and_check_balance_framework(&mut mvt_client_harness, 100_000_000_000)
.await?;
test_utils::initiate_bridge_transfer_helper_framework(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ use super::utils::{calculate_storage_slot, send_transaction, send_transaction_ru
use crate::chains::bridge_contracts::BridgeContractError;
use crate::chains::bridge_contracts::BridgeContractResult;
use crate::types::{
Amount, AssetType, BridgeAddress, BridgeTransferDetails, BridgeTransferDetailsCounterparty, BridgeTransferId, HashLock, HashLockPreImage, LockDetails, TimeLock
Amount, AssetType, BridgeAddress, BridgeTransferDetails, BridgeTransferDetailsCounterparty, BridgeTransferId, HashLock, HashLockPreImage, TimeLock
};
use alloy::primitives::{Address, FixedBytes, U256};
use alloy::providers::{Provider, ProviderBuilder};
Expand Down
8 changes: 2 additions & 6 deletions protocol-units/bridge/service/src/chains/movement/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -466,12 +466,8 @@ impl BridgeContract<MovementAddress> for MovementClient {
}
}

use std::{
env, fs,
io::Write,
path::PathBuf,
process::{Command, Stdio},
};
use std::process::Stdio;

use tokio::{
io::{AsyncBufReadExt, BufReader},
process::Command as TokioCommand,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,11 @@ use super::utils::{self, MovementAddress};
use crate::chains::bridge_contracts::BridgeContract;
use crate::chains::bridge_contracts::BridgeContractError;
use crate::chains::bridge_contracts::BridgeContractResult;
use crate::chains::ethereum::types::EthAddress;
use crate::types::BridgeTransferDetailsCounterparty;
use crate::types::{
Amount, AssetType, BridgeAddress, BridgeTransferDetails, LockDetails, BridgeTransferId, HashLock,
Amount, AssetType, BridgeAddress, BridgeTransferDetails, BridgeTransferId, HashLock,
HashLockPreImage, TimeLock,
};
use alloy::primitives::Address;
use anyhow::{Context, Result};
use aptos_api_types::{EntryFunctionId, MoveModuleId, ViewRequest};
use aptos_sdk::{
Expand Down

0 comments on commit c69fc5a

Please sign in to comment.