mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-04-26 22:47:56 +00:00
Remove bridges subtree (#5752)
* remove bridges folder * remove BRIDGES.md * remove bridges mentions from top Cargo.toml * remove bridges from CODEOWNERS * remove bridges mentions from testing.md * remove bridge pallets from Rococo/Wococo runtime * also remove from node
This commit is contained in:
committed by
GitHub
parent
2e42da645f
commit
3f29fd04e1
@@ -1,527 +0,0 @@
|
||||
// Copyright 2020 Parity Technologies (UK) Ltd.
|
||||
// This file is part of Polkadot.
|
||||
|
||||
// Polkadot is free software: you can redistribute it and/or modify
|
||||
// it under the terms of the GNU General Public License as published by
|
||||
// the Free Software Foundation, either version 3 of the License, or
|
||||
// (at your option) any later version.
|
||||
|
||||
// Polkadot is distributed in the hope that it will be useful,
|
||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
// GNU General Public License for more details.
|
||||
|
||||
// You should have received a copy of the GNU General Public License
|
||||
// along with Polkadot. If not, see <http://www.gnu.org/licenses/>.
|
||||
|
||||
//! Over-bridge messaging support for Rococo <> Wococo bridge.
|
||||
|
||||
pub use self::{at_rococo::*, at_wococo::*};
|
||||
|
||||
use crate::{Balances, Runtime};
|
||||
|
||||
use bp_messages::{
|
||||
source_chain::{SenderOrigin, TargetHeaderChain},
|
||||
target_chain::{ProvedMessages, SourceHeaderChain},
|
||||
InboundLaneData, LaneId, Message, MessageNonce,
|
||||
};
|
||||
use bp_rococo::{Balance, Rococo, EXTRA_STORAGE_PROOF_SIZE, MAXIMAL_ENCODED_ACCOUNT_ID_SIZE};
|
||||
use bp_runtime::{Chain, ChainId, ROCOCO_CHAIN_ID, WOCOCO_CHAIN_ID};
|
||||
use bridge_runtime_common::messages::{
|
||||
source as messages_source, target as messages_target, transaction_payment,
|
||||
BridgedChainWithMessages, ChainWithMessages, MessageBridge, MessageTransaction,
|
||||
ThisChainWithMessages,
|
||||
};
|
||||
use frame_support::{
|
||||
traits::Get,
|
||||
weights::{Weight, WeightToFee as WeightToFeeT},
|
||||
RuntimeDebug,
|
||||
};
|
||||
use rococo_runtime_constants::fee::WeightToFee;
|
||||
use sp_runtime::FixedU128;
|
||||
use sp_std::{marker::PhantomData, ops::RangeInclusive};
|
||||
|
||||
/// Maximal number of pending outbound messages.
|
||||
const MAXIMAL_PENDING_MESSAGES_AT_OUTBOUND_LANE: MessageNonce =
|
||||
bp_rococo::MAX_UNCONFIRMED_MESSAGES_IN_CONFIRMATION_TX;
|
||||
/// Maximal weight of single message delivery confirmation transaction on Rococo/Wococo chain.
|
||||
///
|
||||
/// This value is a result of `pallet_bridge_messages::Pallet::receive_messages_delivery_proof` weight formula
|
||||
/// computation for the case when single message is confirmed. The result then must be rounded up to account
|
||||
/// possible future runtime upgrades.
|
||||
const MAX_SINGLE_MESSAGE_DELIVERY_CONFIRMATION_TX_WEIGHT: Weight = 2_000_000_000;
|
||||
/// Increase of delivery transaction weight on Rococo/Wococo chain with every additional message byte.
|
||||
///
|
||||
/// This value is a result of `pallet_bridge_messages::WeightInfoExt::storage_proof_size_overhead(1)` call. The
|
||||
/// result then must be rounded up to account possible future runtime upgrades.
|
||||
const ADDITIONAL_MESSAGE_BYTE_DELIVERY_WEIGHT: Weight = 25_000;
|
||||
/// Weight of single regular message delivery transaction on Rococo/Wococo chain.
|
||||
///
|
||||
/// This value is a result of `pallet_bridge_messages::Pallet::receive_messages_proof_weight()` call
|
||||
/// for the case when single message of `pallet_bridge_messages::EXPECTED_DEFAULT_MESSAGE_LENGTH` bytes is delivered.
|
||||
/// The message must have dispatch weight set to zero. The result then must be rounded up to account
|
||||
/// possible future runtime upgrades.
|
||||
const DEFAULT_MESSAGE_DELIVERY_TX_WEIGHT: Weight = 1_500_000_000;
|
||||
/// Weight of pay-dispatch-fee operation for inbound messages at Rococo/Wococo chain.
|
||||
///
|
||||
/// This value corresponds to the result of `pallet_bridge_messages::WeightInfoExt::pay_inbound_dispatch_fee_overhead()`
|
||||
/// call for your chain. Don't put too much reserve there, because it is used to **decrease**
|
||||
/// `DEFAULT_MESSAGE_DELIVERY_TX_WEIGHT` cost. So putting large reserve would make delivery transactions cheaper.
|
||||
const PAY_INBOUND_DISPATCH_FEE_WEIGHT: Weight = 600_000_000;
|
||||
/// Number of bytes, included in the signed Rococo/Wococo transaction apart from the encoded call itself.
|
||||
///
|
||||
/// Can be computed by subtracting encoded call size from raw transaction size.
|
||||
const TX_EXTRA_BYTES: u32 = 130;
|
||||
|
||||
/// Rococo chain as it is seen at Rococo.
|
||||
pub type RococoAtRococo =
|
||||
RococoLikeChain<AtRococoWithWococoMessageBridge, crate::RococoGrandpaInstance>;
|
||||
|
||||
/// Rococo chain as it is seen at Wococo.
|
||||
pub type RococoAtWococo =
|
||||
RococoLikeChain<AtWococoWithRococoMessageBridge, crate::RococoGrandpaInstance>;
|
||||
|
||||
/// Wococo chain as it is seen at Wococo.
|
||||
pub type WococoAtWococo =
|
||||
RococoLikeChain<AtWococoWithRococoMessageBridge, crate::WococoGrandpaInstance>;
|
||||
|
||||
/// Wococo chain as it is seen at Rococo.
|
||||
pub type WococoAtRococo =
|
||||
RococoLikeChain<AtRococoWithWococoMessageBridge, crate::WococoGrandpaInstance>;
|
||||
|
||||
/// Rococo/Wococo chain from message lane point of view.
|
||||
#[derive(RuntimeDebug, Clone, Copy)]
|
||||
pub struct RococoLikeChain<B, GI> {
|
||||
_bridge_definition: PhantomData<B>,
|
||||
_at_this_chain_grandpa_pallet_instance: PhantomData<GI>,
|
||||
}
|
||||
|
||||
impl<B, GI> ChainWithMessages for RococoLikeChain<B, GI> {
|
||||
type Hash = crate::Hash;
|
||||
type AccountId = crate::AccountId;
|
||||
type Signer = primitives::v2::AccountPublic;
|
||||
type Signature = crate::Signature;
|
||||
type Weight = Weight;
|
||||
type Balance = Balance;
|
||||
}
|
||||
|
||||
impl<B, GI> ThisChainWithMessages for RococoLikeChain<B, GI> {
|
||||
type Origin = crate::Origin;
|
||||
type Call = crate::Call;
|
||||
|
||||
fn is_message_accepted(_submitter: &crate::Origin, lane: &LaneId) -> bool {
|
||||
*lane == [0, 0, 0, 0]
|
||||
}
|
||||
|
||||
fn maximal_pending_messages_at_outbound_lane() -> MessageNonce {
|
||||
MAXIMAL_PENDING_MESSAGES_AT_OUTBOUND_LANE
|
||||
}
|
||||
|
||||
fn estimate_delivery_confirmation_transaction() -> MessageTransaction<Weight> {
|
||||
let inbound_data_size = InboundLaneData::<crate::AccountId>::encoded_size_hint(
|
||||
MAXIMAL_ENCODED_ACCOUNT_ID_SIZE,
|
||||
1,
|
||||
1,
|
||||
)
|
||||
.unwrap_or(u32::MAX);
|
||||
|
||||
MessageTransaction {
|
||||
dispatch_weight: MAX_SINGLE_MESSAGE_DELIVERY_CONFIRMATION_TX_WEIGHT,
|
||||
size: inbound_data_size
|
||||
.saturating_add(EXTRA_STORAGE_PROOF_SIZE)
|
||||
.saturating_add(TX_EXTRA_BYTES),
|
||||
}
|
||||
}
|
||||
|
||||
fn transaction_payment(transaction: MessageTransaction<Weight>) -> Balance {
|
||||
// current fee multiplier is used here
|
||||
transaction_payment(
|
||||
crate::BlockWeights::get()
|
||||
.get(frame_support::weights::DispatchClass::Normal)
|
||||
.base_extrinsic,
|
||||
crate::TransactionByteFee::get(),
|
||||
pallet_transaction_payment::Pallet::<Runtime>::next_fee_multiplier(),
|
||||
|weight| WeightToFee::weight_to_fee(&weight),
|
||||
transaction,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
impl<B, GI> BridgedChainWithMessages for RococoLikeChain<B, GI> {
|
||||
fn maximal_extrinsic_size() -> u32 {
|
||||
Rococo::max_extrinsic_size()
|
||||
}
|
||||
|
||||
fn message_weight_limits(_message_payload: &[u8]) -> RangeInclusive<Weight> {
|
||||
// we don't want to relay too large messages + keep reserve for future upgrades
|
||||
let upper_limit = messages_target::maximal_incoming_message_dispatch_weight(
|
||||
Rococo::max_extrinsic_weight(),
|
||||
);
|
||||
|
||||
// we're charging for payload bytes in `With(Wococo | Rococo)MessageBridge::transaction_payment` function
|
||||
//
|
||||
// this bridge may be used to deliver all kind of messages, so we're not making any assumptions about
|
||||
// minimal dispatch weight here
|
||||
|
||||
0..=upper_limit
|
||||
}
|
||||
|
||||
fn estimate_delivery_transaction(
|
||||
message_payload: &[u8],
|
||||
include_pay_dispatch_fee_cost: bool,
|
||||
message_dispatch_weight: Weight,
|
||||
) -> MessageTransaction<Weight> {
|
||||
let message_payload_len = u32::try_from(message_payload.len()).unwrap_or(u32::MAX);
|
||||
let extra_bytes_in_payload = Weight::from(message_payload_len)
|
||||
.saturating_sub(pallet_bridge_messages::EXPECTED_DEFAULT_MESSAGE_LENGTH.into());
|
||||
|
||||
MessageTransaction {
|
||||
dispatch_weight: extra_bytes_in_payload
|
||||
.saturating_mul(ADDITIONAL_MESSAGE_BYTE_DELIVERY_WEIGHT)
|
||||
.saturating_add(DEFAULT_MESSAGE_DELIVERY_TX_WEIGHT)
|
||||
.saturating_sub(if include_pay_dispatch_fee_cost {
|
||||
0
|
||||
} else {
|
||||
PAY_INBOUND_DISPATCH_FEE_WEIGHT
|
||||
})
|
||||
.saturating_add(message_dispatch_weight),
|
||||
size: message_payload_len
|
||||
.saturating_add(EXTRA_STORAGE_PROOF_SIZE)
|
||||
.saturating_add(TX_EXTRA_BYTES),
|
||||
}
|
||||
}
|
||||
|
||||
fn transaction_payment(transaction: MessageTransaction<Weight>) -> Balance {
|
||||
// current fee multiplier is used here
|
||||
bridge_runtime_common::messages::transaction_payment(
|
||||
crate::BlockWeights::get()
|
||||
.get(frame_support::weights::DispatchClass::Normal)
|
||||
.base_extrinsic,
|
||||
crate::TransactionByteFee::get(),
|
||||
pallet_transaction_payment::Pallet::<Runtime>::next_fee_multiplier(),
|
||||
|weight| WeightToFee::weight_to_fee(&weight),
|
||||
transaction,
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
impl<B, GI> TargetHeaderChain<messages_source::FromThisChainMessagePayload<B>, crate::AccountId>
|
||||
for RococoLikeChain<B, GI>
|
||||
where
|
||||
B: MessageBridge,
|
||||
B::ThisChain: ChainWithMessages<AccountId = crate::AccountId>,
|
||||
B::BridgedChain: ChainWithMessages<Hash = crate::Hash>,
|
||||
GI: 'static,
|
||||
Runtime: pallet_bridge_grandpa::Config<GI>,
|
||||
<<Runtime as pallet_bridge_grandpa::Config<GI>>::BridgedChain as bp_runtime::Chain>::Hash:
|
||||
From<crate::Hash>,
|
||||
{
|
||||
type Error = &'static str;
|
||||
type MessagesDeliveryProof =
|
||||
messages_source::FromBridgedChainMessagesDeliveryProof<crate::Hash>;
|
||||
|
||||
fn verify_message(
|
||||
payload: &messages_source::FromThisChainMessagePayload<B>,
|
||||
) -> Result<(), Self::Error> {
|
||||
messages_source::verify_chain_message::<B>(payload)
|
||||
}
|
||||
|
||||
fn verify_messages_delivery_proof(
|
||||
proof: Self::MessagesDeliveryProof,
|
||||
) -> Result<(LaneId, InboundLaneData<crate::AccountId>), Self::Error> {
|
||||
messages_source::verify_messages_delivery_proof::<B, Runtime, GI>(proof)
|
||||
}
|
||||
}
|
||||
|
||||
impl<B, GI> SourceHeaderChain<Balance> for RococoLikeChain<B, GI>
|
||||
where
|
||||
B: MessageBridge,
|
||||
B::BridgedChain: ChainWithMessages<Balance = Balance, Hash = crate::Hash>,
|
||||
GI: 'static,
|
||||
Runtime: pallet_bridge_grandpa::Config<GI>,
|
||||
<<Runtime as pallet_bridge_grandpa::Config<GI>>::BridgedChain as bp_runtime::Chain>::Hash:
|
||||
From<crate::Hash>,
|
||||
{
|
||||
type Error = &'static str;
|
||||
type MessagesProof = messages_target::FromBridgedChainMessagesProof<crate::Hash>;
|
||||
|
||||
fn verify_messages_proof(
|
||||
proof: Self::MessagesProof,
|
||||
messages_count: u32,
|
||||
) -> Result<ProvedMessages<Message<Balance>>, Self::Error> {
|
||||
messages_target::verify_messages_proof::<B, Runtime, GI>(proof, messages_count)
|
||||
.and_then(verify_inbound_messages_lane)
|
||||
}
|
||||
}
|
||||
|
||||
/// Error that happens when we are receiving incoming message via unexpected lane.
|
||||
const INBOUND_LANE_DISABLED: &str = "The inbound message lane is disabled.";
|
||||
|
||||
/// Verify that lanes of inbound messages are enabled.
|
||||
fn verify_inbound_messages_lane(
|
||||
messages: ProvedMessages<Message<Balance>>,
|
||||
) -> Result<ProvedMessages<Message<Balance>>, &'static str> {
|
||||
let allowed_incoming_lanes = [[0, 0, 0, 0]];
|
||||
if messages.keys().any(|lane_id| !allowed_incoming_lanes.contains(lane_id)) {
|
||||
return Err(INBOUND_LANE_DISABLED)
|
||||
}
|
||||
Ok(messages)
|
||||
}
|
||||
|
||||
/// The cost of delivery confirmation transaction.
|
||||
pub struct GetDeliveryConfirmationTransactionFee;
|
||||
|
||||
impl Get<Balance> for GetDeliveryConfirmationTransactionFee {
|
||||
fn get() -> Balance {
|
||||
<RococoAtRococo as ThisChainWithMessages>::transaction_payment(
|
||||
RococoAtRococo::estimate_delivery_confirmation_transaction(),
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
impl SenderOrigin<crate::AccountId> for crate::Origin {
|
||||
fn linked_account(&self) -> Option<crate::AccountId> {
|
||||
match self.caller {
|
||||
crate::OriginCaller::system(frame_system::RawOrigin::Signed(ref submitter)) =>
|
||||
Some(submitter.clone()),
|
||||
crate::OriginCaller::system(frame_system::RawOrigin::Root) |
|
||||
crate::OriginCaller::system(frame_system::RawOrigin::None) =>
|
||||
crate::RootAccountForPayments::get(),
|
||||
_ => None,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/// This module contains definitions that are used by the messages pallet instance, "deployed" at Rococo.
|
||||
mod at_rococo {
|
||||
use super::*;
|
||||
|
||||
/// Message bridge that is "deployed" at Rococo chain and connecting it to Wococo chain.
|
||||
#[derive(RuntimeDebug, Clone, Copy)]
|
||||
pub struct AtRococoWithWococoMessageBridge;
|
||||
|
||||
impl MessageBridge for AtRococoWithWococoMessageBridge {
|
||||
const THIS_CHAIN_ID: ChainId = ROCOCO_CHAIN_ID;
|
||||
const BRIDGED_CHAIN_ID: ChainId = WOCOCO_CHAIN_ID;
|
||||
const RELAYER_FEE_PERCENT: u32 = 10;
|
||||
const BRIDGED_MESSAGES_PALLET_NAME: &'static str =
|
||||
bp_rococo::WITH_ROCOCO_MESSAGES_PALLET_NAME;
|
||||
|
||||
type ThisChain = RococoAtRococo;
|
||||
type BridgedChain = WococoAtRococo;
|
||||
|
||||
fn bridged_balance_to_this_balance(
|
||||
bridged_balance: bp_wococo::Balance,
|
||||
_bridged_to_this_conversion_rate_override: Option<FixedU128>,
|
||||
) -> bp_rococo::Balance {
|
||||
bridged_balance
|
||||
}
|
||||
}
|
||||
|
||||
/// Message payload for Rococo -> Wococo messages as it is seen at the Rococo.
|
||||
pub type ToWococoMessagePayload =
|
||||
messages_source::FromThisChainMessagePayload<AtRococoWithWococoMessageBridge>;
|
||||
|
||||
/// Message verifier for Rococo -> Wococo messages at Rococo.
|
||||
pub type ToWococoMessageVerifier =
|
||||
messages_source::FromThisChainMessageVerifier<AtRococoWithWococoMessageBridge>;
|
||||
|
||||
/// Message payload for Wococo -> Rococo messages as it is seen at Rococo.
|
||||
pub type FromWococoMessagePayload =
|
||||
messages_target::FromBridgedChainMessagePayload<AtRococoWithWococoMessageBridge>;
|
||||
|
||||
/// Encoded Rococo Call as it comes from Wococo.
|
||||
pub type FromWococoEncodedCall =
|
||||
messages_target::FromBridgedChainEncodedMessageCall<crate::Call>;
|
||||
|
||||
/// Call-dispatch based message dispatch for Wococo -> Rococo messages.
|
||||
pub type FromWococoMessageDispatch = messages_target::FromBridgedChainMessageDispatch<
|
||||
AtRococoWithWococoMessageBridge,
|
||||
Runtime,
|
||||
Balances,
|
||||
crate::AtRococoFromWococoMessagesDispatch,
|
||||
>;
|
||||
}
|
||||
|
||||
/// This module contains definitions that are used by the messages pallet instance, "deployed" at Wococo.
|
||||
mod at_wococo {
|
||||
use super::*;
|
||||
|
||||
/// Message bridge that is "deployed" at Wococo chain and connecting it to Rococo chain.
|
||||
#[derive(RuntimeDebug, Clone, Copy)]
|
||||
pub struct AtWococoWithRococoMessageBridge;
|
||||
|
||||
impl MessageBridge for AtWococoWithRococoMessageBridge {
|
||||
const THIS_CHAIN_ID: ChainId = WOCOCO_CHAIN_ID;
|
||||
const BRIDGED_CHAIN_ID: ChainId = ROCOCO_CHAIN_ID;
|
||||
const RELAYER_FEE_PERCENT: u32 = 10;
|
||||
const BRIDGED_MESSAGES_PALLET_NAME: &'static str =
|
||||
bp_wococo::WITH_WOCOCO_MESSAGES_PALLET_NAME;
|
||||
|
||||
type ThisChain = WococoAtWococo;
|
||||
type BridgedChain = RococoAtWococo;
|
||||
|
||||
fn bridged_balance_to_this_balance(
|
||||
bridged_balance: bp_rococo::Balance,
|
||||
_bridged_to_this_conversion_rate_override: Option<FixedU128>,
|
||||
) -> bp_wococo::Balance {
|
||||
bridged_balance
|
||||
}
|
||||
}
|
||||
|
||||
/// Message payload for Wococo -> Rococo messages as it is seen at the Wococo.
|
||||
pub type ToRococoMessagePayload =
|
||||
messages_source::FromThisChainMessagePayload<AtWococoWithRococoMessageBridge>;
|
||||
|
||||
/// Message verifier for Wococo -> Rococo messages at Wococo.
|
||||
pub type ToRococoMessageVerifier =
|
||||
messages_source::FromThisChainMessageVerifier<AtWococoWithRococoMessageBridge>;
|
||||
|
||||
/// Message payload for Rococo -> Wococo messages as it is seen at Wococo.
|
||||
pub type FromRococoMessagePayload =
|
||||
messages_target::FromBridgedChainMessagePayload<AtWococoWithRococoMessageBridge>;
|
||||
|
||||
/// Encoded Wococo Call as it comes from Rococo.
|
||||
pub type FromRococoEncodedCall =
|
||||
messages_target::FromBridgedChainEncodedMessageCall<crate::Call>;
|
||||
|
||||
/// Call-dispatch based message dispatch for Rococo -> Wococo messages.
|
||||
pub type FromRococoMessageDispatch = messages_target::FromBridgedChainMessageDispatch<
|
||||
AtWococoWithRococoMessageBridge,
|
||||
Runtime,
|
||||
Balances,
|
||||
crate::AtWococoFromRococoMessagesDispatch,
|
||||
>;
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use super::*;
|
||||
use bp_messages::{target_chain::ProvedLaneMessages, MessageData, MessageKey};
|
||||
use bridge_runtime_common::messages;
|
||||
use parity_scale_codec::{Decode, Encode};
|
||||
use sp_runtime::traits::TrailingZeroInput;
|
||||
|
||||
#[test]
|
||||
fn ensure_rococo_messages_weights_are_correct() {
|
||||
// **NOTE**: the main purpose of this test is to be sure that any message that is sumbitted
|
||||
// to (any) inbound lane in Rococo<>Wococo bridge can be delivered to the bridged chain.
|
||||
// Since we deal with testnets here, in case of failure + urgency:
|
||||
//
|
||||
// 1) ping bridges team about this failure (see the CODEOWNERS file if you're unsure who to ping);
|
||||
// 2) comment/#[ignore] the test.
|
||||
|
||||
// we don't have any knowledge of messages-at-Rococo weights, so we'll be using
|
||||
// weights of one of our testnets, which should be accurate enough
|
||||
type Weights = pallet_bridge_messages::weights::MillauWeight<Runtime>;
|
||||
|
||||
pallet_bridge_messages::ensure_weights_are_correct::<Weights>(
|
||||
DEFAULT_MESSAGE_DELIVERY_TX_WEIGHT,
|
||||
ADDITIONAL_MESSAGE_BYTE_DELIVERY_WEIGHT,
|
||||
MAX_SINGLE_MESSAGE_DELIVERY_CONFIRMATION_TX_WEIGHT,
|
||||
PAY_INBOUND_DISPATCH_FEE_WEIGHT,
|
||||
crate::RocksDbWeight::get(),
|
||||
);
|
||||
|
||||
let max_incoming_message_proof_size = bp_rococo::EXTRA_STORAGE_PROOF_SIZE.saturating_add(
|
||||
messages::target::maximal_incoming_message_size(Rococo::max_extrinsic_size()),
|
||||
);
|
||||
pallet_bridge_messages::ensure_able_to_receive_message::<Weights>(
|
||||
Rococo::max_extrinsic_size(),
|
||||
Rococo::max_extrinsic_weight(),
|
||||
max_incoming_message_proof_size,
|
||||
messages::target::maximal_incoming_message_dispatch_weight(
|
||||
Rococo::max_extrinsic_weight(),
|
||||
),
|
||||
);
|
||||
|
||||
let max_incoming_inbound_lane_data_proof_size =
|
||||
bp_messages::InboundLaneData::<()>::encoded_size_hint(
|
||||
bp_rococo::MAXIMAL_ENCODED_ACCOUNT_ID_SIZE,
|
||||
bp_rococo::MAX_UNREWARDED_RELAYERS_IN_CONFIRMATION_TX as _,
|
||||
bp_rococo::MAX_UNCONFIRMED_MESSAGES_IN_CONFIRMATION_TX as _,
|
||||
)
|
||||
.unwrap_or(u32::MAX);
|
||||
pallet_bridge_messages::ensure_able_to_receive_confirmation::<Weights>(
|
||||
Rococo::max_extrinsic_size(),
|
||||
Rococo::max_extrinsic_weight(),
|
||||
max_incoming_inbound_lane_data_proof_size,
|
||||
bp_rococo::MAX_UNREWARDED_RELAYERS_IN_CONFIRMATION_TX,
|
||||
bp_rococo::MAX_UNCONFIRMED_MESSAGES_IN_CONFIRMATION_TX,
|
||||
crate::RocksDbWeight::get(),
|
||||
);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn ensure_rococo_tx_extra_bytes_constant_is_correct() {
|
||||
// **NOTE**: this test checks that we're computing transaction fee (for bridged chain, which, in
|
||||
// case of Rococo<>Wococo, means any chain) on-chain properly. If this assert fails:
|
||||
//
|
||||
// 1) just fix the `TX_EXTRA_BYTES` constant to actual (or sightly rounded up) value;
|
||||
// 2) (only if it has changed significantly (> x2 times)) ping the bridges team (see the CODEOWNERS
|
||||
// file if you're unsure who to ping)
|
||||
|
||||
let signed_extra: crate::SignedExtra = (
|
||||
frame_system::CheckNonZeroSender::new(),
|
||||
frame_system::CheckSpecVersion::new(),
|
||||
frame_system::CheckTxVersion::new(),
|
||||
frame_system::CheckGenesis::new(),
|
||||
frame_system::CheckMortality::from(sp_runtime::generic::Era::mortal(
|
||||
u64::MAX,
|
||||
u64::MAX,
|
||||
)),
|
||||
frame_system::CheckNonce::from(primitives::v2::Nonce::MAX),
|
||||
frame_system::CheckWeight::new(),
|
||||
pallet_transaction_payment::ChargeTransactionPayment::from(
|
||||
primitives::v2::Balance::MAX,
|
||||
),
|
||||
);
|
||||
let mut zeroes = TrailingZeroInput::zeroes();
|
||||
let extra_bytes_in_transaction = signed_extra.encoded_size() +
|
||||
crate::Address::decode(&mut zeroes).unwrap().encoded_size() +
|
||||
crate::Signature::decode(&mut zeroes).unwrap().encoded_size();
|
||||
assert!(
|
||||
TX_EXTRA_BYTES as usize >= extra_bytes_in_transaction,
|
||||
"Hardcoded number of extra bytes in Rococo transaction {} is lower than actual value: {}",
|
||||
TX_EXTRA_BYTES,
|
||||
extra_bytes_in_transaction,
|
||||
);
|
||||
}
|
||||
|
||||
fn proved_messages(lane_id: LaneId) -> ProvedMessages<Message<Balance>> {
|
||||
vec![(
|
||||
lane_id,
|
||||
ProvedLaneMessages {
|
||||
lane_state: None,
|
||||
messages: vec![Message {
|
||||
key: MessageKey { lane_id, nonce: 0 },
|
||||
data: MessageData { payload: vec![], fee: 0 },
|
||||
}],
|
||||
},
|
||||
)]
|
||||
.into_iter()
|
||||
.collect()
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn verify_inbound_messages_lane_succeeds() {
|
||||
assert_eq!(
|
||||
verify_inbound_messages_lane(proved_messages([0, 0, 0, 0])),
|
||||
Ok(proved_messages([0, 0, 0, 0])),
|
||||
);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn verify_inbound_messages_lane_fails() {
|
||||
assert_eq!(
|
||||
verify_inbound_messages_lane(proved_messages([0, 0, 0, 1])),
|
||||
Err(INBOUND_LANE_DISABLED),
|
||||
);
|
||||
|
||||
let proved_messages = proved_messages([0, 0, 0, 0])
|
||||
.into_iter()
|
||||
.chain(proved_messages([0, 0, 0, 1]))
|
||||
.collect();
|
||||
assert_eq!(verify_inbound_messages_lane(proved_messages), Err(INBOUND_LANE_DISABLED),);
|
||||
}
|
||||
}
|
||||
@@ -58,7 +58,7 @@ use sp_runtime::{
|
||||
OpaqueKeys, SaturatedConversion, Verify,
|
||||
},
|
||||
transaction_validity::{TransactionPriority, TransactionSource, TransactionValidity},
|
||||
ApplyExtrinsicResult, FixedU128, KeyTypeId,
|
||||
ApplyExtrinsicResult, KeyTypeId,
|
||||
};
|
||||
use sp_staking::SessionIndex;
|
||||
use sp_std::{collections::btree_map::BTreeMap, prelude::*};
|
||||
@@ -74,16 +74,11 @@ use runtime_parachains::{
|
||||
session_info as parachains_session_info, shared as parachains_shared, ump as parachains_ump,
|
||||
};
|
||||
|
||||
use bridge_runtime_common::messages::{
|
||||
source::estimate_message_dispatch_and_delivery_fee, MessageBridge,
|
||||
};
|
||||
|
||||
pub use frame_system::Call as SystemCall;
|
||||
|
||||
/// Constant values used within the runtime.
|
||||
use rococo_runtime_constants::{currency::*, fee::*, time::*};
|
||||
|
||||
mod bridge_messages;
|
||||
mod validator_manager;
|
||||
mod weights;
|
||||
pub mod xcm_config;
|
||||
@@ -231,19 +226,6 @@ construct_runtime! {
|
||||
// Validator Manager pallet.
|
||||
ValidatorManager: validator_manager,
|
||||
|
||||
// It might seem strange that we add both sides of the bridge to the same runtime. We do this because this
|
||||
// runtime as shared by both the Rococo and Wococo chains. When running as Rococo we only use
|
||||
// `BridgeWococoGrandpa`, and vice versa.
|
||||
BridgeRococoGrandpa: pallet_bridge_grandpa::{Pallet, Call, Storage, Config<T>} = 40,
|
||||
BridgeWococoGrandpa: pallet_bridge_grandpa::<Instance1>::{Pallet, Call, Storage, Config<T>} = 41,
|
||||
|
||||
// Bridge messages support. The same story as with the bridge grandpa pallet above ^^^ - when we're
|
||||
// running as Rococo we only use `BridgeWococoMessages`/`BridgeWococoMessagesDispatch`, and vice versa.
|
||||
BridgeRococoMessages: pallet_bridge_messages::{Pallet, Call, Storage, Event<T>, Config<T>} = 43,
|
||||
BridgeWococoMessages: pallet_bridge_messages::<Instance1>::{Pallet, Call, Storage, Event<T>, Config<T>} = 44,
|
||||
BridgeRococoMessagesDispatch: pallet_bridge_dispatch::{Pallet, Event<T>} = 45,
|
||||
BridgeWococoMessagesDispatch: pallet_bridge_dispatch::<Instance1>::{Pallet, Event<T>} = 46,
|
||||
|
||||
// A "council"
|
||||
Collective: pallet_collective = 80,
|
||||
Membership: pallet_membership = 81,
|
||||
@@ -748,137 +730,6 @@ parameter_types! {
|
||||
pub const HeadersToKeep: u32 = 7 * DAYS as u32;
|
||||
}
|
||||
|
||||
pub type RococoGrandpaInstance = ();
|
||||
impl pallet_bridge_grandpa::Config for Runtime {
|
||||
type BridgedChain = bp_rococo::Rococo;
|
||||
type MaxRequests = MaxRequests;
|
||||
type HeadersToKeep = HeadersToKeep;
|
||||
|
||||
type WeightInfo = pallet_bridge_grandpa::weights::MillauWeight<Runtime>;
|
||||
}
|
||||
|
||||
pub type WococoGrandpaInstance = pallet_bridge_grandpa::Instance1;
|
||||
impl pallet_bridge_grandpa::Config<WococoGrandpaInstance> for Runtime {
|
||||
type BridgedChain = bp_wococo::Wococo;
|
||||
type MaxRequests = MaxRequests;
|
||||
type HeadersToKeep = HeadersToKeep;
|
||||
|
||||
type WeightInfo = pallet_bridge_grandpa::weights::MillauWeight<Runtime>;
|
||||
}
|
||||
|
||||
// Instance that is "deployed" at Wococo chain. Responsible for dispatching Rococo -> Wococo messages.
|
||||
pub type AtWococoFromRococoMessagesDispatch = ();
|
||||
impl pallet_bridge_dispatch::Config<AtWococoFromRococoMessagesDispatch> for Runtime {
|
||||
type Event = Event;
|
||||
type BridgeMessageId = (bp_messages::LaneId, bp_messages::MessageNonce);
|
||||
type Call = Call;
|
||||
type CallFilter = frame_support::traits::Everything;
|
||||
type EncodedCall = bridge_messages::FromRococoEncodedCall;
|
||||
type SourceChainAccountId = bp_wococo::AccountId;
|
||||
type TargetChainAccountPublic = sp_runtime::MultiSigner;
|
||||
type TargetChainSignature = sp_runtime::MultiSignature;
|
||||
type AccountIdConverter = bp_rococo::AccountIdConverter;
|
||||
}
|
||||
|
||||
// Instance that is "deployed" at Rococo chain. Responsible for dispatching Wococo -> Rococo messages.
|
||||
pub type AtRococoFromWococoMessagesDispatch = pallet_bridge_dispatch::Instance1;
|
||||
impl pallet_bridge_dispatch::Config<AtRococoFromWococoMessagesDispatch> for Runtime {
|
||||
type Event = Event;
|
||||
type BridgeMessageId = (bp_messages::LaneId, bp_messages::MessageNonce);
|
||||
type Call = Call;
|
||||
type CallFilter = frame_support::traits::Everything;
|
||||
type EncodedCall = bridge_messages::FromWococoEncodedCall;
|
||||
type SourceChainAccountId = bp_rococo::AccountId;
|
||||
type TargetChainAccountPublic = sp_runtime::MultiSigner;
|
||||
type TargetChainSignature = sp_runtime::MultiSignature;
|
||||
type AccountIdConverter = bp_wococo::AccountIdConverter;
|
||||
}
|
||||
|
||||
parameter_types! {
|
||||
pub const MaxMessagesToPruneAtOnce: bp_messages::MessageNonce = 8;
|
||||
pub const MaxUnrewardedRelayerEntriesAtInboundLane: bp_messages::MessageNonce =
|
||||
bp_rococo::MAX_UNREWARDED_RELAYERS_IN_CONFIRMATION_TX;
|
||||
pub const MaxUnconfirmedMessagesAtInboundLane: bp_messages::MessageNonce =
|
||||
bp_rococo::MAX_UNCONFIRMED_MESSAGES_IN_CONFIRMATION_TX;
|
||||
pub const RootAccountForPayments: Option<AccountId> = None;
|
||||
pub const RococoChainId: bp_runtime::ChainId = bp_runtime::ROCOCO_CHAIN_ID;
|
||||
pub const WococoChainId: bp_runtime::ChainId = bp_runtime::WOCOCO_CHAIN_ID;
|
||||
}
|
||||
|
||||
// Instance that is "deployed" at Wococo chain. Responsible for sending Wococo -> Rococo messages
|
||||
// and receiving Rococo -> Wococo messages.
|
||||
pub type AtWococoWithRococoMessagesInstance = ();
|
||||
impl pallet_bridge_messages::Config<AtWococoWithRococoMessagesInstance> for Runtime {
|
||||
type Event = Event;
|
||||
type BridgedChainId = RococoChainId;
|
||||
type WeightInfo = pallet_bridge_messages::weights::MillauWeight<Runtime>;
|
||||
type Parameter = ();
|
||||
type MaxMessagesToPruneAtOnce = MaxMessagesToPruneAtOnce;
|
||||
type MaxUnrewardedRelayerEntriesAtInboundLane = MaxUnrewardedRelayerEntriesAtInboundLane;
|
||||
type MaxUnconfirmedMessagesAtInboundLane = MaxUnconfirmedMessagesAtInboundLane;
|
||||
|
||||
type OutboundPayload = crate::bridge_messages::ToRococoMessagePayload;
|
||||
type OutboundMessageFee = bp_wococo::Balance;
|
||||
|
||||
type InboundPayload = crate::bridge_messages::FromRococoMessagePayload;
|
||||
type InboundMessageFee = bp_rococo::Balance;
|
||||
type InboundRelayer = bp_rococo::AccountId;
|
||||
|
||||
type AccountIdConverter = bp_wococo::AccountIdConverter;
|
||||
|
||||
type TargetHeaderChain = crate::bridge_messages::RococoAtWococo;
|
||||
type LaneMessageVerifier = crate::bridge_messages::ToRococoMessageVerifier;
|
||||
type MessageDeliveryAndDispatchPayment =
|
||||
pallet_bridge_messages::instant_payments::InstantCurrencyPayments<
|
||||
Runtime,
|
||||
AtWococoWithRococoMessagesInstance,
|
||||
pallet_balances::Pallet<Runtime>,
|
||||
crate::bridge_messages::GetDeliveryConfirmationTransactionFee,
|
||||
>;
|
||||
type OnDeliveryConfirmed = ();
|
||||
type OnMessageAccepted = ();
|
||||
|
||||
type SourceHeaderChain = crate::bridge_messages::RococoAtWococo;
|
||||
type MessageDispatch = crate::bridge_messages::FromRococoMessageDispatch;
|
||||
}
|
||||
|
||||
// Instance that is "deployed" at Rococo chain. Responsible for sending Rococo -> Wococo messages
|
||||
// and receiving Wococo -> Rococo messages.
|
||||
pub type AtRococoWithWococoMessagesInstance = pallet_bridge_messages::Instance1;
|
||||
impl pallet_bridge_messages::Config<AtRococoWithWococoMessagesInstance> for Runtime {
|
||||
type Event = Event;
|
||||
type BridgedChainId = WococoChainId;
|
||||
type WeightInfo = pallet_bridge_messages::weights::MillauWeight<Runtime>;
|
||||
type Parameter = ();
|
||||
type MaxMessagesToPruneAtOnce = MaxMessagesToPruneAtOnce;
|
||||
type MaxUnrewardedRelayerEntriesAtInboundLane = MaxUnrewardedRelayerEntriesAtInboundLane;
|
||||
type MaxUnconfirmedMessagesAtInboundLane = MaxUnconfirmedMessagesAtInboundLane;
|
||||
|
||||
type OutboundPayload = crate::bridge_messages::ToWococoMessagePayload;
|
||||
type OutboundMessageFee = bp_rococo::Balance;
|
||||
|
||||
type InboundPayload = crate::bridge_messages::FromWococoMessagePayload;
|
||||
type InboundMessageFee = bp_wococo::Balance;
|
||||
type InboundRelayer = bp_wococo::AccountId;
|
||||
|
||||
type AccountIdConverter = bp_rococo::AccountIdConverter;
|
||||
|
||||
type TargetHeaderChain = crate::bridge_messages::WococoAtRococo;
|
||||
type LaneMessageVerifier = crate::bridge_messages::ToWococoMessageVerifier;
|
||||
type MessageDeliveryAndDispatchPayment =
|
||||
pallet_bridge_messages::instant_payments::InstantCurrencyPayments<
|
||||
Runtime,
|
||||
AtRococoWithWococoMessagesInstance,
|
||||
pallet_balances::Pallet<Runtime>,
|
||||
crate::bridge_messages::GetDeliveryConfirmationTransactionFee,
|
||||
>;
|
||||
type OnDeliveryConfirmed = ();
|
||||
type OnMessageAccepted = ();
|
||||
|
||||
type SourceHeaderChain = crate::bridge_messages::WococoAtRococo;
|
||||
type MessageDispatch = crate::bridge_messages::FromWococoMessageDispatch;
|
||||
}
|
||||
|
||||
parameter_types! {
|
||||
pub const EndingPeriod: BlockNumber = 1 * HOURS;
|
||||
pub const SampleLength: BlockNumber = 1;
|
||||
@@ -1452,90 +1303,6 @@ sp_api::impl_runtime_apis! {
|
||||
}
|
||||
}
|
||||
|
||||
impl bp_rococo::RococoFinalityApi<Block> for Runtime {
|
||||
fn best_finalized() -> (bp_rococo::BlockNumber, bp_rococo::Hash) {
|
||||
let header = BridgeRococoGrandpa::best_finalized();
|
||||
(header.number, header.hash())
|
||||
}
|
||||
}
|
||||
|
||||
impl bp_wococo::WococoFinalityApi<Block> for Runtime {
|
||||
fn best_finalized() -> (bp_wococo::BlockNumber, bp_wococo::Hash) {
|
||||
let header = BridgeWococoGrandpa::best_finalized();
|
||||
(header.number, header.hash())
|
||||
}
|
||||
}
|
||||
|
||||
impl bp_rococo::ToRococoOutboundLaneApi<Block, Balance, bridge_messages::ToRococoMessagePayload> for Runtime {
|
||||
fn estimate_message_delivery_and_dispatch_fee(
|
||||
_lane_id: bp_messages::LaneId,
|
||||
payload: bridge_messages::ToWococoMessagePayload,
|
||||
rococo_to_wococo_conversion_rate: Option<FixedU128>,
|
||||
) -> Option<Balance> {
|
||||
estimate_message_dispatch_and_delivery_fee::<bridge_messages::AtWococoWithRococoMessageBridge>(
|
||||
&payload,
|
||||
bridge_messages::AtWococoWithRococoMessageBridge::RELAYER_FEE_PERCENT,
|
||||
rococo_to_wococo_conversion_rate,
|
||||
).ok()
|
||||
}
|
||||
|
||||
fn message_details(
|
||||
lane: bp_messages::LaneId,
|
||||
begin: bp_messages::MessageNonce,
|
||||
end: bp_messages::MessageNonce,
|
||||
) -> Vec<bp_messages::MessageDetails<Balance>> {
|
||||
(begin..=end).filter_map(|nonce| {
|
||||
let message_data = BridgeRococoMessages::outbound_message_data(lane, nonce)?;
|
||||
let decoded_payload = bridge_messages::ToRococoMessagePayload::decode(
|
||||
&mut &message_data.payload[..]
|
||||
).ok()?;
|
||||
Some(bp_messages::MessageDetails {
|
||||
nonce,
|
||||
dispatch_weight: decoded_payload.weight,
|
||||
size: message_data.payload.len() as _,
|
||||
delivery_and_dispatch_fee: message_data.fee,
|
||||
dispatch_fee_payment: decoded_payload.dispatch_fee_payment,
|
||||
})
|
||||
})
|
||||
.collect()
|
||||
}
|
||||
}
|
||||
|
||||
impl bp_wococo::ToWococoOutboundLaneApi<Block, Balance, bridge_messages::ToWococoMessagePayload> for Runtime {
|
||||
fn estimate_message_delivery_and_dispatch_fee(
|
||||
_lane_id: bp_messages::LaneId,
|
||||
payload: bridge_messages::ToWococoMessagePayload,
|
||||
wococo_to_rococo_conversion_rate: Option<FixedU128>,
|
||||
) -> Option<Balance> {
|
||||
estimate_message_dispatch_and_delivery_fee::<bridge_messages::AtRococoWithWococoMessageBridge>(
|
||||
&payload,
|
||||
bridge_messages::AtRococoWithWococoMessageBridge::RELAYER_FEE_PERCENT,
|
||||
wococo_to_rococo_conversion_rate,
|
||||
).ok()
|
||||
}
|
||||
|
||||
fn message_details(
|
||||
lane: bp_messages::LaneId,
|
||||
begin: bp_messages::MessageNonce,
|
||||
end: bp_messages::MessageNonce,
|
||||
) -> Vec<bp_messages::MessageDetails<Balance>> {
|
||||
(begin..=end).filter_map(|nonce| {
|
||||
let message_data = BridgeWococoMessages::outbound_message_data(lane, nonce)?;
|
||||
let decoded_payload = bridge_messages::ToWococoMessagePayload::decode(
|
||||
&mut &message_data.payload[..]
|
||||
).ok()?;
|
||||
Some(bp_messages::MessageDetails {
|
||||
nonce,
|
||||
dispatch_weight: decoded_payload.weight,
|
||||
size: message_data.payload.len() as _,
|
||||
delivery_and_dispatch_fee: message_data.fee,
|
||||
dispatch_fee_payment: decoded_payload.dispatch_fee_payment,
|
||||
})
|
||||
})
|
||||
.collect()
|
||||
}
|
||||
}
|
||||
|
||||
impl frame_system_rpc_runtime_api::AccountNonceApi<Block, AccountId, Nonce> for Runtime {
|
||||
fn account_nonce(account: AccountId) -> Nonce {
|
||||
System::account_nonce(account)
|
||||
|
||||
Reference in New Issue
Block a user