Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Allow Multiple Bridge Pallet Instances (paritytech#226)
Browse files Browse the repository at this point in the history
* Add Instance type parameter to pallet

* Sketch out what the runtime could look like

* Allow runtime to compile with multiple bridge pallets

* Cargo Fmt

* Allow an instance of a PoA chain to be used with currency-exchange

I specify that it's only _an instance_ instead of _instances_ since the currency-exchange
pallet does not support multiple instances itself. What this commit does is make it so
that the different instances of the PoA chains we currently have are compatible with the
currency-exchange pallet through the implementation of the PeerBlockchain trait.

* Add Instance type parameter to Currency Exchange pallet

* Wire up currency exchange intances in runtime

* Rust Fmt

* Show sccache

* Allow Eth pallet to use a default instance

* Use a default instance in Eth pallet tests

* Remove Rialto and Kovan feature flags

Through some discussions it has been decided that the `bridge-node` should, like
Substrate's `node-template`, be a showcase of the different pallets available in
a project. Because of this I've removed the feature flags for the Rialto and Kovan
networks in favour of having both of them included in the runtime.

* Update the chain_spec to use both Rialto and Kovan configs

* Update pallet level calls used by Substrate client

Allows the project to compile. However, it should be noted that in reality
we shouldn't be hardcoding the pallet we're calling.

* Allow currency-exchange pallet to use a default instance

* Support benchmarking an instance of the Eth pallet

* Update currency exchange benchmarks to work with instances

* Fix test helpers which now need a PoA instance

* Remove Actions for checking Rialto and Kovan features

* Add missing comments

* Update Runtime API string constants

* Add issue number for generic chain support in relay

* Add Runtime APIs for instances of the currency-exchange pallet

* Rust Fmt

Co-authored-by: Denis S. Soldatov aka General-Beck <[email protected]>
2 people authored and bkchr committed Apr 10, 2024
1 parent c4424e5 commit 30844b1
Showing 19 changed files with 360 additions and 251 deletions.
4 changes: 1 addition & 3 deletions bridges/bin/node/node/Cargo.toml
Original file line number Diff line number Diff line change
@@ -146,9 +146,7 @@ tag = 'v2.0.0-rc4'
git = "https://github.com/paritytech/substrate.git"

[features]
default = ["bridge-rialto"]
bridge-kovan = ["bridge-node-runtime/bridge-kovan"]
bridge-rialto = ["bridge-node-runtime/bridge-rialto"]
default = []
runtime-benchmarks = [
"bridge-node-runtime/runtime-benchmarks",
]
23 changes: 16 additions & 7 deletions bridges/bin/node/node/src/chain_spec.rs
Original file line number Diff line number Diff line change
@@ -15,8 +15,8 @@
// along with Parity Bridges Common. If not, see <http://www.gnu.org/licenses/>.

use bridge_node_runtime::{
AccountId, AuraConfig, BalancesConfig, BridgeEthPoAConfig, GenesisConfig, GrandpaConfig, SessionConfig,
SessionKeys, Signature, SudoConfig, SystemConfig, WASM_BINARY,
AccountId, AuraConfig, BalancesConfig, BridgeKovanConfig, BridgeRialtoConfig, GenesisConfig, GrandpaConfig,
SessionConfig, SessionKeys, Signature, SudoConfig, SystemConfig, WASM_BINARY,
};
use grandpa_primitives::AuthorityId as GrandpaId;
use sp_consensus_aura::sr25519::AuthorityId as AuraId;
@@ -152,7 +152,8 @@ fn testnet_genesis(
pallet_aura: Some(AuraConfig {
authorities: Vec::new(),
}),
pallet_bridge_eth_poa: load_bridge_config(),
pallet_bridge_eth_poa_Instance1: load_rialto_bridge_config(),
pallet_bridge_eth_poa_Instance2: load_kovan_bridge_config(),
pallet_grandpa: Some(GrandpaConfig {
authorities: Vec::new(),
}),
@@ -166,10 +167,18 @@ fn testnet_genesis(
}
}

fn load_bridge_config() -> Option<BridgeEthPoAConfig> {
Some(BridgeEthPoAConfig {
initial_header: bridge_node_runtime::bridge::genesis_header(),
fn load_rialto_bridge_config() -> Option<BridgeRialtoConfig> {
Some(BridgeRialtoConfig {
initial_header: bridge_node_runtime::rialto::genesis_header(),
initial_difficulty: 0.into(),
initial_validators: bridge_node_runtime::bridge::genesis_validators(),
initial_validators: bridge_node_runtime::rialto::genesis_validators(),
})
}

fn load_kovan_bridge_config() -> Option<BridgeKovanConfig> {
Some(BridgeKovanConfig {
initial_header: bridge_node_runtime::kovan::genesis_header(),
initial_difficulty: 0.into(),
initial_validators: bridge_node_runtime::kovan::genesis_validators(),
})
}
5 changes: 1 addition & 4 deletions bridges/bin/node/runtime/Cargo.toml
Original file line number Diff line number Diff line change
@@ -224,9 +224,7 @@ package = "substrate-wasm-builder-runner"
git = "https://github.com/paritytech/substrate/"

[features]
default = ["std", "bridge-rialto"]
bridge-kovan = []
bridge-rialto = []
default = ["std"]
std = [
"pallet-aura/std",
"pallet-balances/std",
@@ -268,5 +266,4 @@ runtime-benchmarks = [
"pallet-bridge-eth-poa/runtime-benchmarks",
"sp-bridge-eth-poa/test-helpers",
"sp-runtime/runtime-benchmarks",
"bridge-kovan",
]
26 changes: 3 additions & 23 deletions bridges/bin/node/runtime/src/exchange.rs
Original file line number Diff line number Diff line change
@@ -30,7 +30,6 @@
use codec::{Decode, Encode};
use frame_support::RuntimeDebug;
use hex_literal::hex;
use pallet_bridge_currency_exchange::Blockchain;
use sp_bridge_eth_poa::{transaction_decode, RawTransaction};
use sp_currency_exchange::{
Error as ExchangeError, LockFundsTransaction, MaybeLockFundsTransaction, Result as ExchangeResult,
@@ -65,25 +64,6 @@ pub struct EthereumTransactionTag {
pub nonce: sp_core::U256,
}

/// Eth blockchain from runtime perspective.
pub struct EthBlockchain;

impl Blockchain for EthBlockchain {
type Transaction = RawTransaction;
type TransactionInclusionProof = EthereumTransactionInclusionProof;

fn verify_transaction_inclusion_proof(proof: &Self::TransactionInclusionProof) -> Option<Self::Transaction> {
let is_transaction_finalized =
crate::BridgeEthPoA::verify_transaction_finalized(proof.block, proof.index, &proof.proof);

if !is_transaction_finalized {
return None;
}

proof.proof.get(proof.index as usize).cloned()
}
}

/// Eth transaction from runtime perspective.
pub struct EthTransaction;

@@ -147,7 +127,7 @@ impl MaybeLockFundsTransaction for EthTransaction {

/// Prepares everything required to bench claim of funds locked by given transaction.
#[cfg(feature = "runtime-benchmarks")]
pub(crate) fn prepare_environment_for_claim<T: pallet_bridge_eth_poa::Trait>(
pub(crate) fn prepare_environment_for_claim<T: pallet_bridge_eth_poa::Trait<I>, I: pallet_bridge_eth_poa::Instance>(
transactions: &[RawTransaction],
) -> sp_bridge_eth_poa::H256 {
use pallet_bridge_eth_poa::{
@@ -156,8 +136,8 @@ pub(crate) fn prepare_environment_for_claim<T: pallet_bridge_eth_poa::Trait>(
};
use sp_bridge_eth_poa::compute_merkle_root;

let mut storage = BridgeStorage::<T>::new();
let header = HeaderBuilder::with_parent_number_on_runtime::<T>(0)
let mut storage = BridgeStorage::<T, I>::new();
let header = HeaderBuilder::with_parent_number_on_runtime::<T, I>(0)
.with_transactions_root(compute_merkle_root(transactions.iter()))
.sign_by(&validator(0));
let header_id = header.compute_id();
24 changes: 23 additions & 1 deletion bridges/bin/node/runtime/src/kovan.rs
Original file line number Diff line number Diff line change
@@ -14,12 +14,15 @@
// You should have received a copy of the GNU General Public License
// along with Parity Bridges Common. If not, see <http://www.gnu.org/licenses/>.

use crate::exchange::EthereumTransactionInclusionProof;

use frame_support::RuntimeDebug;
use hex_literal::hex;
use pallet_bridge_currency_exchange::PeerBlockchain;
use pallet_bridge_eth_poa::{
AuraConfiguration, PruningStrategy as BridgePruningStrategy, ValidatorsConfiguration, ValidatorsSource,
};
use sp_bridge_eth_poa::{Address, Header, U256};
use sp_bridge_eth_poa::{Address, Header, RawTransaction, U256};
use sp_std::prelude::*;

frame_support::parameter_types! {
@@ -131,6 +134,25 @@ impl BridgePruningStrategy for PruningStrategy {
}
}

/// The Kovan Blockchain as seen by the runtime.
pub struct KovanBlockchain;

impl PeerBlockchain for KovanBlockchain {
type Transaction = RawTransaction;
type TransactionInclusionProof = EthereumTransactionInclusionProof;

fn verify_transaction_inclusion_proof(proof: &Self::TransactionInclusionProof) -> Option<Self::Transaction> {
let is_transaction_finalized =
crate::BridgeKovan::verify_transaction_finalized(proof.block, proof.index, &proof.proof);

if !is_transaction_finalized {
return None;
}

proof.proof.get(proof.index as usize).cloned()
}
}

#[cfg(test)]
mod tests {
use super::*;
105 changes: 76 additions & 29 deletions bridges/bin/node/runtime/src/lib.rs
Original file line number Diff line number Diff line change
@@ -32,17 +32,11 @@ pub mod exchange;

#[cfg(feature = "runtime-benchmarks")]
pub mod benches;
#[cfg(feature = "bridge-kovan")]
pub mod kovan;
#[cfg(feature = "bridge-rialto")]
pub mod rialto;

#[cfg(feature = "runtime-benchmarks")]
pub use benches as bridge;
#[cfg(all(feature = "bridge-kovan", not(feature = "runtime-benchmarks")))]
pub use kovan as bridge;
#[cfg(all(feature = "bridge-rialto", not(feature = "runtime-benchmarks")))]
pub use rialto as bridge;

use codec::{Decode, Encode};
use pallet_grandpa::{fg_primitives, AuthorityId as GrandpaId, AuthorityList as GrandpaAuthorityList};
@@ -69,10 +63,12 @@ pub use frame_support::{
weights::{IdentityFee, RuntimeDbWeight, Weight},
StorageValue,
};

pub use pallet_balances::Call as BalancesCall;
pub use pallet_bridge_currency_exchange::Call as BridgeCurrencyExchangeCall;
pub use pallet_bridge_eth_poa::Call as BridgeEthPoACall;
pub use pallet_timestamp::Call as TimestampCall;

#[cfg(any(feature = "std", test))]
pub use sp_runtime::BuildStorage;
pub use sp_runtime::{Perbill, Permill};
@@ -233,17 +229,39 @@ impl pallet_aura::Trait for Runtime {
type AuthorityId = AuraId;
}

impl pallet_bridge_eth_poa::Trait for Runtime {
type AuraConfiguration = bridge::BridgeAuraConfiguration;
type FinalityVotesCachingInterval = bridge::FinalityVotesCachingInterval;
type ValidatorsConfiguration = bridge::BridgeValidatorsConfiguration;
type PruningStrategy = bridge::PruningStrategy;
type Rialto = pallet_bridge_eth_poa::Instance1;
impl pallet_bridge_eth_poa::Trait<Rialto> for Runtime {
type AuraConfiguration = rialto::BridgeAuraConfiguration;
type FinalityVotesCachingInterval = rialto::FinalityVotesCachingInterval;
type ValidatorsConfiguration = rialto::BridgeValidatorsConfiguration;
type PruningStrategy = rialto::PruningStrategy;
type OnHeadersSubmitted = ();
}

type Kovan = pallet_bridge_eth_poa::Instance2;
impl pallet_bridge_eth_poa::Trait<Kovan> for Runtime {
type AuraConfiguration = kovan::BridgeAuraConfiguration;
type FinalityVotesCachingInterval = kovan::FinalityVotesCachingInterval;
type ValidatorsConfiguration = kovan::BridgeValidatorsConfiguration;
type PruningStrategy = kovan::PruningStrategy;
type OnHeadersSubmitted = ();
}

impl pallet_bridge_currency_exchange::Trait for Runtime {
type RialtoCurrencyExchange = pallet_bridge_currency_exchange::Instance1;
impl pallet_bridge_currency_exchange::Trait<RialtoCurrencyExchange> for Runtime {
type OnTransactionSubmitted = ();
type PeerBlockchain = exchange::EthBlockchain;
type PeerBlockchain = rialto::RialtoBlockchain;
type PeerMaybeLockFundsTransaction = exchange::EthTransaction;
type RecipientsMap = sp_currency_exchange::IdentityRecipients<AccountId>;
type Amount = Balance;
type CurrencyConverter = sp_currency_exchange::IdentityCurrencyConverter<Balance>;
type DepositInto = DepositInto;
}

type KovanCurrencyExchange = pallet_bridge_currency_exchange::Instance2;
impl pallet_bridge_currency_exchange::Trait<KovanCurrencyExchange> for Runtime {
type OnTransactionSubmitted = ();
type PeerBlockchain = kovan::KovanBlockchain;
type PeerMaybeLockFundsTransaction = exchange::EthTransaction;
type RecipientsMap = sp_currency_exchange::IdentityRecipients<AccountId>;
type Amount = Balance;
@@ -439,6 +457,10 @@ construct_runtime!(
NodeBlock = opaque::Block,
UncheckedExtrinsic = UncheckedExtrinsic
{
BridgeRialto: pallet_bridge_eth_poa::<Instance1>::{Module, Call, Config, Storage, ValidateUnsigned},
BridgeKovan: pallet_bridge_eth_poa::<Instance2>::{Module, Call, Config, Storage, ValidateUnsigned},
BridgeRialtoCurrencyExchange: pallet_bridge_currency_exchange::<Instance1>::{Module, Call},
BridgeKovanCurrencyExchange: pallet_bridge_currency_exchange::<Instance2>::{Module, Call},
System: frame_system::{Module, Call, Config, Storage, Event<T>},
RandomnessCollectiveFlip: pallet_randomness_collective_flip::{Module, Call, Storage},
Timestamp: pallet_timestamp::{Module, Call, Storage, Inherent},
@@ -448,8 +470,6 @@ construct_runtime!(
TransactionPayment: pallet_transaction_payment::{Module, Storage},
Sudo: pallet_sudo::{Module, Call, Config<T>, Storage, Event<T>},
Session: pallet_session::{Module, Call, Storage, Event, Config<T>},
BridgeEthPoA: pallet_bridge_eth_poa::{Module, Call, Config, Storage, ValidateUnsigned},
BridgeCurrencyExchange: pallet_bridge_currency_exchange::{Module, Call},
}
);

@@ -535,32 +555,59 @@ impl_runtime_apis! {
}
}

impl sp_bridge_eth_poa::EthereumHeadersApi<Block> for Runtime {
impl sp_bridge_eth_poa::RialtoHeaderApi<Block> for Runtime {
fn best_block() -> (u64, sp_bridge_eth_poa::H256) {
let best_block = BridgeEthPoA::best_block();
let best_block = BridgeRialto::best_block();
(best_block.number, best_block.hash)
}

fn finalized_block() -> (u64, sp_bridge_eth_poa::H256) {
let finalized_block = BridgeEthPoA::finalized_block();
let finalized_block = BridgeRialto::finalized_block();
(finalized_block.number, finalized_block.hash)
}

fn is_import_requires_receipts(header: sp_bridge_eth_poa::Header) -> bool {
BridgeEthPoA::is_import_requires_receipts(header)
BridgeRialto::is_import_requires_receipts(header)
}

fn is_known_block(hash: sp_bridge_eth_poa::H256) -> bool {
BridgeEthPoA::is_known_block(hash)
BridgeRialto::is_known_block(hash)
}
}

impl sp_currency_exchange::CurrencyExchangeApi<Block, exchange::EthereumTransactionInclusionProof> for Runtime {
impl sp_bridge_eth_poa::KovanHeaderApi<Block> for Runtime {
fn best_block() -> (u64, sp_bridge_eth_poa::H256) {
let best_block = BridgeKovan::best_block();
(best_block.number, best_block.hash)
}

fn finalized_block() -> (u64, sp_bridge_eth_poa::H256) {
let finalized_block = BridgeKovan::finalized_block();
(finalized_block.number, finalized_block.hash)
}

fn is_import_requires_receipts(header: sp_bridge_eth_poa::Header) -> bool {
BridgeKovan::is_import_requires_receipts(header)
}

fn is_known_block(hash: sp_bridge_eth_poa::H256) -> bool {
BridgeKovan::is_known_block(hash)
}
}

impl sp_currency_exchange::RialtoCurrencyExchangeApi<Block, exchange::EthereumTransactionInclusionProof> for Runtime {
fn filter_transaction_proof(proof: exchange::EthereumTransactionInclusionProof) -> bool {
BridgeRialtoCurrencyExchange::filter_transaction_proof(&proof)
}
}

impl sp_currency_exchange::KovanCurrencyExchangeApi<Block, exchange::EthereumTransactionInclusionProof> for Runtime {
fn filter_transaction_proof(proof: exchange::EthereumTransactionInclusionProof) -> bool {
BridgeCurrencyExchange::filter_transaction_proof(&proof)
BridgeKovanCurrencyExchange::filter_transaction_proof(&proof)
}
}


impl sp_transaction_pool::runtime_api::TaggedTransactionQueue<Block> for Runtime {
fn validate_transaction(
source: TransactionSource,
@@ -656,14 +703,14 @@ impl_runtime_apis! {
ProofParams as BridgeCurrencyExchangeProofParams,
};

impl BridgeCurrencyExchangeTrait for Runtime {
impl BridgeCurrencyExchangeTrait<KovanCurrencyExchange> for Runtime {
fn make_proof(
proof_params: BridgeCurrencyExchangeProofParams<AccountId>,
) -> crate::exchange::EthereumTransactionInclusionProof {
use sp_currency_exchange::DepositInto;

if proof_params.recipient_exists {
<Runtime as pallet_bridge_currency_exchange::Trait>::DepositInto::deposit_into(
<Runtime as pallet_bridge_currency_exchange::Trait<KovanCurrencyExchange>>::DepositInto::deposit_into(
proof_params.recipient.clone(),
ExistentialDeposit::get(),
).unwrap();
@@ -681,7 +728,7 @@ impl_runtime_apis! {
let transactions = sp_std::iter::repeat(transaction.clone())
.take(1 + proof_params.proof_size_factor as usize)
.collect::<Vec<_>>();
let block_hash = crate::exchange::prepare_environment_for_claim::<Runtime>(&transactions);
let block_hash = crate::exchange::prepare_environment_for_claim::<Runtime, Kovan>(&transactions);
crate::exchange::EthereumTransactionInclusionProof {
block: block_hash,
index: 0,
@@ -690,8 +737,8 @@ impl_runtime_apis! {
}
}

add_benchmark!(params, batches, b"bridge-eth-poa", BridgeEthPoA);
add_benchmark!(params, batches, b"bridge-currency-exchange", BridgeCurrencyExchangeBench::<Runtime>);
add_benchmark!(params, batches, b"bridge-eth-poa", BridgeKovan);
add_benchmark!(params, batches, b"bridge-currency-exchange", BridgeCurrencyExchangeBench::<Runtime, KovanCurrencyExchange>);

if batches.is_empty() { return Err("Benchmark not found for this pallet.".into()) }
Ok(batches)
@@ -785,7 +832,7 @@ mod tests {
let initial_amount =
<pallet_balances::Module<Runtime> as Currency<AccountId>>::free_balance(&existing_account);
let additional_amount = 10_000;
<Runtime as pallet_bridge_currency_exchange::Trait>::DepositInto::deposit_into(
<Runtime as pallet_bridge_currency_exchange::Trait<KovanCurrencyExchange>>::DepositInto::deposit_into(
existing_account.clone(),
additional_amount,
)
@@ -804,7 +851,7 @@ mod tests {
let initial_amount = 0;
let additional_amount = ExistentialDeposit::get() + 10_000;
let new_account: AccountId = [42u8; 32].into();
<Runtime as pallet_bridge_currency_exchange::Trait>::DepositInto::deposit_into(
<Runtime as pallet_bridge_currency_exchange::Trait<KovanCurrencyExchange>>::DepositInto::deposit_into(
new_account.clone(),
additional_amount,
)
24 changes: 23 additions & 1 deletion bridges/bin/node/runtime/src/rialto.rs
Original file line number Diff line number Diff line change
@@ -14,12 +14,15 @@
// You should have received a copy of the GNU General Public License
// along with Parity Bridges Common. If not, see <http://www.gnu.org/licenses/>.

use crate::exchange::EthereumTransactionInclusionProof;

use frame_support::RuntimeDebug;
use hex_literal::hex;
use pallet_bridge_currency_exchange::PeerBlockchain;
use pallet_bridge_eth_poa::{
AuraConfiguration, PruningStrategy as TPruningStrategy, ValidatorsConfiguration, ValidatorsSource,
};
use sp_bridge_eth_poa::{Address, Header, U256};
use sp_bridge_eth_poa::{Address, Header, RawTransaction, U256};
use sp_std::prelude::*;

frame_support::parameter_types! {
@@ -104,6 +107,25 @@ impl TPruningStrategy for PruningStrategy {
}
}

/// The Rialto Blockchain as seen by the runtime.
pub struct RialtoBlockchain;

impl PeerBlockchain for RialtoBlockchain {
type Transaction = RawTransaction;
type TransactionInclusionProof = EthereumTransactionInclusionProof;

fn verify_transaction_inclusion_proof(proof: &Self::TransactionInclusionProof) -> Option<Self::Transaction> {
let is_transaction_finalized =
crate::BridgeRialto::verify_transaction_finalized(proof.block, proof.index, &proof.proof);

if !is_transaction_finalized {
return None;
}

proof.proof.get(proof.index as usize).cloned()
}
}

#[cfg(test)]
mod tests {
use super::*;
12 changes: 6 additions & 6 deletions bridges/modules/currency-exchange/src/benchmarking.rs
Original file line number Diff line number Diff line change
@@ -18,18 +18,18 @@
//! So we are giving runtime opportunity to prepare environment and construct proof
//! before invoking module calls.
use super::{Blockchain, Call, Module as CurrencyExchangeModule, Trait as CurrencyExchangeTrait};
use super::{Call, Instance, Module as CurrencyExchangeModule, PeerBlockchain, Trait as CurrencyExchangeTrait};
use sp_std::prelude::*;

use frame_benchmarking::{account, benchmarks};
use frame_benchmarking::{account, benchmarks_instance};
use frame_system::RawOrigin;

const SEED: u32 = 0;
const WORST_TX_SIZE_FACTOR: u32 = 1000;
const WORST_PROOF_SIZE_FACTOR: u32 = 1000;

/// Module we're benchmarking here.
pub struct Module<T: Trait>(CurrencyExchangeModule<T>);
pub struct Module<T: Trait<I>, I: Instance>(CurrencyExchangeModule<T, I>);

/// Proof benchmarking parameters.
pub struct ProofParams<Recipient> {
@@ -46,14 +46,14 @@ pub struct ProofParams<Recipient> {
}

/// Trait that must be implemented by runtime.
pub trait Trait: CurrencyExchangeTrait {
pub trait Trait<I: Instance>: CurrencyExchangeTrait<I> {
/// Prepare proof for importing exchange transaction.
fn make_proof(
proof_params: ProofParams<Self::AccountId>,
) -> <<Self as CurrencyExchangeTrait>::PeerBlockchain as Blockchain>::TransactionInclusionProof;
) -> <<Self as CurrencyExchangeTrait<I>>::PeerBlockchain as PeerBlockchain>::TransactionInclusionProof;
}

benchmarks! {
benchmarks_instance! {
_ { }

// Benchmark `import_peer_transaction` extrinsic with the best possible conditions:
74 changes: 39 additions & 35 deletions bridges/modules/currency-exchange/src/lib.rs
Original file line number Diff line number Diff line change
@@ -33,8 +33,8 @@ pub trait OnTransactionSubmitted<AccountId> {
fn on_valid_transaction_submitted(submitter: AccountId);
}

/// Peer blockhain interface.
pub trait Blockchain {
/// Peer blockchain interface.
pub trait PeerBlockchain {
/// Transaction type.
type Transaction: Parameter;
/// Transaction inclusion proof type.
@@ -47,14 +47,14 @@ pub trait Blockchain {
}

/// The module configuration trait
pub trait Trait: frame_system::Trait {
pub trait Trait<I = DefaultInstance>: frame_system::Trait {
/// Handler for transaction submission result.
type OnTransactionSubmitted: OnTransactionSubmitted<Self::AccountId>;
/// Peer blockchain type.
type PeerBlockchain: Blockchain;
/// Represents the blockchain that we'll be exchanging currency with.
type PeerBlockchain: PeerBlockchain;
/// Peer blockchain transaction parser.
type PeerMaybeLockFundsTransaction: MaybeLockFundsTransaction<
Transaction = <Self::PeerBlockchain as Blockchain>::Transaction,
Transaction = <Self::PeerBlockchain as PeerBlockchain>::Transaction,
>;
/// Map between blockchains recipients.
type RecipientsMap: RecipientsMap<
@@ -73,7 +73,7 @@ pub trait Trait: frame_system::Trait {
}

decl_error! {
pub enum Error for Module<T: Trait> {
pub enum Error for Module<T: Trait<I>, I: Instance> {
/// Invalid peer blockchain transaction provided.
InvalidTransaction,
/// Peer transaction has invalid amount.
@@ -96,17 +96,17 @@ decl_error! {
}

decl_module! {
pub struct Module<T: Trait> for enum Call where origin: T::Origin {
pub struct Module<T: Trait<I>, I: Instance = DefaultInstance> for enum Call where origin: T::Origin {
/// Imports lock fund transaction of the peer blockchain.
#[weight = 0] // TODO: update me (https://github.com/paritytech/parity-bridges-common/issues/78)
pub fn import_peer_transaction(
origin,
proof: <<T as Trait>::PeerBlockchain as Blockchain>::TransactionInclusionProof,
proof: <<T as Trait<I>>::PeerBlockchain as PeerBlockchain>::TransactionInclusionProof,
) -> DispatchResult {
let submitter = frame_system::ensure_signed(origin)?;

// verify and parse transaction proof
let deposit = prepare_deposit_details::<T>(&proof)?;
let deposit = prepare_deposit_details::<T, I>(&proof)?;

// make sure to update the mapping if we deposit successfully to avoid double spending,
// i.e. whenever `deposit_into` is successful we MUST update `Transfers`.
@@ -117,9 +117,9 @@ decl_module! {
match deposit_result {
Ok(_) => (),
Err(ExchangeError::DepositPartiallyFailed) => (),
Err(error) => return Err(Error::<T>::from(error).into()),
Err(error) => return Err(Error::<T, I>::from(error).into()),
}
Transfers::<T>::insert(&deposit.transfer_id, ())
Transfers::<T, I>::insert(&deposit.transfer_id, ())
}

// reward submitter for providing valid message
@@ -137,25 +137,25 @@ decl_module! {
}

decl_storage! {
trait Store for Module<T: Trait> as Bridge {
trait Store for Module<T: Trait<I>, I: Instance = DefaultInstance> as Bridge {
/// All transfers that have already been claimed.
Transfers: map hasher(blake2_128_concat) <T::PeerMaybeLockFundsTransaction as MaybeLockFundsTransaction>::Id => ();
}
}

impl<T: Trait> Module<T> {
impl<T: Trait<I>, I: Instance> Module<T, I> {
/// Returns true if currency exchange module is able to import given transaction proof in
/// its current state.
pub fn filter_transaction_proof(proof: &<T::PeerBlockchain as Blockchain>::TransactionInclusionProof) -> bool {
if prepare_deposit_details::<T>(proof).is_err() {
pub fn filter_transaction_proof(proof: &<T::PeerBlockchain as PeerBlockchain>::TransactionInclusionProof) -> bool {
if prepare_deposit_details::<T, I>(proof).is_err() {
return false;
}

true
}
}

impl<T: Trait> From<ExchangeError> for Error<T> {
impl<T: Trait<I>, I: Instance> From<ExchangeError> for Error<T, I> {
fn from(error: ExchangeError) -> Self {
match error {
ExchangeError::InvalidTransaction => Error::InvalidTransaction,
@@ -174,7 +174,7 @@ impl<AccountId> OnTransactionSubmitted<AccountId> for () {
}

/// Exchange deposit details.
struct DepositDetails<T: Trait> {
struct DepositDetails<T: Trait<I>, I: Instance> {
/// Transfer id.
pub transfer_id: <T::PeerMaybeLockFundsTransaction as MaybeLockFundsTransaction>::Id,
/// Transfer recipient.
@@ -185,21 +185,25 @@ struct DepositDetails<T: Trait> {

/// Verify and parse transaction proof, preparing everything required for importing
/// this transaction proof.
fn prepare_deposit_details<T: Trait>(
proof: &<<T as Trait>::PeerBlockchain as Blockchain>::TransactionInclusionProof,
) -> Result<DepositDetails<T>, Error<T>> {
fn prepare_deposit_details<T: Trait<I>, I: Instance>(
proof: &<<T as Trait<I>>::PeerBlockchain as PeerBlockchain>::TransactionInclusionProof,
) -> Result<DepositDetails<T, I>, Error<T, I>> {
// ensure that transaction is included in finalized block that we know of
let transaction = <T as Trait>::PeerBlockchain::verify_transaction_inclusion_proof(proof)
.ok_or_else(|| Error::<T>::UnfinalizedTransaction)?;
let transaction = <T as Trait<I>>::PeerBlockchain::verify_transaction_inclusion_proof(proof)
.ok_or_else(|| Error::<T, I>::UnfinalizedTransaction)?;

// parse transaction
let transaction = <T as Trait>::PeerMaybeLockFundsTransaction::parse(&transaction).map_err(Error::<T>::from)?;
let transaction =
<T as Trait<I>>::PeerMaybeLockFundsTransaction::parse(&transaction).map_err(Error::<T, I>::from)?;
let transfer_id = transaction.id;
ensure!(!Transfers::<T>::contains_key(&transfer_id), Error::<T>::AlreadyClaimed);
ensure!(
!Transfers::<T, I>::contains_key(&transfer_id),
Error::<T, I>::AlreadyClaimed
);

// grant recipient
let recipient = T::RecipientsMap::map(transaction.recipient).map_err(Error::<T>::from)?;
let amount = T::CurrencyConverter::convert(transaction.amount).map_err(Error::<T>::from)?;
let recipient = T::RecipientsMap::map(transaction.recipient).map_err(Error::<T, I>::from)?;
let amount = T::CurrencyConverter::convert(transaction.amount).map_err(Error::<T, I>::from)?;

Ok(DepositDetails {
transfer_id,
@@ -235,13 +239,13 @@ mod tests {

impl OnTransactionSubmitted<AccountId> for DummyTransactionSubmissionHandler {
fn on_valid_transaction_submitted(submitter: AccountId) {
Transfers::<TestRuntime>::insert(submitter, ());
Transfers::<TestRuntime, DefaultInstance>::insert(submitter, ());
}
}

pub struct DummyBlockchain;

impl Blockchain for DummyBlockchain {
impl PeerBlockchain for DummyBlockchain {
type Transaction = RawTransaction;
type TransactionInclusionProof = (bool, RawTransaction);

@@ -386,7 +390,7 @@ mod tests {
new_test_ext().execute_with(|| {
assert_noop!(
Exchange::import_peer_transaction(Origin::signed(SUBMITTER), (false, transaction(0))),
Error::<TestRuntime>::UnfinalizedTransaction,
Error::<TestRuntime, DefaultInstance>::UnfinalizedTransaction,
);
});
}
@@ -399,7 +403,7 @@ mod tests {
Origin::signed(SUBMITTER),
(true, transaction(INVALID_TRANSACTION_ID)),
),
Error::<TestRuntime>::InvalidTransaction,
Error::<TestRuntime, DefaultInstance>::InvalidTransaction,
);
});
}
@@ -413,7 +417,7 @@ mod tests {
Origin::signed(SUBMITTER),
(true, transaction(ALREADY_CLAIMED_TRANSACTION_ID)),
),
Error::<TestRuntime>::AlreadyClaimed,
Error::<TestRuntime, DefaultInstance>::AlreadyClaimed,
);
});
}
@@ -425,7 +429,7 @@ mod tests {
transaction.recipient = UNKNOWN_RECIPIENT_ID;
assert_noop!(
Exchange::import_peer_transaction(Origin::signed(SUBMITTER), (true, transaction)),
Error::<TestRuntime>::FailedToMapRecipients,
Error::<TestRuntime, DefaultInstance>::FailedToMapRecipients,
);
});
}
@@ -437,7 +441,7 @@ mod tests {
transaction.amount = INVALID_AMOUNT;
assert_noop!(
Exchange::import_peer_transaction(Origin::signed(SUBMITTER), (true, transaction)),
Error::<TestRuntime>::FailedToConvertCurrency,
Error::<TestRuntime, DefaultInstance>::FailedToConvertCurrency,
);
});
}
@@ -449,7 +453,7 @@ mod tests {
transaction.amount = MAX_DEPOSIT_AMOUNT + 1;
assert_noop!(
Exchange::import_peer_transaction(Origin::signed(SUBMITTER), (true, transaction)),
Error::<TestRuntime>::DepositFailed,
Error::<TestRuntime, DefaultInstance>::DepositFailed,
);
});
}
42 changes: 21 additions & 21 deletions bridges/modules/ethereum/src/benchmarking.rs
Original file line number Diff line number Diff line change
@@ -21,11 +21,11 @@ use crate::test_utils::{
HeaderBuilder,
};

use frame_benchmarking::benchmarks;
use frame_benchmarking::benchmarks_instance;
use frame_system::RawOrigin;
use primitives::{compute_merkle_root, U256};

benchmarks! {
benchmarks_instance! {
_ { }

// Benchmark `import_unsigned_header` extrinsic with the best possible conditions:
@@ -37,7 +37,7 @@ benchmarks! {
let n in 1..1000;

let num_validators = 2;
let initial_header = initialize_bench::<T>(num_validators);
let initial_header = initialize_bench::<T, I>(num_validators);

// prepare header to be inserted
let header = build_custom_header(
@@ -50,7 +50,7 @@ benchmarks! {
);
}: import_unsigned_header(RawOrigin::None, header, None)
verify {
let storage = BridgeStorage::<T>::new();
let storage = BridgeStorage::<T, I>::new();
assert_eq!(storage.best_block().0.number, 1);
assert_eq!(storage.finalized_block().number, 0);
}
@@ -67,9 +67,9 @@ benchmarks! {
// finalization.
let n in 1..7;

let mut storage = BridgeStorage::<T>::new();
let mut storage = BridgeStorage::<T, I>::new();
let num_validators: u32 = 2;
let initial_header = initialize_bench::<T>(num_validators as usize);
let initial_header = initialize_bench::<T, I>(num_validators as usize);

// Since we only have two validators we need to make sure the number of blocks is even to
// make sure the right validator signs the final block
@@ -95,7 +95,7 @@ benchmarks! {
let header = HeaderBuilder::with_parent(&last_header).sign_by(&last_authority);
}: import_unsigned_header(RawOrigin::None, header, None)
verify {
let storage = BridgeStorage::<T>::new();
let storage = BridgeStorage::<T, I>::new();
assert_eq!(storage.best_block().0.number, (num_blocks + 1) as u64);
assert_eq!(storage.finalized_block().number, num_blocks as u64);
}
@@ -108,9 +108,9 @@ benchmarks! {
// finalization.
let n in 7..100;

let mut storage = BridgeStorage::<T>::new();
let mut storage = BridgeStorage::<T, I>::new();
let num_validators: u32 = 2;
let initial_header = initialize_bench::<T>(num_validators as usize);
let initial_header = initialize_bench::<T, I>(num_validators as usize);

// Since we only have two validators we need to make sure the number of blocks is even to
// make sure the right validator signs the final block
@@ -136,7 +136,7 @@ benchmarks! {
let header = HeaderBuilder::with_parent(&last_header).sign_by(&last_authority);
}: import_unsigned_header(RawOrigin::None, header, None)
verify {
let storage = BridgeStorage::<T>::new();
let storage = BridgeStorage::<T, I>::new();
assert_eq!(storage.best_block().0.number, (num_blocks + 1) as u64);
assert_eq!(storage.finalized_block().number, num_blocks as u64);
}
@@ -148,14 +148,14 @@ benchmarks! {
import_unsigned_pruning {
let n in 1..MAX_BLOCKS_TO_PRUNE_IN_SINGLE_IMPORT as u32;

let mut storage = BridgeStorage::<T>::new();
let mut storage = BridgeStorage::<T, I>::new();

let num_validators = 3;
let initial_header = initialize_bench::<T>(num_validators as usize);
let initial_header = initialize_bench::<T, I>(num_validators as usize);
let validators = validators(num_validators);

// Want to prune eligible blocks between [0, n)
BlocksToPrune::put(PruningRange {
BlocksToPrune::<I>::put(PruningRange {
oldest_unpruned_block: 0,
oldest_block_to_keep: n as u64,
});
@@ -171,11 +171,11 @@ benchmarks! {
let header = HeaderBuilder::with_parent(&parent).sign_by_set(&validators);
}: import_unsigned_header(RawOrigin::None, header, None)
verify {
let storage = BridgeStorage::<T>::new();
let storage = BridgeStorage::<T, I>::new();
let max_pruned: u64 = (n - 1) as _;
assert_eq!(storage.best_block().0.number, (n + 1) as u64);
assert!(HeadersByNumber::get(&0).is_none());
assert!(HeadersByNumber::get(&max_pruned).is_none());
assert!(HeadersByNumber::<I>::get(&0).is_none());
assert!(HeadersByNumber::<I>::get(&max_pruned).is_none());
}

// The goal of this bench is to import a block which contains a transaction receipt. The receipt
@@ -184,10 +184,10 @@ benchmarks! {
import_unsigned_with_receipts {
let n in 1..100;

let mut storage = BridgeStorage::<T>::new();
let mut storage = BridgeStorage::<T, I>::new();

let num_validators = 1;
let initial_header = initialize_bench::<T>(num_validators as usize);
let initial_header = initialize_bench::<T, I>(num_validators as usize);

let mut receipts = vec![];
for i in 1..=n {
@@ -213,18 +213,18 @@ benchmarks! {
);
}: import_unsigned_header(RawOrigin::None, header, Some(receipts))
verify {
let storage = BridgeStorage::<T>::new();
let storage = BridgeStorage::<T, I>::new();
assert_eq!(storage.best_block().0.number, 2);
}
}

fn initialize_bench<T: Trait>(num_validators: usize) -> Header {
fn initialize_bench<T: Trait<I>, I: Instance>(num_validators: usize) -> Header {
// Initialize storage with some initial header
let initial_header = build_genesis_header(&validator(0));
let initial_difficulty = initial_header.difficulty;
let initial_validators = validators_addresses(num_validators as usize);

initialize_storage::<T>(&initial_header, initial_difficulty, &initial_validators);
initialize_storage::<T, I>(&initial_header, initial_difficulty, &initial_validators);

initial_header
}
5 changes: 3 additions & 2 deletions bridges/modules/ethereum/src/import.rs
Original file line number Diff line number Diff line change
@@ -169,6 +169,7 @@ mod tests {
validators_change_receipt, HeaderBuilder, KeepSomeHeadersBehindBest, TestRuntime, GAS_LIMIT,
};
use crate::validators::ValidatorsSource;
use crate::DefaultInstance;
use crate::{BlocksToPrune, BridgeStorage, Headers, PruningRange};
use frame_support::{StorageMap, StorageValue};
use secp256k1::SecretKey;
@@ -352,7 +353,7 @@ mod tests {
step += 3;
}
assert_eq!(
BlocksToPrune::get(),
BlocksToPrune::<DefaultInstance>::get(),
PruningRange {
oldest_unpruned_block: 11,
oldest_block_to_keep: 14,
@@ -378,7 +379,7 @@ mod tests {
.unwrap();
assert_eq!(finalized_blocks, expected_blocks);
assert_eq!(
BlocksToPrune::get(),
BlocksToPrune::<DefaultInstance>::get(),
PruningRange {
oldest_unpruned_block: 15,
oldest_block_to_keep: 15,
182 changes: 93 additions & 89 deletions bridges/modules/ethereum/src/lib.rs

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion bridges/modules/ethereum/src/mock.rs
Original file line number Diff line number Diff line change
@@ -136,7 +136,7 @@ pub fn run_test_with_genesis<T>(genesis: Header, total_validators: usize, test:
initial_difficulty: 0.into(),
initial_validators: addresses.clone(),
}
.build_storage::<TestRuntime>()
.build_storage::<TestRuntime, crate::DefaultInstance>()
.unwrap(),
)
.execute_with(|| {
14 changes: 7 additions & 7 deletions bridges/modules/ethereum/src/test_utils.rs
Original file line number Diff line number Diff line change
@@ -63,31 +63,31 @@ impl HeaderBuilder {
/// Creates default header on top of test parent with given hash.
#[cfg(test)]
pub fn with_parent_hash(parent_hash: H256) -> Self {
Self::with_parent_hash_on_runtime::<crate::mock::TestRuntime>(parent_hash)
Self::with_parent_hash_on_runtime::<crate::mock::TestRuntime, crate::DefaultInstance>(parent_hash)
}

/// Creates default header on top of test parent with given number. First parent is selected.
#[cfg(test)]
pub fn with_parent_number(parent_number: u64) -> Self {
Self::with_parent_number_on_runtime::<crate::mock::TestRuntime>(parent_number)
Self::with_parent_number_on_runtime::<crate::mock::TestRuntime, crate::DefaultInstance>(parent_number)
}

/// Creates default header on top of parent with given hash.
pub fn with_parent_hash_on_runtime<T: Trait>(parent_hash: H256) -> Self {
pub fn with_parent_hash_on_runtime<T: Trait<I>, I: crate::Instance>(parent_hash: H256) -> Self {
use crate::Headers;
use frame_support::StorageMap;

let parent_header = Headers::<T>::get(&parent_hash).unwrap().header;
let parent_header = Headers::<T, I>::get(&parent_hash).unwrap().header;
Self::with_parent(&parent_header)
}

/// Creates default header on top of parent with given number. First parent is selected.
pub fn with_parent_number_on_runtime<T: Trait>(parent_number: u64) -> Self {
pub fn with_parent_number_on_runtime<T: Trait<I>, I: crate::Instance>(parent_number: u64) -> Self {
use crate::HeadersByNumber;
use frame_support::StorageMap;

let parent_hash = HeadersByNumber::get(parent_number).unwrap()[0];
Self::with_parent_hash_on_runtime::<T>(parent_hash)
let parent_hash = HeadersByNumber::<I>::get(parent_number).unwrap()[0];
Self::with_parent_hash_on_runtime::<T, I>(parent_hash)
}

/// Creates default header on top of non-existent parent.
3 changes: 2 additions & 1 deletion bridges/modules/ethereum/src/validators.rs
Original file line number Diff line number Diff line change
@@ -276,6 +276,7 @@ impl ValidatorsSource {
pub(crate) mod tests {
use super::*;
use crate::mock::{run_test, validators_addresses, validators_change_receipt, TestRuntime};
use crate::DefaultInstance;
use crate::{BridgeStorage, Headers, ScheduledChange, ScheduledChanges, StoredHeader};
use frame_support::StorageMap;
use primitives::compute_merkle_root;
@@ -433,7 +434,7 @@ pub(crate) mod tests {
};
Headers::<TestRuntime>::insert(id100.hash, header100);
if let Some(scheduled_at) = scheduled_at {
ScheduledChanges::insert(scheduled_at.hash, scheduled_change);
ScheduledChanges::<DefaultInstance>::insert(scheduled_at.hash, scheduled_change);
}

validators.finalize_validators_change(&storage, &finalized_blocks)
15 changes: 8 additions & 7 deletions bridges/modules/ethereum/src/verification.rs
Original file line number Diff line number Diff line change
@@ -361,6 +361,7 @@ mod tests {
validators_change_receipt, AccountId, HeaderBuilder, TestRuntime, GAS_LIMIT,
};
use crate::validators::ValidatorsSource;
use crate::DefaultInstance;
use crate::{
pool_configuration, BridgeStorage, FinalizedBlock, Headers, HeadersByNumber, NextValidatorsSetId,
ScheduledChanges, ValidatorsSet, ValidatorsSets,
@@ -402,7 +403,7 @@ mod tests {
let block3 = HeaderBuilder::with_parent_number(2).sign_by_set(&validators);
insert_header(&mut storage, block3);

FinalizedBlock::put(block2_id);
FinalizedBlock::<DefaultInstance>::put(block2_id);

let validators_config =
ValidatorsConfiguration::Single(ValidatorsSource::Contract(Default::default(), Vec::new()));
@@ -419,29 +420,29 @@ mod tests {
}

fn change_validators_set_at(number: u64, finalized_set: Vec<Address>, signalled_set: Option<Vec<Address>>) {
let set_id = NextValidatorsSetId::get();
NextValidatorsSetId::put(set_id + 1);
ValidatorsSets::insert(
let set_id = NextValidatorsSetId::<DefaultInstance>::get();
NextValidatorsSetId::<DefaultInstance>::put(set_id + 1);
ValidatorsSets::<DefaultInstance>::insert(
set_id,
ValidatorsSet {
validators: finalized_set,
signal_block: None,
enact_block: HeaderId {
number: 0,
hash: HeadersByNumber::get(&0).unwrap()[0],
hash: HeadersByNumber::<DefaultInstance>::get(&0).unwrap()[0],
},
},
);

let header_hash = HeadersByNumber::get(&number).unwrap()[0];
let header_hash = HeadersByNumber::<DefaultInstance>::get(&number).unwrap()[0];
let mut header = Headers::<TestRuntime>::get(&header_hash).unwrap();
header.next_validators_set_id = set_id;
if let Some(signalled_set) = signalled_set {
header.last_signal_block = Some(HeaderId {
number: header.header.number - 1,
hash: header.header.parent_hash,
});
ScheduledChanges::insert(
ScheduledChanges::<DefaultInstance>::insert(
header.header.parent_hash,
ScheduledChange {
validators: signalled_set,
11 changes: 9 additions & 2 deletions bridges/primitives/currency-exchange/src/lib.rs
Original file line number Diff line number Diff line change
@@ -134,8 +134,15 @@ impl<Amount> CurrencyConverter for IdentityCurrencyConverter<Amount> {
}

decl_runtime_apis! {
/// API for exchange transactions submitters.
pub trait CurrencyExchangeApi<Proof: Parameter> {
/// API for Rialto exchange transactions submitters.
pub trait RialtoCurrencyExchangeApi<Proof: Parameter> {
/// Returns true if currency exchange module is able to import transaction proof in
/// its current state.
fn filter_transaction_proof(proof: Proof) -> bool;
}

/// API for Kovan exchange transactions submitters.
pub trait KovanCurrencyExchangeApi<Proof: Parameter> {
/// Returns true if currency exchange module is able to import transaction proof in
/// its current state.
fn filter_transaction_proof(proof: Proof) -> bool;
23 changes: 18 additions & 5 deletions bridges/primitives/ethereum-poa/src/lib.rs
Original file line number Diff line number Diff line change
@@ -505,19 +505,32 @@ pub fn step_validator<T>(header_validators: &[T], header_step: u64) -> &T {
}

sp_api::decl_runtime_apis! {
/// API for headers submitters.
pub trait EthereumHeadersApi {
/// API for querying information about headers from the Rialto Bridge Pallet
pub trait RialtoHeaderApi {
/// Returns number and hash of the best block known to the bridge module.
/// The caller should only submit `import_header` transaction that makes
///
/// The caller should only submit an `import_header` transaction that makes
/// (or leads to making) other header the best one.
fn best_block() -> (u64, H256);

/// Returns number and hash of the best finalized block known to the bridge module.
fn finalized_block() -> (u64, H256);

/// Returns true if the import of given block requires transactions receipts.
fn is_import_requires_receipts(header: Header) -> bool;
/// Returns true if header is known to the runtime.
fn is_known_block(hash: H256) -> bool;
}

/// API for querying information about headers from the Kovan Bridge Pallet
pub trait KovanHeaderApi {
/// Returns number and hash of the best block known to the bridge module.
///
/// The caller should only submit an `import_header` transaction that makes
/// (or leads to making) other header the best one.
fn best_block() -> (u64, H256);
/// Returns number and hash of the best finalized block known to the bridge module.
fn finalized_block() -> (u64, H256);
/// Returns true if the import of given block requires transactions receipts.
fn is_import_requires_receipts(header: Header) -> bool;
/// Returns true if header is known to the runtime.
fn is_known_block(hash: H256) -> bool;
}
17 changes: 10 additions & 7 deletions bridges/relays/ethereum/src/substrate_client.rs
Original file line number Diff line number Diff line change
@@ -34,10 +34,10 @@ use sp_core::crypto::Pair;
use sp_runtime::traits::IdentifyAccount;
use std::collections::VecDeque;

const ETH_API_IMPORT_REQUIRES_RECEIPTS: &str = "EthereumHeadersApi_is_import_requires_receipts";
const ETH_API_IS_KNOWN_BLOCK: &str = "EthereumHeadersApi_is_known_block";
const ETH_API_BEST_BLOCK: &str = "EthereumHeadersApi_best_block";
const ETH_API_BEST_FINALIZED_BLOCK: &str = "EthereumHeadersApi_finalized_block";
const ETH_API_IMPORT_REQUIRES_RECEIPTS: &str = "RialtoHeaderApi_is_import_requires_receipts";
const ETH_API_IS_KNOWN_BLOCK: &str = "RialtoHeaderApi_is_known_block";
const ETH_API_BEST_BLOCK: &str = "RialtoHeaderApi_best_block";
const ETH_API_BEST_FINALIZED_BLOCK: &str = "RialtoHeaderApi_finalized_block";
const EXCH_API_FILTER_TRANSACTION_PROOF: &str = "CurrencyExchangeApi_filter_transaction_proof";
const SUB_API_GRANDPA_AUTHORITIES: &str = "GrandpaApi_grandpa_authorities";

@@ -336,7 +336,8 @@ impl SubmitEthereumExchangeTransactionProof for SubstrateRpcClient {
let nonce = self.next_account_index(account_id).await?;

let transaction = create_signed_transaction(
bridge_node_runtime::Call::BridgeCurrencyExchange(
// TODO [#209]: Change so that that it's dynamic
bridge_node_runtime::Call::BridgeRialtoCurrencyExchange(
bridge_node_runtime::BridgeCurrencyExchangeCall::import_peer_transaction(proof),
),
&params.signer,
@@ -356,7 +357,8 @@ fn create_signed_submit_transaction(
genesis_hash: H256,
) -> bridge_node_runtime::UncheckedExtrinsic {
create_signed_transaction(
bridge_node_runtime::Call::BridgeEthPoA(bridge_node_runtime::BridgeEthPoACall::import_signed_headers(
// TODO [#209]: Change so that that it's dynamic
bridge_node_runtime::Call::BridgeRialto(bridge_node_runtime::BridgeEthPoACall::import_signed_headers(
headers
.into_iter()
.map(|header| {
@@ -376,7 +378,8 @@ fn create_signed_submit_transaction(
/// Create unsigned Substrate transaction for submitting Ethereum header.
fn create_unsigned_submit_transaction(header: QueuedEthereumHeader) -> bridge_node_runtime::UncheckedExtrinsic {
let function =
bridge_node_runtime::Call::BridgeEthPoA(bridge_node_runtime::BridgeEthPoACall::import_unsigned_header(
// TODO [#209]: Change so that that it's dynamic
bridge_node_runtime::Call::BridgeRialto(bridge_node_runtime::BridgeEthPoACall::import_unsigned_header(
into_substrate_ethereum_header(header.header()),
into_substrate_ethereum_receipts(header.extra()),
));

0 comments on commit 30844b1

Please sign in to comment.