mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-03 01:47:24 +00:00
f532982623
* CLI options and keystore integration * Replace multiqueue with future::mpsc * BFT gossip * Revert to app_dirs * generate_from_seed commented * Refactor event loop * Start consensus by timer * Message buffering * Minor fixes * Work around duty-roster issue. * some more minor fixes * fix compilation * more consistent formatting * make bft input stream never conclude * Minor fixes * add timestamp module to executive * more cleanups and logging * Fixed message propagation
302 lines
9.0 KiB
Rust
302 lines
9.0 KiB
Rust
// Copyright 2017 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/>.
|
|
|
|
//! The Polkadot runtime. This can be compiled with ``#[no_std]`, ready for Wasm.
|
|
|
|
#![cfg_attr(not(feature = "std"), no_std)]
|
|
|
|
#[macro_use]
|
|
extern crate substrate_runtime_io as runtime_io;
|
|
|
|
#[macro_use]
|
|
extern crate substrate_runtime_support as runtime_support;
|
|
|
|
#[macro_use]
|
|
extern crate substrate_runtime_primitives as runtime_primitives;
|
|
|
|
#[cfg(test)]
|
|
extern crate substrate_serializer;
|
|
|
|
#[cfg_attr(feature = "std", macro_use)]
|
|
extern crate substrate_primitives;
|
|
|
|
extern crate substrate_runtime_std as rstd;
|
|
extern crate substrate_codec as codec;
|
|
extern crate substrate_runtime_consensus as consensus;
|
|
extern crate substrate_runtime_council as council;
|
|
extern crate substrate_runtime_democracy as democracy;
|
|
extern crate substrate_runtime_executive as executive;
|
|
extern crate substrate_runtime_session as session;
|
|
extern crate substrate_runtime_staking as staking;
|
|
extern crate substrate_runtime_system as system;
|
|
extern crate substrate_runtime_timestamp as timestamp;
|
|
extern crate polkadot_primitives;
|
|
|
|
mod parachains;
|
|
|
|
use runtime_io::BlakeTwo256;
|
|
use polkadot_primitives::{AccountId, Balance, BlockNumber, Hash, Index, Log, SessionKey, Signature};
|
|
use runtime_primitives::generic;
|
|
use runtime_primitives::traits::{Identity, HasPublicAux};
|
|
#[cfg(feature = "std")] pub use runtime_primitives::BuildExternalities;
|
|
|
|
/// Concrete runtime type used to parameterize the various modules.
|
|
pub struct Concrete;
|
|
|
|
impl HasPublicAux for Concrete {
|
|
type PublicAux = AccountId; // TODO: Option<AccountId>
|
|
}
|
|
|
|
impl system::Trait for Concrete {
|
|
type Index = Index;
|
|
type BlockNumber = BlockNumber;
|
|
type Hash = Hash;
|
|
type Hashing = BlakeTwo256;
|
|
type Digest = generic::Digest<Log>;
|
|
type AccountId = AccountId;
|
|
type Header = generic::Header<BlockNumber, Hash, Log>;
|
|
}
|
|
/// System module for this concrete runtime.
|
|
pub type System = system::Module<Concrete>;
|
|
|
|
impl consensus::Trait for Concrete {
|
|
type PublicAux = <Self as HasPublicAux>::PublicAux;
|
|
type SessionKey = SessionKey;
|
|
}
|
|
/// Consensus module for this concrete runtime.
|
|
pub type Consensus = consensus::Module<Concrete>;
|
|
pub use consensus::Call as ConsensusCall;
|
|
|
|
impl timestamp::Trait for Concrete {
|
|
type Value = u64;
|
|
}
|
|
/// Timestamp module for this concrete runtime.
|
|
pub type Timestamp = timestamp::Module<Concrete>;
|
|
pub use timestamp::Call as TimestampCall;
|
|
|
|
impl session::Trait for Concrete {
|
|
type ConvertAccountIdToSessionKey = Identity;
|
|
}
|
|
/// Session module for this concrete runtime.
|
|
pub type Session = session::Module<Concrete>;
|
|
|
|
impl staking::Trait for Concrete {
|
|
type Balance = Balance;
|
|
type DetermineContractAddress = BlakeTwo256;
|
|
}
|
|
/// Staking module for this concrete runtime.
|
|
pub type Staking = staking::Module<Concrete>;
|
|
|
|
impl democracy::Trait for Concrete {
|
|
type Proposal = PrivCall;
|
|
}
|
|
/// Democracy module for this concrete runtime.
|
|
pub type Democracy = democracy::Module<Concrete>;
|
|
|
|
impl council::Trait for Concrete {}
|
|
/// Council module for this concrete runtime.
|
|
pub type Council = council::Module<Concrete>;
|
|
/// Council voting module for this concrete runtime.
|
|
pub type CouncilVoting = council::voting::Module<Concrete>;
|
|
|
|
impl parachains::Trait for Concrete {}
|
|
pub type Parachains = parachains::Module<Concrete>;
|
|
|
|
impl_outer_dispatch! {
|
|
pub enum Call where aux: <Concrete as HasPublicAux>::PublicAux {
|
|
Consensus = 0,
|
|
Session = 1,
|
|
Staking = 2,
|
|
Timestamp = 3,
|
|
Democracy = 5,
|
|
Council = 6,
|
|
CouncilVoting = 7,
|
|
}
|
|
|
|
pub enum PrivCall {
|
|
Consensus = 0,
|
|
Session = 1,
|
|
Staking = 2,
|
|
Democracy = 5,
|
|
Council = 6,
|
|
CouncilVoting = 7,
|
|
}
|
|
}
|
|
|
|
/// Block header type as expected by this runtime.
|
|
pub type Header = generic::Header<BlockNumber, Hash, Log>;
|
|
/// Block type as expected by this runtime.
|
|
pub type Block = generic::Block<BlockNumber, Hash, Log, AccountId, Index, Call, Signature>;
|
|
/// Unchecked extrinsic type as expected by this runtime.
|
|
pub type UncheckedExtrinsic = generic::UncheckedExtrinsic<AccountId, Index, Call, Signature>;
|
|
/// Extrinsic type as expected by this runtime.
|
|
pub type Extrinsic = generic::Extrinsic<AccountId, Index, Call>;
|
|
/// Executive: handles dispatch to the various modules.
|
|
pub type Executive = executive::Executive<Concrete, Block, Staking,
|
|
(((((((), Parachains), Council), Democracy), Staking), Session), Timestamp)>;
|
|
|
|
impl_outer_config! {
|
|
pub struct GenesisConfig for Concrete {
|
|
ConsensusConfig => consensus,
|
|
SystemConfig => system,
|
|
SessionConfig => session,
|
|
StakingConfig => staking,
|
|
DemocracyConfig => democracy,
|
|
CouncilConfig => council,
|
|
ParachainsConfig => parachains,
|
|
}
|
|
}
|
|
|
|
pub mod api {
|
|
impl_stubs!(
|
|
authorities => |()| super::Consensus::authorities(),
|
|
initialise_block => |header| super::Executive::initialise_block(&header),
|
|
apply_extrinsic => |extrinsic| super::Executive::apply_extrinsic(extrinsic),
|
|
execute_block => |block| super::Executive::execute_block(block),
|
|
finalise_block => |()| super::Executive::finalise_block(),
|
|
validator_count => |()| super::Session::validator_count(),
|
|
validators => |()| super::Session::validators()
|
|
);
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod tests {
|
|
use super::*;
|
|
use substrate_primitives as primitives;
|
|
use ::codec::Slicable;
|
|
use substrate_primitives::hexdisplay::HexDisplay;
|
|
use substrate_serializer as ser;
|
|
use runtime_primitives::traits::{Digest as DigestT, Header as HeaderT};
|
|
type Digest = generic::Digest<Log>;
|
|
|
|
#[test]
|
|
fn test_header_serialization() {
|
|
let header = Header {
|
|
parent_hash: 5.into(),
|
|
number: 67,
|
|
state_root: 3.into(),
|
|
extrinsics_root: 6.into(),
|
|
digest: { let mut d = Digest::default(); d.push(Log(vec![1])); d },
|
|
};
|
|
|
|
assert_eq!(ser::to_string_pretty(&header), r#"{
|
|
"parentHash": "0x0000000000000000000000000000000000000000000000000000000000000005",
|
|
"number": 67,
|
|
"stateRoot": "0x0000000000000000000000000000000000000000000000000000000000000003",
|
|
"extrinsicsRoot": "0x0000000000000000000000000000000000000000000000000000000000000006",
|
|
"digest": {
|
|
"logs": [
|
|
"0x01"
|
|
]
|
|
}
|
|
}"#);
|
|
|
|
let v = header.encode();
|
|
assert_eq!(Header::decode(&mut &v[..]).unwrap(), header);
|
|
}
|
|
|
|
#[test]
|
|
fn block_encoding_round_trip() {
|
|
let mut block = Block {
|
|
header: Header::new(1, Default::default(), Default::default(), Default::default(), Default::default()),
|
|
extrinsics: vec![
|
|
UncheckedExtrinsic {
|
|
extrinsic: Extrinsic {
|
|
function: Call::Timestamp(timestamp::Call::set(100_000_000)),
|
|
signed: Default::default(),
|
|
index: Default::default(),
|
|
},
|
|
signature: Default::default(),
|
|
}
|
|
],
|
|
};
|
|
|
|
let raw = block.encode();
|
|
let decoded = Block::decode(&mut &raw[..]).unwrap();
|
|
|
|
assert_eq!(block, decoded);
|
|
|
|
block.extrinsics.push(UncheckedExtrinsic {
|
|
extrinsic: Extrinsic {
|
|
function: Call::Staking(staking::Call::stake()),
|
|
signed: Default::default(),
|
|
index: 10101,
|
|
},
|
|
signature: Default::default(),
|
|
});
|
|
|
|
let raw = block.encode();
|
|
let decoded = Block::decode(&mut &raw[..]).unwrap();
|
|
|
|
assert_eq!(block, decoded);
|
|
}
|
|
|
|
#[test]
|
|
fn block_encoding_substrate_round_trip() {
|
|
let mut block = Block {
|
|
header: Header::new(1, Default::default(), Default::default(), Default::default(), Default::default()),
|
|
extrinsics: vec![
|
|
UncheckedExtrinsic {
|
|
extrinsic: Extrinsic {
|
|
function: Call::Timestamp(timestamp::Call::set(100_000_000)),
|
|
signed: Default::default(),
|
|
index: Default::default(),
|
|
},
|
|
signature: Default::default(),
|
|
}
|
|
],
|
|
};
|
|
|
|
block.extrinsics.push(UncheckedExtrinsic {
|
|
extrinsic: Extrinsic {
|
|
function: Call::Staking(staking::Call::stake()),
|
|
signed: Default::default(),
|
|
index: 10101,
|
|
},
|
|
signature: Default::default(),
|
|
});
|
|
|
|
let raw = block.encode();
|
|
let decoded_substrate = primitives::block::Block::decode(&mut &raw[..]).unwrap();
|
|
let encoded_substrate = decoded_substrate.encode();
|
|
let decoded = Block::decode(&mut &encoded_substrate[..]).unwrap();
|
|
|
|
assert_eq!(block, decoded);
|
|
}
|
|
|
|
#[test]
|
|
fn serialize_unchecked() {
|
|
let tx = UncheckedExtrinsic {
|
|
extrinsic: Extrinsic {
|
|
signed: [1; 32],
|
|
index: 999u64,
|
|
function: Call::Timestamp(TimestampCall::set(135135)),
|
|
},
|
|
signature: primitives::hash::H512([0; 64]).into(),
|
|
};
|
|
// 71000000
|
|
// 0101010101010101010101010101010101010101010101010101010101010101
|
|
// e703000000000000
|
|
// 00
|
|
// df0f0200
|
|
// 0000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000
|
|
|
|
let v = Slicable::encode(&tx);
|
|
println!("{}", HexDisplay::from(&v));
|
|
assert_eq!(UncheckedExtrinsic::decode(&mut &v[..]).unwrap(), tx);
|
|
}
|
|
}
|