difftreelog
Merge remote-tracking branch 'origin/feat/set-sub-identities' into develop
in: master
6 files changed
Makefilediffbeforeafterboth--- a/Makefile
+++ b/Makefile
@@ -146,5 +146,5 @@
make _bench PALLET=app-promotion PALLET_DIR=app-promotion
.PHONY: bench
-# Disabled: bench-scheduler, bench-collator-selection, bench-rmrk-core, bench-rmrk-equip
-bench: bench-evm-migration bench-unique bench-structure bench-fungible bench-refungible bench-nonfungible bench-configuration bench-foreign-assets bench-identity
+# Disabled: bench-scheduler, bench-collator-selection, bench-identity, bench-rmrk-core, bench-rmrk-equip
+bench: bench-evm-migration bench-unique bench-structure bench-fungible bench-refungible bench-nonfungible bench-configuration bench-foreign-assets
pallets/identity/src/benchmarking.rsdiffbeforeafterboth--- a/pallets/identity/src/benchmarking.rs
+++ b/pallets/identity/src/benchmarking.rs
@@ -417,7 +417,7 @@
let n in 0..600;
use frame_benchmarking::account;
let identities = (0..n).map(|i| (
- account("caller", i, 0),
+ account("caller", i, SEED),
Registration::<BalanceOf<T>, T::MaxRegistrars, T::MaxAdditionalFields> {
judgements: Default::default(),
deposit: Default::default(),
@@ -433,7 +433,7 @@
use frame_benchmarking::account;
let origin = T::ForceOrigin::successful_origin();
let identities = (0..n).map(|i| (
- account("caller", i, 0),
+ account("caller", i, SEED),
Registration::<BalanceOf<T>, T::MaxRegistrars, T::MaxAdditionalFields> {
judgements: Default::default(),
deposit: Default::default(),
@@ -446,6 +446,20 @@
let identities = identities.into_iter().map(|(acc, _)| acc).collect::<Vec<_>>();
}: _<T::RuntimeOrigin>(origin, identities)
+ force_set_subs {
+ let s in 0 .. T::MaxSubAccounts::get();
+ let n in 0..600;
+ use frame_benchmarking::account;
+ let identities = (0..n).map(|i| (
+ account("caller", i, SEED),
+ (
+ BalanceOf::<T>::max_value(),
+ create_sub_accounts::<T>(&caller, s)?.try_into().unwrap(),
+ ),
+ )).collect::<Vec<_>>();
+ let origin = T::ForceOrigin::successful_origin();
+ }: _<T::RuntimeOrigin>(origin, identities)
+
add_sub {
let s in 0 .. T::MaxSubAccounts::get() - 1;
pallets/identity/src/lib.rsdiffbeforeafterboth--- a/pallets/identity/src/lib.rs
+++ b/pallets/identity/src/lib.rs
@@ -314,6 +314,8 @@
main: T::AccountId,
deposit: BalanceOf<T>,
},
+ /// A number of identities were forcibly updated with new sub-identities.
+ SubIdentitiesInserted { amount: u32 },
}
#[pallet::call]
@@ -1137,13 +1139,64 @@
) -> DispatchResult {
T::ForceOrigin::ensure_origin(origin)?;
for identity in identities.clone() {
- IdentityOf::<T>::set(identity, None);
+ let (_, sub_ids) = <SubsOf<T>>::take(&identity);
+ <IdentityOf<T>>::remove(&identity);
+ for sub in sub_ids.iter() {
+ <SuperOf<T>>::remove(sub);
+ }
}
Self::deposit_event(Event::IdentitiesRemoved {
amount: identities.len() as u32,
});
Ok(())
}
+
+ /// Set sub-identities to be associated with the provided accounts as force origin.
+ ///
+ /// This is not meant to operate in tandem with the identity pallet as is,
+ /// and be instead used to keep identities made and verified externally,
+ /// forbidden from interacting with an ordinary user, since it ignores any safety mechanism.
+ #[pallet::call_index(17)]
+ #[pallet::weight(T::WeightInfo::force_set_subs(
+ T::MaxSubAccounts::get(), // S
+ subs.len() as u32, // N
+ ))]
+ pub fn force_set_subs(
+ origin: OriginFor<T>,
+ subs: Vec<(
+ T::AccountId,
+ (
+ BalanceOf<T>,
+ BoundedVec<(T::AccountId, Data), T::MaxSubAccounts>,
+ ),
+ )>,
+ ) -> DispatchResult {
+ T::ForceOrigin::ensure_origin(origin)?;
+ for identity in subs.clone() {
+ let account = identity.0;
+ let (_, old_subs) = <SubsOf<T>>::get(&account);
+ for old_sub in old_subs {
+ <SuperOf<T>>::remove(old_sub);
+ }
+
+ let mut ids = BoundedVec::<T::AccountId, T::MaxSubAccounts>::default();
+ for (id, name) in identity.1 .1 {
+ <SuperOf<T>>::insert(&id, (account.clone(), name));
+ ids.try_push(id)
+ .expect("subs length is less than T::MaxSubAccounts; qed");
+ }
+
+ if ids.is_empty() {
+ <SubsOf<T>>::remove(&account);
+ } else {
+ <SubsOf<T>>::insert(account, (identity.1 .0, ids));
+ }
+ }
+ Self::deposit_event(Event::SubIdentitiesInserted {
+ amount: subs.len() as u32,
+ });
+ Ok(())
+ }
}
}
pallets/identity/src/weights.rsdiffbeforeafterboth1// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.2// This file is part of Unique Network.34// Unique Network is free software: you can redistribute it and/or modify5// it under the terms of the GNU General Public License as published by6// the Free Software Foundation, either version 3 of the License, or7// (at your option) any later version.89// Unique Network is distributed in the hope that it will be useful,10// but WITHOUT ANY WARRANTY; without even the implied warranty of11// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the12// GNU General Public License for more details.1314// You should have received a copy of the GNU General Public License15// along with Unique Network. If not, see <http://www.gnu.org/licenses/>.1617// Original license:18// This file is part of Substrate.1920// Copyright (C) 2022 Parity Technologies (UK) Ltd.21// SPDX-License-Identifier: Apache-2.02223// Licensed under the Apache License, Version 2.0 (the "License");24// you may not use this file except in compliance with the License.25// You may obtain a copy of the License at26//27// http://www.apache.org/licenses/LICENSE-2.028//29// Unless required by applicable law or agreed to in writing, software30// distributed under the License is distributed on an "AS IS" BASIS,31// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.32// See the License for the specific language governing permissions and33// limitations under the License.3435//! Autogenerated weights for pallet_identity36//!37//! THIS FILE WAS AUTO-GENERATED USING THE SUBSTRATE BENCHMARK CLI VERSION 4.0.0-dev38//! DATE: 2022-11-07, STEPS: `50`, REPEAT: 20, LOW RANGE: `[]`, HIGH RANGE: `[]`39//! HOSTNAME: `bm2`, CPU: `Intel(R) Core(TM) i7-7700K CPU @ 4.20GHz`40//! EXECUTION: Some(Wasm), WASM-EXECUTION: Compiled, CHAIN: Some("dev"), DB CACHE: 10244142// Executed Command:43// ./target/production/substrate44// benchmark45// pallet46// --chain=dev47// --steps=5048// --repeat=2049// --pallet=pallet_identity50// --extrinsic=*51// --execution=wasm52// --wasm-execution=compiled53// --heap-pages=409654// --output=./frame/identity/src/weights.rs55// --header=./HEADER-APACHE256// --template=./.maintain/frame-weight-template.hbs5758#![cfg_attr(rustfmt, rustfmt_skip)]59#![allow(unused_parens)]60#![allow(unused_imports)]6162use frame_support::{traits::Get, weights::{Weight, constants::RocksDbWeight}};63use sp_std::marker::PhantomData;6465/// Weight functions needed for pallet_identity.66pub trait WeightInfo {67 fn add_registrar(r: u32, ) -> Weight;68 fn set_identity(r: u32, x: u32, ) -> Weight;69 fn set_subs_new(s: u32, ) -> Weight;70 fn set_subs_old(p: u32, ) -> Weight;71 fn clear_identity(r: u32, s: u32, x: u32, ) -> Weight;72 fn request_judgement(r: u32, x: u32, ) -> Weight;73 fn cancel_request(r: u32, x: u32, ) -> Weight;74 fn set_fee(r: u32, ) -> Weight;75 fn set_account_id(r: u32, ) -> Weight;76 fn set_fields(r: u32, ) -> Weight;77 fn provide_judgement(r: u32, x: u32, ) -> Weight;78 fn kill_identity(r: u32, s: u32, x: u32, ) -> Weight;79 fn force_insert_identities(x: u32, n: u32, ) -> Weight;80 fn force_remove_identities(x: u32, n: u32, ) -> Weight;81 fn add_sub(s: u32, ) -> Weight;82 fn rename_sub(s: u32, ) -> Weight;83 fn remove_sub(s: u32, ) -> Weight;84 fn quit_sub(s: u32, ) -> Weight;85}8687/// Weights for pallet_identity using the Substrate node and recommended hardware.88pub struct SubstrateWeight<T>(PhantomData<T>);89impl<T: frame_system::Config> WeightInfo for SubstrateWeight<T> {90 // Storage: Identity Registrars (r:1 w:1)91 /// The range of component `r` is `[1, 19]`.92 fn add_registrar(r: u32, ) -> Weight {93 // Minimum execution time: 20_269 nanoseconds.94 Weight::from_ref_time(21_910_543 as u64)95 // Standard Error: 4_60496 .saturating_add(Weight::from_ref_time(223_104 as u64).saturating_mul(r as u64))97 .saturating_add(T::DbWeight::get().reads(1 as u64))98 .saturating_add(T::DbWeight::get().writes(1 as u64))99 }100 // Storage: Identity IdentityOf (r:1 w:1)101 /// The range of component `r` is `[1, 20]`.102 /// The range of component `x` is `[0, 100]`.103 fn set_identity(r: u32, x: u32, ) -> Weight {104 // Minimum execution time: 41_872 nanoseconds.105 Weight::from_ref_time(40_230_216 as u64)106 // Standard Error: 2_342107 .saturating_add(Weight::from_ref_time(145_168 as u64).saturating_mul(r as u64))108 // Standard Error: 457109 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))110 .saturating_add(T::DbWeight::get().reads(1 as u64))111 .saturating_add(T::DbWeight::get().writes(1 as u64))112 }113 // Storage: Identity IdentityOf (r:1 w:0)114 // Storage: Identity SubsOf (r:1 w:1)115 // Storage: Identity SuperOf (r:2 w:2)116 /// The range of component `s` is `[0, 100]`.117 fn set_subs_new(s: u32, ) -> Weight {118 // Minimum execution time: 12_024 nanoseconds.119 Weight::from_ref_time(32_550_819 as u64)120 // Standard Error: 5_057121 .saturating_add(Weight::from_ref_time(2_521_245 as u64).saturating_mul(s as u64))122 .saturating_add(T::DbWeight::get().reads(2 as u64))123 .saturating_add(T::DbWeight::get().reads((1 as u64).saturating_mul(s as u64)))124 .saturating_add(T::DbWeight::get().writes(1 as u64))125 .saturating_add(T::DbWeight::get().writes((1 as u64).saturating_mul(s as u64)))126 }127 // Storage: Identity IdentityOf (r:1 w:0)128 // Storage: Identity SubsOf (r:1 w:1)129 // Storage: Identity SuperOf (r:0 w:2)130 /// The range of component `p` is `[0, 100]`.131 fn set_subs_old(p: u32, ) -> Weight {132 // Minimum execution time: 12_232 nanoseconds.133 Weight::from_ref_time(34_009_761 as u64)134 // Standard Error: 5_047135 .saturating_add(Weight::from_ref_time(1_113_100 as u64).saturating_mul(p as u64))136 .saturating_add(T::DbWeight::get().reads(2 as u64))137 .saturating_add(T::DbWeight::get().writes(1 as u64))138 .saturating_add(T::DbWeight::get().writes((1 as u64).saturating_mul(p as u64)))139 }140 // Storage: Identity SubsOf (r:1 w:1)141 // Storage: Identity IdentityOf (r:1 w:1)142 // Storage: Identity SuperOf (r:0 w:100)143 /// The range of component `r` is `[1, 20]`.144 /// The range of component `s` is `[0, 100]`.145 /// The range of component `x` is `[0, 100]`.146 fn clear_identity(r: u32, s: u32, x: u32, ) -> Weight {147 // Minimum execution time: 57_144 nanoseconds.148 Weight::from_ref_time(41_559_247 as u64)149 // Standard Error: 9_996150 .saturating_add(Weight::from_ref_time(146_770 as u64).saturating_mul(r as u64))151 // Standard Error: 1_952152 .saturating_add(Weight::from_ref_time(1_086_673 as u64).saturating_mul(s as u64))153 // Standard Error: 1_952154 .saturating_add(Weight::from_ref_time(162_481 as u64).saturating_mul(x as u64))155 .saturating_add(T::DbWeight::get().reads(2 as u64))156 .saturating_add(T::DbWeight::get().writes(2 as u64))157 .saturating_add(T::DbWeight::get().writes((1 as u64).saturating_mul(s as u64)))158 }159 // Storage: Identity Registrars (r:1 w:0)160 // Storage: Identity IdentityOf (r:1 w:1)161 /// The range of component `r` is `[1, 20]`.162 /// The range of component `x` is `[0, 100]`.163 fn request_judgement(r: u32, x: u32, ) -> Weight {164 // Minimum execution time: 44_726 nanoseconds.165 Weight::from_ref_time(41_637_308 as u64)166 // Standard Error: 1_907167 .saturating_add(Weight::from_ref_time(219_078 as u64).saturating_mul(r as u64))168 // Standard Error: 372169 .saturating_add(Weight::from_ref_time(309_888 as u64).saturating_mul(x as u64))170 .saturating_add(T::DbWeight::get().reads(2 as u64))171 .saturating_add(T::DbWeight::get().writes(1 as u64))172 }173 // Storage: Identity IdentityOf (r:1 w:1)174 /// The range of component `r` is `[1, 20]`.175 /// The range of component `x` is `[0, 100]`.176 fn cancel_request(r: u32, x: u32, ) -> Weight {177 // Minimum execution time: 39_719 nanoseconds.178 Weight::from_ref_time(38_008_751 as u64)179 // Standard Error: 2_394180 .saturating_add(Weight::from_ref_time(181_870 as u64).saturating_mul(r as u64))181 // Standard Error: 467182 .saturating_add(Weight::from_ref_time(314_990 as u64).saturating_mul(x as u64))183 .saturating_add(T::DbWeight::get().reads(1 as u64))184 .saturating_add(T::DbWeight::get().writes(1 as u64))185 }186 // Storage: Identity Registrars (r:1 w:1)187 /// The range of component `r` is `[1, 19]`.188 fn set_fee(r: u32, ) -> Weight {189 // Minimum execution time: 10_634 nanoseconds.190 Weight::from_ref_time(11_383_704 as u64)191 // Standard Error: 2_250192 .saturating_add(Weight::from_ref_time(193_094 as u64).saturating_mul(r as u64))193 .saturating_add(T::DbWeight::get().reads(1 as u64))194 .saturating_add(T::DbWeight::get().writes(1 as u64))195 }196 // Storage: Identity Registrars (r:1 w:1)197 /// The range of component `r` is `[1, 19]`.198 fn set_account_id(r: u32, ) -> Weight {199 // Minimum execution time: 10_840 nanoseconds.200 Weight::from_ref_time(11_638_740 as u64)201 // Standard Error: 1_985202 .saturating_add(Weight::from_ref_time(193_016 as u64).saturating_mul(r as u64))203 .saturating_add(T::DbWeight::get().reads(1 as u64))204 .saturating_add(T::DbWeight::get().writes(1 as u64))205 }206 // Storage: Identity Registrars (r:1 w:1)207 /// The range of component `r` is `[1, 19]`.208 fn set_fields(r: u32, ) -> Weight {209 // Minimum execution time: 10_748 nanoseconds.210 Weight::from_ref_time(11_346_901 as u64)211 // Standard Error: 2_132212 .saturating_add(Weight::from_ref_time(196_630 as u64).saturating_mul(r as u64))213 .saturating_add(T::DbWeight::get().reads(1 as u64))214 .saturating_add(T::DbWeight::get().writes(1 as u64))215 }216 // Storage: Identity Registrars (r:1 w:0)217 // Storage: Identity IdentityOf (r:1 w:1)218 /// The range of component `r` is `[1, 19]`.219 /// The range of component `x` is `[0, 100]`.220 fn provide_judgement(r: u32, x: u32, ) -> Weight {221 // Minimum execution time: 33_682 nanoseconds.222 Weight::from_ref_time(31_336_603 as u64)223 // Standard Error: 3_056224 .saturating_add(Weight::from_ref_time(200_403 as u64).saturating_mul(r as u64))225 // Standard Error: 565226 .saturating_add(Weight::from_ref_time(525_142 as u64).saturating_mul(x as u64))227 .saturating_add(T::DbWeight::get().reads(2 as u64))228 .saturating_add(T::DbWeight::get().writes(1 as u64))229 }230 // Storage: Identity SubsOf (r:1 w:1)231 // Storage: Identity IdentityOf (r:1 w:1)232 // Storage: System Account (r:1 w:1)233 // Storage: Identity SuperOf (r:0 w:100)234 /// The range of component `r` is `[1, 20]`.235 /// The range of component `s` is `[0, 100]`.236 /// The range of component `x` is `[0, 100]`.237 fn kill_identity(r: u32, s: u32, x: u32, ) -> Weight {238 // Minimum execution time: 68_794 nanoseconds.239 Weight::from_ref_time(52_114_486 as u64)240 // Standard Error: 4_808241 .saturating_add(Weight::from_ref_time(153_462 as u64).saturating_mul(r as u64))242 // Standard Error: 939243 .saturating_add(Weight::from_ref_time(1_084_612 as u64).saturating_mul(s as u64))244 // Standard Error: 939245 .saturating_add(Weight::from_ref_time(170_112 as u64).saturating_mul(x as u64))246 .saturating_add(T::DbWeight::get().reads(3 as u64))247 .saturating_add(T::DbWeight::get().writes(3 as u64))248 .saturating_add(T::DbWeight::get().writes((1 as u64).saturating_mul(s as u64)))249 }250 // Storage: Identity IdentityOf (r:1 w:1)251 /// The range of component `x` is `[0, 100]`.252 /// The range of component `n` is `[0, 600]`.253 fn force_insert_identities(x: u32, n: u32) -> Weight {254 // Minimum execution time: 41_872 nanoseconds.255 Weight::from_ref_time(40_230_216 as u64)256 // Standard Error: 2_342257 .saturating_add(Weight::from_ref_time(145_168 as u64))258 // Standard Error: 457259 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))260 .saturating_add(T::DbWeight::get().reads(1 as u64))261 .saturating_add(T::DbWeight::get().writes(1 as u64).saturating_mul(n as u64))262 }263 // Storage: Identity IdentityOf (r:1 w:1)264 /// The range of component `x` is `[0, 100]`.265 /// The range of component `n` is `[0, 600]`.266 fn force_remove_identities(x: u32, n: u32) -> Weight {267 // Minimum execution time: 41_872 nanoseconds.268 Weight::from_ref_time(40_230_216 as u64)269 // Standard Error: 2_342270 .saturating_add(Weight::from_ref_time(145_168 as u64))271 // Standard Error: 457272 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))273 .saturating_add(T::DbWeight::get().reads(1 as u64))274 .saturating_add(T::DbWeight::get().writes(1 as u64).saturating_mul(n as u64))275 }276 // Storage: Identity IdentityOf (r:1 w:0)277 // Storage: Identity SuperOf (r:1 w:1)278 // Storage: Identity SubsOf (r:1 w:1)279 /// The range of component `s` is `[0, 99]`.280 fn add_sub(s: u32, ) -> Weight {281 // Minimum execution time: 37_914 nanoseconds.282 Weight::from_ref_time(43_488_083 as u64)283 // Standard Error: 1_631284 .saturating_add(Weight::from_ref_time(118_845 as u64).saturating_mul(s as u64))285 .saturating_add(T::DbWeight::get().reads(3 as u64))286 .saturating_add(T::DbWeight::get().writes(2 as u64))287 }288 // Storage: Identity IdentityOf (r:1 w:0)289 // Storage: Identity SuperOf (r:1 w:1)290 /// The range of component `s` is `[1, 100]`.291 fn rename_sub(s: u32, ) -> Weight {292 // Minimum execution time: 16_124 nanoseconds.293 Weight::from_ref_time(18_580_462 as u64)294 // Standard Error: 688295 .saturating_add(Weight::from_ref_time(67_220 as u64).saturating_mul(s as u64))296 .saturating_add(T::DbWeight::get().reads(2 as u64))297 .saturating_add(T::DbWeight::get().writes(1 as u64))298 }299 // Storage: Identity IdentityOf (r:1 w:0)300 // Storage: Identity SuperOf (r:1 w:1)301 // Storage: Identity SubsOf (r:1 w:1)302 /// The range of component `s` is `[1, 100]`.303 fn remove_sub(s: u32, ) -> Weight {304 // Minimum execution time: 41_517 nanoseconds.305 Weight::from_ref_time(45_123_530 as u64)306 // Standard Error: 1_530307 .saturating_add(Weight::from_ref_time(105_429 as u64).saturating_mul(s as u64))308 .saturating_add(T::DbWeight::get().reads(3 as u64))309 .saturating_add(T::DbWeight::get().writes(2 as u64))310 }311 // Storage: Identity SuperOf (r:1 w:1)312 // Storage: Identity SubsOf (r:1 w:1)313 /// The range of component `s` is `[0, 99]`.314 fn quit_sub(s: u32, ) -> Weight {315 // Minimum execution time: 30_171 nanoseconds.316 Weight::from_ref_time(33_355_514 as u64)317 // Standard Error: 1_286318 .saturating_add(Weight::from_ref_time(114_716 as u64).saturating_mul(s as u64))319 .saturating_add(T::DbWeight::get().reads(2 as u64))320 .saturating_add(T::DbWeight::get().writes(2 as u64))321 }322}323324// For backwards compatibility and tests325impl WeightInfo for () {326 // Storage: Identity Registrars (r:1 w:1)327 /// The range of component `r` is `[1, 19]`.328 fn add_registrar(r: u32, ) -> Weight {329 // Minimum execution time: 20_269 nanoseconds.330 Weight::from_ref_time(21_910_543 as u64)331 // Standard Error: 4_604332 .saturating_add(Weight::from_ref_time(223_104 as u64).saturating_mul(r as u64))333 .saturating_add(RocksDbWeight::get().reads(1 as u64))334 .saturating_add(RocksDbWeight::get().writes(1 as u64))335 }336 // Storage: Identity IdentityOf (r:1 w:1)337 /// The range of component `r` is `[1, 20]`.338 /// The range of component `x` is `[0, 100]`.339 fn set_identity(r: u32, x: u32, ) -> Weight {340 // Minimum execution time: 41_872 nanoseconds.341 Weight::from_ref_time(40_230_216 as u64)342 // Standard Error: 2_342343 .saturating_add(Weight::from_ref_time(145_168 as u64).saturating_mul(r as u64))344 // Standard Error: 457345 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))346 .saturating_add(RocksDbWeight::get().reads(1 as u64))347 .saturating_add(RocksDbWeight::get().writes(1 as u64))348 }349 // Storage: Identity IdentityOf (r:1 w:0)350 // Storage: Identity SubsOf (r:1 w:1)351 // Storage: Identity SuperOf (r:2 w:2)352 /// The range of component `s` is `[0, 100]`.353 fn set_subs_new(s: u32, ) -> Weight {354 // Minimum execution time: 12_024 nanoseconds.355 Weight::from_ref_time(32_550_819 as u64)356 // Standard Error: 5_057357 .saturating_add(Weight::from_ref_time(2_521_245 as u64).saturating_mul(s as u64))358 .saturating_add(RocksDbWeight::get().reads(2 as u64))359 .saturating_add(RocksDbWeight::get().reads((1 as u64).saturating_mul(s as u64)))360 .saturating_add(RocksDbWeight::get().writes(1 as u64))361 .saturating_add(RocksDbWeight::get().writes((1 as u64).saturating_mul(s as u64)))362 }363 // Storage: Identity IdentityOf (r:1 w:0)364 // Storage: Identity SubsOf (r:1 w:1)365 // Storage: Identity SuperOf (r:0 w:2)366 /// The range of component `p` is `[0, 100]`.367 fn set_subs_old(p: u32, ) -> Weight {368 // Minimum execution time: 12_232 nanoseconds.369 Weight::from_ref_time(34_009_761 as u64)370 // Standard Error: 5_047371 .saturating_add(Weight::from_ref_time(1_113_100 as u64).saturating_mul(p as u64))372 .saturating_add(RocksDbWeight::get().reads(2 as u64))373 .saturating_add(RocksDbWeight::get().writes(1 as u64))374 .saturating_add(RocksDbWeight::get().writes((1 as u64).saturating_mul(p as u64)))375 }376 // Storage: Identity SubsOf (r:1 w:1)377 // Storage: Identity IdentityOf (r:1 w:1)378 // Storage: Identity SuperOf (r:0 w:100)379 /// The range of component `r` is `[1, 20]`.380 /// The range of component `s` is `[0, 100]`.381 /// The range of component `x` is `[0, 100]`.382 fn clear_identity(r: u32, s: u32, x: u32, ) -> Weight {383 // Minimum execution time: 57_144 nanoseconds.384 Weight::from_ref_time(41_559_247 as u64)385 // Standard Error: 9_996386 .saturating_add(Weight::from_ref_time(146_770 as u64).saturating_mul(r as u64))387 // Standard Error: 1_952388 .saturating_add(Weight::from_ref_time(1_086_673 as u64).saturating_mul(s as u64))389 // Standard Error: 1_952390 .saturating_add(Weight::from_ref_time(162_481 as u64).saturating_mul(x as u64))391 .saturating_add(RocksDbWeight::get().reads(2 as u64))392 .saturating_add(RocksDbWeight::get().writes(2 as u64))393 .saturating_add(RocksDbWeight::get().writes((1 as u64).saturating_mul(s as u64)))394 }395 // Storage: Identity Registrars (r:1 w:0)396 // Storage: Identity IdentityOf (r:1 w:1)397 /// The range of component `r` is `[1, 20]`.398 /// The range of component `x` is `[0, 100]`.399 fn request_judgement(r: u32, x: u32, ) -> Weight {400 // Minimum execution time: 44_726 nanoseconds.401 Weight::from_ref_time(41_637_308 as u64)402 // Standard Error: 1_907403 .saturating_add(Weight::from_ref_time(219_078 as u64).saturating_mul(r as u64))404 // Standard Error: 372405 .saturating_add(Weight::from_ref_time(309_888 as u64).saturating_mul(x as u64))406 .saturating_add(RocksDbWeight::get().reads(2 as u64))407 .saturating_add(RocksDbWeight::get().writes(1 as u64))408 }409 // Storage: Identity IdentityOf (r:1 w:1)410 /// The range of component `r` is `[1, 20]`.411 /// The range of component `x` is `[0, 100]`.412 fn cancel_request(r: u32, x: u32, ) -> Weight {413 // Minimum execution time: 39_719 nanoseconds.414 Weight::from_ref_time(38_008_751 as u64)415 // Standard Error: 2_394416 .saturating_add(Weight::from_ref_time(181_870 as u64).saturating_mul(r as u64))417 // Standard Error: 467418 .saturating_add(Weight::from_ref_time(314_990 as u64).saturating_mul(x as u64))419 .saturating_add(RocksDbWeight::get().reads(1 as u64))420 .saturating_add(RocksDbWeight::get().writes(1 as u64))421 }422 // Storage: Identity Registrars (r:1 w:1)423 /// The range of component `r` is `[1, 19]`.424 fn set_fee(r: u32, ) -> Weight {425 // Minimum execution time: 10_634 nanoseconds.426 Weight::from_ref_time(11_383_704 as u64)427 // Standard Error: 2_250428 .saturating_add(Weight::from_ref_time(193_094 as u64).saturating_mul(r as u64))429 .saturating_add(RocksDbWeight::get().reads(1 as u64))430 .saturating_add(RocksDbWeight::get().writes(1 as u64))431 }432 // Storage: Identity Registrars (r:1 w:1)433 /// The range of component `r` is `[1, 19]`.434 fn set_account_id(r: u32, ) -> Weight {435 // Minimum execution time: 10_840 nanoseconds.436 Weight::from_ref_time(11_638_740 as u64)437 // Standard Error: 1_985438 .saturating_add(Weight::from_ref_time(193_016 as u64).saturating_mul(r as u64))439 .saturating_add(RocksDbWeight::get().reads(1 as u64))440 .saturating_add(RocksDbWeight::get().writes(1 as u64))441 }442 // Storage: Identity Registrars (r:1 w:1)443 /// The range of component `r` is `[1, 19]`.444 fn set_fields(r: u32, ) -> Weight {445 // Minimum execution time: 10_748 nanoseconds.446 Weight::from_ref_time(11_346_901 as u64)447 // Standard Error: 2_132448 .saturating_add(Weight::from_ref_time(196_630 as u64).saturating_mul(r as u64))449 .saturating_add(RocksDbWeight::get().reads(1 as u64))450 .saturating_add(RocksDbWeight::get().writes(1 as u64))451 }452 // Storage: Identity Registrars (r:1 w:0)453 // Storage: Identity IdentityOf (r:1 w:1)454 /// The range of component `r` is `[1, 19]`.455 /// The range of component `x` is `[0, 100]`.456 fn provide_judgement(r: u32, x: u32, ) -> Weight {457 // Minimum execution time: 33_682 nanoseconds.458 Weight::from_ref_time(31_336_603 as u64)459 // Standard Error: 3_056460 .saturating_add(Weight::from_ref_time(200_403 as u64).saturating_mul(r as u64))461 // Standard Error: 565462 .saturating_add(Weight::from_ref_time(525_142 as u64).saturating_mul(x as u64))463 .saturating_add(RocksDbWeight::get().reads(2 as u64))464 .saturating_add(RocksDbWeight::get().writes(1 as u64))465 }466 // Storage: Identity SubsOf (r:1 w:1)467 // Storage: Identity IdentityOf (r:1 w:1)468 // Storage: System Account (r:1 w:1)469 // Storage: Identity SuperOf (r:0 w:100)470 /// The range of component `r` is `[1, 20]`.471 /// The range of component `s` is `[0, 100]`.472 /// The range of component `x` is `[0, 100]`.473 fn kill_identity(r: u32, s: u32, x: u32, ) -> Weight {474 // Minimum execution time: 68_794 nanoseconds.475 Weight::from_ref_time(52_114_486 as u64)476 // Standard Error: 4_808477 .saturating_add(Weight::from_ref_time(153_462 as u64).saturating_mul(r as u64))478 // Standard Error: 939479 .saturating_add(Weight::from_ref_time(1_084_612 as u64).saturating_mul(s as u64))480 // Standard Error: 939481 .saturating_add(Weight::from_ref_time(170_112 as u64).saturating_mul(x as u64))482 .saturating_add(RocksDbWeight::get().reads(3 as u64))483 .saturating_add(RocksDbWeight::get().writes(3 as u64))484 .saturating_add(RocksDbWeight::get().writes((1 as u64).saturating_mul(s as u64)))485 }486 // Storage: Identity IdentityOf (r:1 w:1)487 /// The range of component `x` is `[0, 100]`.488 /// The range of component `n` is `[0, 600]`.489 fn force_insert_identities(x: u32, n: u32) -> Weight {490 // Minimum execution time: 41_872 nanoseconds.491 Weight::from_ref_time(40_230_216 as u64)492 // Standard Error: 2_342493 .saturating_add(Weight::from_ref_time(145_168 as u64))494 // Standard Error: 457495 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))496 .saturating_add(RocksDbWeight::get().reads(1 as u64))497 .saturating_add(RocksDbWeight::get().writes(1 as u64).saturating_mul(n as u64))498 }499 // Storage: Identity IdentityOf (r:1 w:1)500 /// The range of component `x` is `[0, 100]`.501 /// The range of component `n` is `[0, 600]`.502 fn force_remove_identities(x: u32, n: u32) -> Weight {503 // Minimum execution time: 41_872 nanoseconds.504 Weight::from_ref_time(40_230_216 as u64)505 // Standard Error: 2_342506 .saturating_add(Weight::from_ref_time(145_168 as u64))507 // Standard Error: 457508 .saturating_add(Weight::from_ref_time(291_732 as u64).saturating_mul(x as u64))509 .saturating_add(RocksDbWeight::get().reads(1 as u64))510 .saturating_add(RocksDbWeight::get().writes(1 as u64).saturating_mul(n as u64))511 }512 // Storage: Identity IdentityOf (r:1 w:0)513 // Storage: Identity SuperOf (r:1 w:1)514 // Storage: Identity SubsOf (r:1 w:1)515 /// The range of component `s` is `[0, 99]`.516 fn add_sub(s: u32, ) -> Weight {517 // Minimum execution time: 37_914 nanoseconds.518 Weight::from_ref_time(43_488_083 as u64)519 // Standard Error: 1_631520 .saturating_add(Weight::from_ref_time(118_845 as u64).saturating_mul(s as u64))521 .saturating_add(RocksDbWeight::get().reads(3 as u64))522 .saturating_add(RocksDbWeight::get().writes(2 as u64))523 }524 // Storage: Identity IdentityOf (r:1 w:0)525 // Storage: Identity SuperOf (r:1 w:1)526 /// The range of component `s` is `[1, 100]`.527 fn rename_sub(s: u32, ) -> Weight {528 // Minimum execution time: 16_124 nanoseconds.529 Weight::from_ref_time(18_580_462 as u64)530 // Standard Error: 688531 .saturating_add(Weight::from_ref_time(67_220 as u64).saturating_mul(s as u64))532 .saturating_add(RocksDbWeight::get().reads(2 as u64))533 .saturating_add(RocksDbWeight::get().writes(1 as u64))534 }535 // Storage: Identity IdentityOf (r:1 w:0)536 // Storage: Identity SuperOf (r:1 w:1)537 // Storage: Identity SubsOf (r:1 w:1)538 /// The range of component `s` is `[1, 100]`.539 fn remove_sub(s: u32, ) -> Weight {540 // Minimum execution time: 41_517 nanoseconds.541 Weight::from_ref_time(45_123_530 as u64)542 // Standard Error: 1_530543 .saturating_add(Weight::from_ref_time(105_429 as u64).saturating_mul(s as u64))544 .saturating_add(RocksDbWeight::get().reads(3 as u64))545 .saturating_add(RocksDbWeight::get().writes(2 as u64))546 }547 // Storage: Identity SuperOf (r:1 w:1)548 // Storage: Identity SubsOf (r:1 w:1)549 /// The range of component `s` is `[0, 99]`.550 fn quit_sub(s: u32, ) -> Weight {551 // Minimum execution time: 30_171 nanoseconds.552 Weight::from_ref_time(33_355_514 as u64)553 // Standard Error: 1_286554 .saturating_add(Weight::from_ref_time(114_716 as u64).saturating_mul(s as u64))555 .saturating_add(RocksDbWeight::get().reads(2 as u64))556 .saturating_add(RocksDbWeight::get().writes(2 as u64))557 }558}tests/src/collator-selection/identity.seqtest.tsdiffbeforeafterboth--- a/tests/src/collator-selection/identity.seqtest.ts
+++ b/tests/src/collator-selection/identity.seqtest.ts
@@ -29,6 +29,14 @@
return (await getIdentities(helper)).flatMap(([key, _value]) => key);
}
+async function getSubIdentityAccounts(helper: UniqueHelper, address: string) {
+ return ((await helper.getApi().query.identity.subsOf(address)).toHuman() as any)[1];
+}
+
+async function getSubIdentityName(helper: UniqueHelper, address: string) {
+ return ((await helper.getApi().query.identity.superOf(address)).toHuman() as any);
+}
+
describe('Integration Test: Identities Manipulation', () => {
let superuser: IKeyringPair;
@@ -47,49 +55,220 @@
.to.be.rejectedWith(/Transaction call is not expected/);
});
- itSub('Sets identities', async ({helper}) => {
- const oldIdentitiesCount = (await getIdentityAccounts(helper)).length;
+ describe('Identities', () => {
+ itSub('Sets identities', async ({helper}) => {
+ const oldIdentitiesCount = (await getIdentityAccounts(helper)).length;
- const crowdSize = 10;
- const crowd = await helper.arrange.createCrowd(crowdSize, 0n, superuser);
- const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
+ const crowdSize = 10;
+ const crowd = await helper.arrange.createCrowd(crowdSize, 0n, superuser);
+ const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
- expect((await getIdentityAccounts(helper)).length).to.be.equal(oldIdentitiesCount + crowdSize);
- });
+ expect((await getIdentityAccounts(helper)).length).to.be.equal(oldIdentitiesCount + crowdSize);
+ });
- itSub('Setting identities does not delete existing but does overwrite', async ({helper}) => {
- const crowd = await helper.arrange.createCrowd(10, 0n, superuser);
- const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
+ itSub('Setting identities does not delete existing but does overwrite', async ({helper}) => {
+ const crowd = await helper.arrange.createCrowd(10, 0n, superuser);
+ const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
+
+ // insert a single identity
+ let singleIdentity = identities.pop()!;
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [[singleIdentity]]);
- // insert a single identity
- let singleIdentity = identities.pop()!;
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [[singleIdentity]]);
+ const oldIdentitiesCount = (await getIdentityAccounts(helper)).length;
- const oldIdentitiesCount = (await getIdentityAccounts(helper)).length;
+ // change an identity and push it with a few new others
+ singleIdentity = [singleIdentity[0], {info: {display: {Raw: 'something special'}}}];
+ identities.push(singleIdentity);
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
- // change an identity and push it with a few new others
- singleIdentity = [singleIdentity[0], {info: {display: {Raw: 'something special'}}}];
- identities.push(singleIdentity);
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
+ // oldIdentitiesCount + 9 because one identity is overwritten, not inserted on top
+ expect((await getIdentityAccounts(helper)).length).to.be.equal(oldIdentitiesCount + 9);
+ expect((await helper.callRpc('api.query.identity.identityOf', [singleIdentity[0]])).toHuman().info.display)
+ .to.be.deep.equal({Raw: 'something special'});
+ });
- // oldIdentitiesCount + 9 because one identity is overwritten, not inserted on top
- expect((await getIdentityAccounts(helper)).length).to.be.equal(oldIdentitiesCount + 9);
- expect((await helper.callRpc('api.query.identity.identityOf', [singleIdentity[0]])).toHuman().info.display)
- .to.be.deep.equal({Raw: 'something special'});
+ itSub('Removes identities', async ({helper}) => {
+ const crowd = await helper.arrange.createCrowd(10, 0n, superuser);
+ const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
+ const oldIdentities = await getIdentityAccounts(helper);
+
+ // delete a couple, check that they are no longer there
+ const scapegoats = [crowd.pop()!.address, crowd.pop()!.address];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceRemoveIdentities', [scapegoats]);
+ const newIdentities = await getIdentityAccounts(helper);
+ expect(newIdentities.concat(scapegoats)).to.be.have.members(oldIdentities);
+ });
});
- itSub('Removes identities', async ({helper}) => {
- const crowd = await helper.arrange.createCrowd(10, 0n, superuser);
- const identities = crowd.map((acc, i) => [acc.address, {info: {display: {Raw: `accounter #${i}`}}}]);
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
- const oldIdentities = await getIdentityAccounts(helper);
+ describe('Sub-identities', () => {
+ itSub('Sets subs', async ({helper}) => {
+ const crowdSize = 18;
+ const crowd = await helper.arrange.createCrowd(crowdSize, 0n, superuser);
+ const supers = [crowd.pop()!, crowd.pop()!, crowd.pop()!];
- // delete a couple, check that they are no longer there
- const scapegoats = [crowd.pop()!.address, crowd.pop()!.address];
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceRemoveIdentities', [scapegoats]);
- const newIdentities = await getIdentityAccounts(helper);
- expect(newIdentities.concat(scapegoats)).to.be.have.members(oldIdentities);
+ const subsPerSup = crowd.length / supers.length;
+ let subCount = 0;
+ const subs = [
+ crowd.slice(subCount, subCount += subsPerSup + 1),
+ crowd.slice(subCount, subCount += subsPerSup),
+ crowd.slice(subCount, subCount += subsPerSup - 1),
+ ];
+
+ const subsInfo = supers.map((acc, i) => [
+ acc.address, [
+ 1000000n + BigInt(i + 1),
+ subs[i].map((sub, j) => [
+ sub.address, {Raw: `accounter #${j}`},
+ ]),
+ ],
+ ]);
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo]);
+
+ for (let i = 0; i < supers.length; i++) {
+ // check deposit
+ expect(((await helper.getApi().query.identity.subsOf(supers[i].address)).toJSON() as any)[0]).to.be.equal(1000001 + i);
+
+ const subsAccounts = await getSubIdentityAccounts(helper, supers[i].address);
+ // check sub-identities as account ids
+ expect(subsAccounts).to.include.members(subs[i].map(x => x.address));
+
+ for (let j = 0; j < subsAccounts.length; j++) {
+ // check sub-identities' names
+ expect((await getSubIdentityName(helper, subsAccounts[j]))[1]).to.be.deep.equal({Raw: `accounter #${j}`});
+ }
+ }
+ });
+
+ itSub('Setting sub-identities does not delete other existing but does overwrite own', async ({helper}) => {
+ const crowdSize = 18;
+ const crowd = await helper.arrange.createCrowd(crowdSize, 0n, superuser);
+ const supers = [crowd.pop()!, crowd.pop()!, crowd.pop()!];
+
+ const subsPerSup = crowd.length / supers.length;
+ let subCount = 0;
+ const subs = [
+ crowd.slice(subCount, subCount += subsPerSup + 1),
+ crowd.slice(subCount, subCount += subsPerSup),
+ crowd.slice(subCount, subCount += subsPerSup - 1),
+ ];
+
+ const subsInfo1 = supers.map((acc, i) => [
+ acc.address, [
+ 1000000n + BigInt(i + 1),
+ subs[i].map((sub, j) => [
+ sub.address, {Raw: `accounter #${j}`},
+ ]),
+ ],
+ ]);
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo1]);
+
+ // change some sub-identities...
+ subs[2].pop(); subs[2].pop(); subs[2].push(...await helper.arrange.createAccounts([0n], superuser));
+
+ // ...and set them
+ const subsInfo2 = [[
+ supers[2].address, [
+ 999999n,
+ subs[2].map((sub, j) => [
+ sub.address, {Raw: `discounter #${j}`},
+ ]),
+ ],
+ ]];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo2]);
+
+ // make sure everything else is the same
+ for (let i = 0; i < supers.length - 1; i++) {
+ // check deposit
+ expect(((await helper.getApi().query.identity.subsOf(supers[i].address)).toJSON() as any)[0]).to.be.equal(1000001 + i);
+
+ const subsAccounts = await getSubIdentityAccounts(helper, supers[i].address);
+ // check sub-identities as account ids
+ expect(subsAccounts).to.include.members(subs[i].map(x => x.address));
+
+ for (let j = 0; j < subsAccounts; j++) {
+ // check sub-identities' names
+ expect((await getSubIdentityName(helper, subsAccounts[j]))[1]).to.be.deep.equal({Raw: `accounter #${j}`});
+ }
+ }
+
+ // check deposit
+ expect(((await helper.getApi().query.identity.subsOf(supers[2].address)).toJSON() as any)[0]).to.be.equal(999999);
+
+ const subsAccounts = await getSubIdentityAccounts(helper, supers[2].address);
+ // check sub-identities as account ids
+ expect(subsAccounts).to.include.members(subs[2].map(x => x.address));
+
+ for (let j = 0; j < subsAccounts.length; j++) {
+ // check sub-identities' names
+ expect((await getSubIdentityName(helper, subsAccounts[j]))[1]).to.be.deep.equal({Raw: `discounter #${j}`});
+ }
+ });
+
+ itSub('Removes sub-identities', async ({helper}) => {
+ const crowdSize = 3;
+ const crowd = await helper.arrange.createCrowd(crowdSize, 0n, superuser);
+ const sup = crowd.pop()!;
+
+ const subsInfo1 = [[
+ sup.address, [
+ 1000000n,
+ crowd.map((sub, j) => [
+ sub.address, {Raw: `accounter #${j}`},
+ ]),
+ ],
+ ]];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo1]);
+
+ // empty sub-identities should delete the records
+ const subsInfo2 = [[
+ sup.address, [
+ 1000000n,
+ [],
+ ],
+ ]];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo2]);
+
+ // check deposit
+ expect((await helper.getApi().query.identity.subsOf(sup.address)).toHuman()).to.be.deep.equal(['0', []]);
+
+ for (let j = 0; j < crowd.length; j++) {
+ // check sub-identities' names
+ expect((await getSubIdentityName(helper, crowd[j].address))).to.be.null;
+ }
+ });
+
+ itSub('Removing identities deletes associated sub-identities', async ({helper}) => {
+ const crowd = await helper.arrange.createCrowd(3, 0n, superuser);
+ const sup = crowd.pop()!;
+
+ // insert identity
+ const identities = [[sup.address, {info: {display: {Raw: 'mental'}}}]];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identities]);
+
+ // and its sub-identities
+ const subsInfo = [[
+ sup.address, [
+ 1000000n,
+ crowd.map((sub, j) => [
+ sub.address, {Raw: `accounter #${j}`},
+ ]),
+ ],
+ ]];
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsInfo]);
+
+ // delete top identity
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceRemoveIdentities', [[sup.address]]);
+
+ // check that sub-identities are deleted
+ expect((await helper.getApi().query.identity.subsOf(sup.address)).toHuman()).to.be.deep.equal(['0', []]);
+
+ for (let j = 0; j < crowd.length; j++) {
+ // check sub-identities' names
+ expect((await getSubIdentityName(helper, crowd[j].address))).to.be.null;
+ }
+ });
});
after(async function() {
tests/src/util/identitySetter.tsdiffbeforeafterboth--- a/tests/src/util/identitySetter.ts
+++ b/tests/src/util/identitySetter.ts
@@ -1,5 +1,8 @@
// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
// SPDX-License-Identifier: Apache-2.0
+//
+// Usage: `yarn setIdentities [relay WS URL] [parachain WS URL] [sudo key]`
+// Example: `yarn setIdentities wss://polkadot-rpc.dwellir.com ws://localhost:9944 escape pattern miracle train sudden cart adapt embark wedding alien lamp mesh`
import {encodeAddress} from '@polkadot/keyring';
import {usingPlaygrounds, Pallets} from './index';
@@ -9,36 +12,81 @@
const paraUrl = process.argv[3] ?? 'ws://localhost:9944';
const key = process.argv.length > 4 ? process.argv.slice(4).join(' ') : '//Alice';
+function extractAccountId(key: any): string {
+ return (key as any).toHuman()[0];
+}
+
function extractIdentity(key: any, value: any): [string, any] {
- return [(key as any).toHuman()[0], (value as any).unwrap()];
+ return [extractAccountId(key), (value as any).unwrap()];
}
-async function getIdentities(helper: ChainHelperBase) {
+async function getIdentities(helper: ChainHelperBase, noneCasePredicate?: (key: any, value: any) => void) {
const identities: [string, any][] = [];
- for(const [key, value] of await helper.getApi().query.identity.identityOf.entries())
+ for(const [key, v] of await helper.getApi().query.identity.identityOf.entries()) {
+ const value = v as any;
+ if (value.isNone) {
+ if (noneCasePredicate) noneCasePredicate(key, value);
+ continue;
+ }
identities.push(extractIdentity(key, value));
+ }
return identities;
}
-// This is a utility for pulling
+function constructSubInfo(identityAccount: string, subQuery: any, supers: any[], ss58?: number): [string, any] {
+ const deposit = subQuery.toJSON()[0];
+ const subIdentities = subQuery.toHuman()[1];
+ subIdentities.map((sub: string) => supers.find((sup: any) => sup[0] === sub));
+ // supers.find((x: any) => x[0] === subIdentities[0])![1].toHuman();
+ return [
+ encodeAddress(identityAccount, ss58), [
+ deposit,
+ subIdentities.map((sub: string) => [
+ encodeAddress(sub, ss58),
+ supers.find((sup: any) => sup[0] === sub)![1].toJSON()[1],
+ ]),
+ ],
+ ];
+}
+
+async function getSubs(helper: ChainHelperBase) {
+ return (await helper.getApi().query.identity.subsOf.entries()).map(([key, value]) => [extractAccountId(key), value as any]);
+}
+
+async function getSupers(helper: ChainHelperBase) {
+ return (await helper.getApi().query.identity.superOf.entries()).map(([key, value]) => [extractAccountId(key), value as any]);
+}
+
+// The utility for pulling identity and sub-identity data
const forceInsertIdentities = async (): Promise<void> => {
const identitiesOnRelay: any[] = [];
+ const subsOnRelay: any[] = [];
const identitiesToRemove: string[] = [];
await usingPlaygrounds(async helper => {
try {
// iterate over every identity
- for(const [key, v] of await helper.getApi().query.identity.identityOf.entries()) {
- const value = v as any;
- if (value.isNone) {
- // in the nigh-impossible case that storage map would actually give None for a value, might as well delete it
- identitiesToRemove.push((key as any).toHuman()[0]);
- continue;
- }
-
+ for(const [key, value] of await getIdentities(helper, (key, _value) => identitiesToRemove.push((key as any).toHuman()[0]))) {
// if any of the judgements resulted in a good confirmed outcome, keep this identity
- if (value.unwrap().toHuman().judgements.filter((x: any) => x[1] == 'Reasonable' || x[1] == 'KnownGood').length == 0) continue;
- identitiesOnRelay.push(extractIdentity(key, value));
+ if (value.toHuman().judgements.filter((x: any) => x[1] == 'Reasonable' || x[1] == 'KnownGood').length == 0) continue;
+ identitiesOnRelay.push([key, value]);
+ }
+
+ const sublessIdentities = [...identitiesOnRelay];
+ const supersOfSubs = await getSupers(helper);
+
+ // iterate over every sub-identity
+ for(const [key, value] of await getSubs(helper)) {
+ // only get subs of the identities interesting to us
+ const identityIndex = sublessIdentities.findIndex((x: any) => x[0] == key);
+ if (identityIndex == -1) continue;
+ sublessIdentities.splice(identityIndex, 1);
+ subsOnRelay.push(constructSubInfo(key, value, supersOfSubs));
}
+
+ // mark the rest of sub-identities for deletion with empty arrays
+ /*for(const [account, _identity] of sublessIdentities) {
+ subsOnRelay.push([account, ['0', []]]);
+ }*/
} catch (error) {
console.error(error);
throw Error('Error during fetching identities');
@@ -60,7 +108,7 @@
const identity = paraIdentities.find(i => i[0] === encodedKey);
if (identity) {
// only update if the identity info does not exist or is changed
- if (value.toString() === identity[1].toString()) {
+ if (JSON.stringify(value) === JSON.stringify(identity[1])) {
continue;
}
}
@@ -71,11 +119,36 @@
// identitiesToRemove.push((key as any).toHuman()[0]);
}
- // await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceRemoveIdentities', [identitiesToRemove]);
- await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identitiesToAdd]);
- console.log(`Tried to upload ${identitiesToAdd.length} identities `
- + `and found ${identitiesToRemove.length} identities for potential removal. `
- + `Now there are ${(await helper.getApi().query.identity.identityOf.keys()).length}.`);
+ const paraSubs = await getSubs(helper);
+ const supersOfSubs = await getSupers(helper);
+ const subsToUpdate: any[] = [];
+
+ if (identitiesToRemove.length != 0)
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceRemoveIdentities', [identitiesToRemove]);
+ if (identitiesToAdd.length != 0)
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceInsertIdentities', [identitiesToAdd]);
+
+ console.log(`Tried to upload ${identitiesToAdd.length} identities`
+ + ` and found ${identitiesToRemove.length} identities for potential removal.`
+ + ` Now there are ${(await helper.getApi().query.identity.identityOf.keys()).length}.`);
+
+ for (const [key, value] of subsOnRelay) {
+ const encodedKey = encodeAddress(key, ss58Format);
+ const sub = paraSubs.find(i => i[0] === encodedKey);
+ if (sub) {
+ // only update if the sub-identity info does not exist or is changed
+ if (JSON.stringify(value) === JSON.stringify(constructSubInfo(sub[0], sub[1], supersOfSubs)[1])) {
+ continue;
+ }
+ }
+ subsToUpdate.push([key, value]);
+ }
+
+ if (subsToUpdate.length != 0)
+ await helper.getSudo().executeExtrinsic(superuser, 'api.tx.identity.forceSetSubs', [subsToUpdate]);
+
+ console.log(`Also tried to update ${subsToUpdate.length} identities with their sub-identities.`
+ + ` Now there are ${(await helper.getApi().query.identity.subsOf.keys()).length} identities with subs.`);
} catch (error) {
console.error(error);
throw Error('Error during setting identities');