Lines
93.55 %
Functions
8.33 %
Branches
100 %
// Copyright (C) Moondance Labs Ltd.
// This file is part of Tanssi.
// Tanssi 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.
// Tanssi 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 Tanssi. If not, see <http://www.gnu.org/licenses/>
use frame_support::pallet_prelude::*;
use parity_scale_codec::DecodeAll;
use snowbridge_core::{Channel, PRIMARY_GOVERNANCE_CHANNEL};
use snowbridge_router_primitives::inbound::envelope::Envelope;
use snowbridge_router_primitives::inbound::MessageProcessor;
use sp_runtime::DispatchError;
use sp_std::vec::Vec;
/// Magic bytes are added in every payload intended for this processor to make sure
/// that we are the intended recipient of the message. Reason being scale encoding is not type aware.
/// So a same set of bytes can be decoded for two different data structures if their
/// total size is same. Magic bytes can be checked after decoding to make sure that the sender
/// indeed send a message intended for this processor.
pub const MAGIC_BYTES: [u8; 4] = [112, 21, 0, 56];
/// Payload is the whole data we expect to receive from the relayer
#[derive(Encode, Decode)]
pub struct Payload<T>
where
T: pallet_external_validators::Config,
{
pub magic_bytes: [u8; 4],
pub message: Message<T>,
}
/// Actual message inside the payload
pub enum Message<T>
V1(InboundCommand<T>),
/// Command to be executed by this message processor
pub enum InboundCommand<T>
ReceiveValidators {
validators: Vec<<T as pallet_external_validators::Config>::ValidatorId>,
external_index: u64,
},
pub struct SymbioticMessageProcessor<T>(PhantomData<T>);
impl<T> MessageProcessor for SymbioticMessageProcessor<T>
fn can_process_message(_channel: &Channel, envelope: &Envelope) -> bool {
let decode_result = Payload::<T>::decode_all(&mut envelope.payload.as_slice());
if let Ok(payload) = decode_result {
payload.magic_bytes == MAGIC_BYTES
} else {
false
fn process_message(_channel: Channel, envelope: Envelope) -> Result<(), DispatchError> {
let message = if let Ok(payload) = decode_result {
payload.message
return Err(DispatchError::Other("unable to parse the envelope payload"));
};
match message {
Message::V1(InboundCommand::ReceiveValidators {
validators,
external_index,
}) => {
if envelope.channel_id != PRIMARY_GOVERNANCE_CHANNEL {
return Err(DispatchError::Other(
"Received governance message from invalid channel id",
));
pallet_external_validators::Pallet::<T>::set_external_validators_inner(
)?;
Ok(())