Skip to content
Snippets Groups Projects
Commit c7c614a0 authored by Hugo Trentesaux's avatar Hugo Trentesaux
Browse files

TMP NOMERGE revert to old runtime

parent f39f04e3
No related branches found
No related tags found
No related merge requests found
No preview for this file type
...@@ -81,27 +81,27 @@ pub async fn monitor_expirations(data: &Data, blocks: u32, sessions: u32) -> any ...@@ -81,27 +81,27 @@ pub async fn monitor_expirations(data: &Data, blocks: u32, sessions: u32) -> any
} }
} }
let mut smith_certs_iter = client let mut smiths_certs_iter = client
.storage() .storage()
.iter( .iter(
runtime::storage() runtime::storage()
.smith_cert() .smiths_cert()
.storage_certs_removable_on(0), .storage_certs_removable_on(0),
10, 10,
Some(parent_hash), Some(parent_hash),
) )
.await?; .await?;
let mut smith_certs = BTreeMap::new(); let mut smiths_certs = BTreeMap::new();
while let Some((k, v)) = smith_certs_iter.next().await? { while let Some((k, v)) = smiths_certs_iter.next().await? {
let block_number = u32::from_le_bytes(k.as_ref()[40..44].try_into().unwrap()); let block_number = u32::from_le_bytes(k.as_ref()[40..44].try_into().unwrap());
if block_number < end_block { if block_number < end_block {
smith_certs.insert(block_number - current_block, v); smiths_certs.insert(block_number - current_block, v);
} }
} }
for (title, certs) in [ for (title, certs) in [
("Certifications", basic_certs), ("Certifications", basic_certs),
("Smith certifications", smith_certs), ("Smith certifications", smiths_certs),
] { ] {
println!("\n{title}:"); println!("\n{title}:");
for (blocks_left, certs) in certs { for (blocks_left, certs) in certs {
...@@ -144,27 +144,27 @@ pub async fn monitor_expirations(data: &Data, blocks: u32, sessions: u32) -> any ...@@ -144,27 +144,27 @@ pub async fn monitor_expirations(data: &Data, blocks: u32, sessions: u32) -> any
} }
} }
let mut smith_membership_iter = client let mut smiths_membership_iter = client
.storage() .storage()
.iter( .iter(
runtime::storage() runtime::storage()
.smith_membership() .smiths_membership()
.memberships_expire_on(0), .memberships_expire_on(0),
10, 10,
Some(parent_hash), Some(parent_hash),
) )
.await?; .await?;
let mut smith_memberships = BTreeMap::new(); let mut smiths_memberships = BTreeMap::new();
while let Some((k, v)) = smith_membership_iter.next().await? { while let Some((k, v)) = smiths_membership_iter.next().await? {
let block_number = u32::from_le_bytes(k.as_ref()[40..44].try_into().unwrap()); let block_number = u32::from_le_bytes(k.as_ref()[40..44].try_into().unwrap());
if block_number < end_block { if block_number < end_block {
smith_memberships.insert(block_number - current_block, v); smiths_memberships.insert(block_number - current_block, v);
} }
} }
for (title, memberships) in [ for (title, memberships) in [
("Memberships", basic_memberships), ("Memberships", basic_memberships),
("Smith memberships", smith_memberships), ("Smith memberships", smiths_memberships),
] { ] {
println!("\n{title}:"); println!("\n{title}:");
for (blocks_left, membership) in memberships { for (blocks_left, membership) in memberships {
......
...@@ -4,7 +4,7 @@ use std::ops::Deref; ...@@ -4,7 +4,7 @@ use std::ops::Deref;
type SessionKeys = [u8; 128]; type SessionKeys = [u8; 128];
#[cfg(feature = "gdev")] #[cfg(feature = "gdev")]
type SmithMembershipMetaData = runtime::runtime_types::common_runtime::entities::SmithMembershipMetaData::<SessionKeys>; type SmithMembershipMetaData = runtime::runtime_types::common_runtime::entities::SmithsMembershipMetaData::<SessionKeys>;
/// define smith subcommands /// define smith subcommands
#[derive(Clone, Default, Debug, clap::Parser)] #[derive(Clone, Default, Debug, clap::Parser)]
...@@ -41,7 +41,7 @@ pub async fn handle_command(data: Data, command: Subcommand) -> anyhow::Result<( ...@@ -41,7 +41,7 @@ pub async fn handle_command(data: Data, command: Subcommand) -> anyhow::Result<(
match command { match command {
Subcommand::Request { endpoint } => { Subcommand::Request { endpoint } => {
data = data.build_keypair(); data = data.build_keypair();
dbg!(request_smith_membership(&data, endpoint).await)?; dbg!(request_smiths_membership(&data, endpoint).await)?;
} }
Subcommand::GoOnline => { Subcommand::GoOnline => {
go_online(&data).await?; go_online(&data).await?;
...@@ -86,7 +86,7 @@ pub async fn rotate_keys(client: &Client) -> Result<SessionKeys, anyhow::Error> ...@@ -86,7 +86,7 @@ pub async fn rotate_keys(client: &Client) -> Result<SessionKeys, anyhow::Error>
} }
/// request smith membership /// request smith membership
pub async fn request_smith_membership(data: &Data, endpoint: String) -> Result<(), anyhow::Error> { pub async fn request_smiths_membership(data: &Data, endpoint: String) -> Result<(), anyhow::Error> {
let session_keys = rotate_keys(data.client()).await?; let session_keys = rotate_keys(data.client()).await?;
let metadata = let metadata =
SmithMembershipMetaData { SmithMembershipMetaData {
...@@ -99,14 +99,14 @@ pub async fn request_smith_membership(data: &Data, endpoint: String) -> Result<( ...@@ -99,14 +99,14 @@ pub async fn request_smith_membership(data: &Data, endpoint: String) -> Result<(
.tx() .tx()
.sign_and_submit_then_watch( .sign_and_submit_then_watch(
&runtime::tx() &runtime::tx()
.smith_membership() .smiths_membership()
.request_membership(metadata), .request_membership(metadata),
&PairSigner::new(data.keypair()), &PairSigner::new(data.keypair()),
BaseExtrinsicParamsBuilder::new(), BaseExtrinsicParamsBuilder::new(),
) )
.await?; .await?;
let events = track_progress(progress).await?; let events = track_progress(progress).await?;
let request = events.find_first::<runtime::smith_membership::events::MembershipRequested>()?; let request = events.find_first::<runtime::smiths_membership::events::MembershipRequested>()?;
if let Some(event) = request { if let Some(event) = request {
println!("{event:?}"); println!("{event:?}");
} }
...@@ -280,7 +280,7 @@ pub async fn cert(data: &Data, receiver: u32) -> Result<(), anyhow::Error> { ...@@ -280,7 +280,7 @@ pub async fn cert(data: &Data, receiver: u32) -> Result<(), anyhow::Error> {
.tx() .tx()
.sign_and_submit_then_watch( .sign_and_submit_then_watch(
&runtime::tx() &runtime::tx()
.smith_cert() .smiths_cert()
.add_cert(data.idty_index(), receiver), .add_cert(data.idty_index(), receiver),
&PairSigner::new(data.keypair()), &PairSigner::new(data.keypair()),
BaseExtrinsicParamsBuilder::new(), BaseExtrinsicParamsBuilder::new(),
...@@ -290,8 +290,8 @@ pub async fn cert(data: &Data, receiver: u32) -> Result<(), anyhow::Error> { ...@@ -290,8 +290,8 @@ pub async fn cert(data: &Data, receiver: u32) -> Result<(), anyhow::Error> {
let events = track_progress(progress).await?; let events = track_progress(progress).await?;
// look for the expected event // look for the expected event
let new_cert_event = events.find_first::<runtime::smith_cert::events::NewCert>()?; let new_cert_event = events.find_first::<runtime::smiths_cert::events::NewCert>()?;
let renew_cert_event = events.find_first::<runtime::smith_cert::events::RenewedCert>()?; let renew_cert_event = events.find_first::<runtime::smiths_cert::events::RenewedCert>()?;
if let Some(event) = new_cert_event { if let Some(event) = new_cert_event {
println!("{event:?}"); println!("{event:?}");
......
use crate::*; use crate::*;
#[cfg(any(feature = "dev", feature = "gdev"))] // find how to get runtime calls #[cfg(any(feature = "dev", feature = "gdev"))] // find how to get runtime calls
type Call = runtime::runtime_types::gdev_runtime::RuntimeCall; type Call = runtime::runtime_types::gdev_runtime::Call;
type BalancesCall = runtime::runtime_types::pallet_balances::pallet::Call; type BalancesCall = runtime::runtime_types::pallet_balances::pallet::Call;
/// transfer balance to target /// transfer balance to target
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment