difftreelog
feat add PoV estimate
in: master
19 files changed
Cargo.lockdiffbeforeafterboth--- a/Cargo.lock
+++ b/Cargo.lock
@@ -5362,6 +5362,7 @@
"substrate-wasm-builder",
"up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
"up-sponsorship",
"xcm",
@@ -5806,6 +5807,7 @@
"sp-runtime",
"sp-std",
"up-data-structs",
+ "up-pov-estimate-rpc",
]
[[package]]
@@ -8917,6 +8919,7 @@
"substrate-wasm-builder",
"up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
"up-sponsorship",
"xcm",
@@ -12824,18 +12827,31 @@
dependencies = [
"anyhow",
"app-promotion-rpc",
+ "frame-benchmarking",
"jsonrpsee",
+ "opal-runtime",
"pallet-common",
"pallet-evm",
"parity-scale-codec 3.2.1",
+ "quartz-runtime",
"rmrk-rpc",
+ "sc-client-api",
+ "sc-executor",
+ "sc-rpc-api",
+ "sc-service",
"sp-api",
"sp-blockchain",
"sp-core",
+ "sp-externalities",
"sp-rpc",
"sp-runtime",
+ "sp-state-machine",
+ "unique-runtime",
+ "up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
+ "zstd",
]
[[package]]
@@ -12978,10 +12994,12 @@
"substrate-prometheus-endpoint",
"tokio",
"try-runtime-cli",
+ "uc-rpc",
"unique-rpc",
"unique-runtime",
"up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
]
@@ -13032,6 +13050,7 @@
"uc-rpc",
"up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
]
@@ -13125,6 +13144,7 @@
"substrate-wasm-builder",
"up-common",
"up-data-structs",
+ "up-pov-estimate-rpc",
"up-rpc",
"up-sponsorship",
"xcm",
@@ -13194,6 +13214,19 @@
]
[[package]]
+name = "up-pov-estimate-rpc"
+version = "0.1.0"
+dependencies = [
+ "parity-scale-codec 3.2.1",
+ "scale-info",
+ "serde",
+ "sp-api",
+ "sp-core",
+ "sp-runtime",
+ "sp-std",
+]
+
+[[package]]
name = "up-rpc"
version = "0.1.3"
dependencies = [
client/rpc/Cargo.tomldiffbeforeafterboth--- a/client/rpc/Cargo.toml
+++ b/client/rpc/Cargo.toml
@@ -7,16 +7,40 @@
[dependencies]
pallet-common = { default-features = false, path = '../../pallets/common' }
up-data-structs = { default-features = false, path = '../../primitives/data-structs' }
+up-common = { default-features = false, path = '../../primitives/common' }
up-rpc = { path = "../../primitives/rpc" }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc" }
rmrk-rpc = { path = "../../primitives/rmrk-rpc" }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc", optional = true }
codec = { package = "parity-scale-codec", version = "3.1.2" }
jsonrpsee = { version = "0.16.2", features = ["server", "macros"] }
anyhow = "1.0.57"
+zstd = { version = "0.11.2", default-features = false }
+sc-rpc-api = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sc-service = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sc-client-api = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sp-state-machine = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sp-externalities = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
sp-api = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
sp-blockchain = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
sp-core = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
sp-rpc = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
sp-runtime = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
pallet-evm = { default-features = false, git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
+
+frame-benchmarking = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+
+sc-executor = { git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+
+unique-runtime = { path = '../../runtime/unique', optional = true }
+quartz-runtime = { path = '../../runtime/quartz', optional = true }
+opal-runtime = { path = '../../runtime/opal' }
+
+[features]
+pov-estimate = [
+ 'up-pov-estimate-rpc',
+ 'unique-runtime?/pov-estimate',
+ 'quartz-runtime?/pov-estimate',
+ 'opal-runtime/pov-estimate',
+]
client/rpc/src/lib.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 License18use std::sync::Arc;1920use codec::{Decode, Encode};21use jsonrpsee::{22 core::{RpcResult as Result},23 proc_macros::rpc,24};25use anyhow::anyhow;26use sp_runtime::traits::{AtLeast32BitUnsigned, Member};27use up_data_structs::{28 RpcCollection, CollectionId, CollectionStats, CollectionLimits, TokenId, Property,29 PropertyKeyPermission, TokenData, TokenChild,30};31use sp_api::{BlockId, BlockT, ProvideRuntimeApi, ApiExt};32use sp_blockchain::HeaderBackend;33use up_rpc::UniqueApi as UniqueRuntimeApi;34use app_promotion_rpc::AppPromotionApi as AppPromotionRuntimeApi;3536// RMRK37use rmrk_rpc::RmrkApi as RmrkRuntimeApi;38use up_data_structs::{39 RmrkCollectionId, RmrkNftId, RmrkBaseId, RmrkNftChild, RmrkThemeName, RmrkResourceId,40};4142pub use app_promotion_unique_rpc::AppPromotionApiServer;43pub use rmrk_unique_rpc::RmrkApiServer;4445#[rpc(server)]46#[async_trait]47pub trait UniqueApi<BlockHash, CrossAccountId, AccountId> {48 /// Get tokens owned by account.49 #[method(name = "unique_accountTokens")]50 fn account_tokens(51 &self,52 collection: CollectionId,53 account: CrossAccountId,54 at: Option<BlockHash>,55 ) -> Result<Vec<TokenId>>;5657 /// Get tokens contained within a collection.58 #[method(name = "unique_collectionTokens")]59 fn collection_tokens(60 &self,61 collection: CollectionId,62 at: Option<BlockHash>,63 ) -> Result<Vec<TokenId>>;6465 /// Check if the token exists.66 #[method(name = "unique_tokenExists")]67 fn token_exists(68 &self,69 collection: CollectionId,70 token: TokenId,71 at: Option<BlockHash>,72 ) -> Result<bool>;7374 /// Get the token owner.75 #[method(name = "unique_tokenOwner")]76 fn token_owner(77 &self,78 collection: CollectionId,79 token: TokenId,80 at: Option<BlockHash>,81 ) -> Result<Option<CrossAccountId>>;8283 /// Returns 10 tokens owners in no particular order.84 #[method(name = "unique_tokenOwners")]85 fn token_owners(86 &self,87 collection: CollectionId,88 token: TokenId,89 at: Option<BlockHash>,90 ) -> Result<Vec<CrossAccountId>>;9192 /// Get the topmost token owner in the hierarchy of a possibly nested token.93 #[method(name = "unique_topmostTokenOwner")]94 fn topmost_token_owner(95 &self,96 collection: CollectionId,97 token: TokenId,98 at: Option<BlockHash>,99 ) -> Result<Option<CrossAccountId>>;100101 /// Get tokens nested directly into the token.102 #[method(name = "unique_tokenChildren")]103 fn token_children(104 &self,105 collection: CollectionId,106 token: TokenId,107 at: Option<BlockHash>,108 ) -> Result<Vec<TokenChild>>;109110 /// Get collection properties, optionally limited to the provided keys.111 #[method(name = "unique_collectionProperties")]112 fn collection_properties(113 &self,114 collection: CollectionId,115 keys: Option<Vec<String>>,116 at: Option<BlockHash>,117 ) -> Result<Vec<Property>>;118119 /// Get token properties, optionally limited to the provided keys.120 #[method(name = "unique_tokenProperties")]121 fn token_properties(122 &self,123 collection: CollectionId,124 token_id: TokenId,125 keys: Option<Vec<String>>,126 at: Option<BlockHash>,127 ) -> Result<Vec<Property>>;128129 /// Get property permissions, optionally limited to the provided keys.130 #[method(name = "unique_propertyPermissions")]131 fn property_permissions(132 &self,133 collection: CollectionId,134 keys: Option<Vec<String>>,135 at: Option<BlockHash>,136 ) -> Result<Vec<PropertyKeyPermission>>;137138 /// Get token data, including properties, optionally limited to the provided keys, and total pieces for an RFT.139 #[method(name = "unique_tokenData")]140 fn token_data(141 &self,142 collection: CollectionId,143 token_id: TokenId,144 keys: Option<Vec<String>>,145 at: Option<BlockHash>,146 ) -> Result<TokenData<CrossAccountId>>;147148 /// Get the amount of distinctive tokens present in a collection.149 #[method(name = "unique_totalSupply")]150 fn total_supply(&self, collection: CollectionId, at: Option<BlockHash>) -> Result<u32>;151152 /// Get the amount of any user tokens owned by an account.153 #[method(name = "unique_accountBalance")]154 fn account_balance(155 &self,156 collection: CollectionId,157 account: CrossAccountId,158 at: Option<BlockHash>,159 ) -> Result<u32>;160161 /// Get the amount of a specific token owned by an account.162 #[method(name = "unique_balance")]163 fn balance(164 &self,165 collection: CollectionId,166 account: CrossAccountId,167 token: TokenId,168 at: Option<BlockHash>,169 ) -> Result<String>;170171 /// Get the amount of currently possible sponsored transactions on a token for the fee to be taken off a sponsor.172 #[method(name = "unique_allowance")]173 fn allowance(174 &self,175 collection: CollectionId,176 sender: CrossAccountId,177 spender: CrossAccountId,178 token: TokenId,179 at: Option<BlockHash>,180 ) -> Result<String>;181182 /// Get the list of admin accounts of a collection.183 #[method(name = "unique_adminlist")]184 fn adminlist(185 &self,186 collection: CollectionId,187 at: Option<BlockHash>,188 ) -> Result<Vec<CrossAccountId>>;189190 /// Get the list of accounts allowed to operate within a collection.191 #[method(name = "unique_allowlist")]192 fn allowlist(193 &self,194 collection: CollectionId,195 at: Option<BlockHash>,196 ) -> Result<Vec<CrossAccountId>>;197198 /// Check if a user is allowed to operate within a collection.199 #[method(name = "unique_allowed")]200 fn allowed(201 &self,202 collection: CollectionId,203 user: CrossAccountId,204 at: Option<BlockHash>,205 ) -> Result<bool>;206207 /// Get the last token ID created in a collection.208 #[method(name = "unique_lastTokenId")]209 fn last_token_id(&self, collection: CollectionId, at: Option<BlockHash>) -> Result<TokenId>;210211 /// Get collection info by the specified ID.212 #[method(name = "unique_collectionById")]213 fn collection_by_id(214 &self,215 collection: CollectionId,216 at: Option<BlockHash>,217 ) -> Result<Option<RpcCollection<AccountId>>>;218219 /// Get chain stats about collections.220 #[method(name = "unique_collectionStats")]221 fn collection_stats(&self, at: Option<BlockHash>) -> Result<CollectionStats>;222223 /// Get the number of blocks until sponsoring a transaction is available.224 #[method(name = "unique_nextSponsored")]225 fn next_sponsored(226 &self,227 collection: CollectionId,228 account: CrossAccountId,229 token: TokenId,230 at: Option<BlockHash>,231 ) -> Result<Option<u64>>;232233 /// Get effective collection limits. If not explicitly set, get the chain defaults.234 #[method(name = "unique_effectiveCollectionLimits")]235 fn effective_collection_limits(236 &self,237 collection_id: CollectionId,238 at: Option<BlockHash>,239 ) -> Result<Option<CollectionLimits>>;240241 /// Get the total amount of pieces of an RFT.242 #[method(name = "unique_totalPieces")]243 fn total_pieces(244 &self,245 collection_id: CollectionId,246 token_id: TokenId,247 at: Option<BlockHash>,248 ) -> Result<Option<String>>;249250 /// Get whether an operator is approved by a given owner.251 #[method(name = "unique_allowanceForAll")]252 fn allowance_for_all(253 &self,254 collection: CollectionId,255 owner: CrossAccountId,256 operator: CrossAccountId,257 at: Option<BlockHash>,258 ) -> Result<bool>;259}260261mod app_promotion_unique_rpc {262 use super::*;263264 #[rpc(server)]265 #[async_trait]266 pub trait AppPromotionApi<BlockHash, BlockNumber, CrossAccountId, AccountId> {267 /// Returns the total amount of staked tokens.268 #[method(name = "appPromotion_totalStaked")]269 fn total_staked(270 &self,271 staker: Option<CrossAccountId>,272 at: Option<BlockHash>,273 ) -> Result<String>;274275 ///Returns the total amount of staked tokens per block when staked.276 #[method(name = "appPromotion_totalStakedPerBlock")]277 fn total_staked_per_block(278 &self,279 staker: CrossAccountId,280 at: Option<BlockHash>,281 ) -> Result<Vec<(BlockNumber, String)>>;282283 /// Returns the total amount of tokens pending withdrawal from staking.284 #[method(name = "appPromotion_pendingUnstake")]285 fn pending_unstake(286 &self,287 staker: Option<CrossAccountId>,288 at: Option<BlockHash>,289 ) -> Result<String>;290291 /// Returns the total amount of tokens pending withdrawal from staking per block.292 #[method(name = "appPromotion_pendingUnstakePerBlock")]293 fn pending_unstake_per_block(294 &self,295 staker: CrossAccountId,296 at: Option<BlockHash>,297 ) -> Result<Vec<(BlockNumber, String)>>;298 }299}300301mod rmrk_unique_rpc {302 use super::*;303304 #[rpc(server)]305 #[async_trait]306 pub trait RmrkApi<307 BlockHash,308 AccountId,309 CollectionInfo,310 NftInfo,311 ResourceInfo,312 PropertyInfo,313 BaseInfo,314 PartType,315 Theme,316 >317 {318 /// Get the latest created collection ID.319 #[method(name = "rmrk_lastCollectionIdx")]320 fn last_collection_idx(&self, at: Option<BlockHash>) -> Result<RmrkCollectionId>;321322 /// Get collection info by ID.323 #[method(name = "rmrk_collectionById")]324 fn collection_by_id(325 &self,326 id: RmrkCollectionId,327 at: Option<BlockHash>,328 ) -> Result<Option<CollectionInfo>>;329330 /// Get NFT info by collection and NFT IDs.331 #[method(name = "rmrk_nftById")]332 fn nft_by_id(333 &self,334 collection_id: RmrkCollectionId,335 nft_id: RmrkNftId,336 at: Option<BlockHash>,337 ) -> Result<Option<NftInfo>>;338339 /// Get tokens owned by an account in a collection.340 #[method(name = "rmrk_accountTokens")]341 fn account_tokens(342 &self,343 account_id: AccountId,344 collection_id: RmrkCollectionId,345 at: Option<BlockHash>,346 ) -> Result<Vec<RmrkNftId>>;347348 /// Get tokens nested in an NFT - its direct children (not the children's children).349 #[method(name = "rmrk_nftChildren")]350 fn nft_children(351 &self,352 collection_id: RmrkCollectionId,353 nft_id: RmrkNftId,354 at: Option<BlockHash>,355 ) -> Result<Vec<RmrkNftChild>>;356357 /// Get collection properties, created by the user - not the proxy-specific properties.358 #[method(name = "rmrk_collectionProperties")]359 fn collection_properties(360 &self,361 collection_id: RmrkCollectionId,362 filter_keys: Option<Vec<String>>,363 at: Option<BlockHash>,364 ) -> Result<Vec<PropertyInfo>>;365366 /// Get NFT properties, created by the user - not the proxy-specific properties.367 #[method(name = "rmrk_nftProperties")]368 fn nft_properties(369 &self,370 collection_id: RmrkCollectionId,371 nft_id: RmrkNftId,372 filter_keys: Option<Vec<String>>,373 at: Option<BlockHash>,374 ) -> Result<Vec<PropertyInfo>>;375376 /// Get data of resources of an NFT.377 #[method(name = "rmrk_nftResources")]378 fn nft_resources(379 &self,380 collection_id: RmrkCollectionId,381 nft_id: RmrkNftId,382 at: Option<BlockHash>,383 ) -> Result<Vec<ResourceInfo>>;384385 /// Get the priority of a resource in an NFT.386 #[method(name = "rmrk_nftResourcePriority")]387 fn nft_resource_priority(388 &self,389 collection_id: RmrkCollectionId,390 nft_id: RmrkNftId,391 resource_id: RmrkResourceId,392 at: Option<BlockHash>,393 ) -> Result<Option<u32>>;394395 /// Get base info by its ID.396 #[method(name = "rmrk_base")]397 fn base(&self, base_id: RmrkBaseId, at: Option<BlockHash>) -> Result<Option<BaseInfo>>;398399 /// Get all parts of a base.400 #[method(name = "rmrk_baseParts")]401 fn base_parts(&self, base_id: RmrkBaseId, at: Option<BlockHash>) -> Result<Vec<PartType>>;402403 /// Get the theme names belonging to a base.404 #[method(name = "rmrk_themeNames")]405 fn theme_names(406 &self,407 base_id: RmrkBaseId,408 at: Option<BlockHash>,409 ) -> Result<Vec<RmrkThemeName>>;410411 /// Get theme info, including properties, optionally limited to the provided keys.412 #[method(name = "rmrk_themes")]413 fn theme(414 &self,415 base_id: RmrkBaseId,416 theme_name: String,417 filter_keys: Option<Vec<String>>,418 at: Option<BlockHash>,419 ) -> Result<Option<Theme>>;420 }421}422423macro_rules! define_struct_for_server_api {424 ($name:ident) => {425 pub struct $name<C, P> {426 client: Arc<C>,427 _marker: std::marker::PhantomData<P>,428 }429430 impl<C, P> $name<C, P> {431 pub fn new(client: Arc<C>) -> Self {432 Self {433 client,434 _marker: Default::default(),435 }436 }437 }438 };439}440441define_struct_for_server_api!(Unique);442define_struct_for_server_api!(AppPromotion);443define_struct_for_server_api!(Rmrk);444445macro_rules! pass_method {446 (447 $method_name:ident(448 $($(#[map(|$map_arg:ident| $map:expr)])? $name:ident: $ty:ty),* $(,)?449 ) -> $result:ty $(=> $mapper:expr)?,450 //$runtime_name:ident $(<$($lt: tt),+>)*451 $runtime_api_macro:ident452 $(; changed_in $ver:expr, $changed_method_name:ident ($($changed_name:expr), * $(,)?) => $fixer:expr)*453 ) => {454 fn $method_name(455 &self,456 $(457 $name: $ty,458 )*459 at: Option<<Block as BlockT>::Hash>,460 ) -> Result<$result> {461 let api = self.client.runtime_api();462 let at = BlockId::hash(at.unwrap_or_else(|| self.client.info().best_hash));463 let _api_version = if let Ok(Some(api_version)) =464 api.api_version::<$runtime_api_macro!()>(&at)465 {466 api_version467 } else {468 // unreachable for our runtime469 return Err(anyhow!("api is not available").into())470 };471472 let result = $(if _api_version < $ver {473 api.$changed_method_name(&at, $($changed_name),*).map(|r| r.map($fixer))474 } else)*475 { api.$method_name(&at, $($((|$map_arg: $ty| $map))? ($name)),*) };476477 Ok(result478 .map_err(|e| anyhow!("unable to query: {e}"))?479 .map_err(|e| anyhow!("runtime error: {e:?}"))$(.map($mapper))??)480 }481 };482}483484macro_rules! unique_api {485 () => {486 dyn UniqueRuntimeApi<Block, CrossAccountId, AccountId>487 };488}489490macro_rules! app_promotion_api {491 () => {492 dyn AppPromotionRuntimeApi<Block, BlockNumber, CrossAccountId, AccountId>493 };494}495496macro_rules! rmrk_api {497 () => {498 dyn RmrkRuntimeApi<Block, AccountId, CollectionInfo, NftInfo, ResourceInfo, PropertyInfo, BaseInfo, PartType, Theme>499 };500}501502#[allow(deprecated)]503impl<C, Block, CrossAccountId, AccountId>504 UniqueApiServer<<Block as BlockT>::Hash, CrossAccountId, AccountId> for Unique<C, Block>505where506 Block: BlockT,507 AccountId: Decode,508 C: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,509 C::Api: UniqueRuntimeApi<Block, CrossAccountId, AccountId>,510 CrossAccountId: pallet_evm::account::CrossAccountId<AccountId>,511{512 pass_method!(513 account_tokens(collection: CollectionId, account: CrossAccountId) -> Vec<TokenId>, unique_api514 );515 pass_method!(516 collection_tokens(collection: CollectionId) -> Vec<TokenId>, unique_api517 );518 pass_method!(519 token_exists(collection: CollectionId, token: TokenId) -> bool, unique_api520 );521 pass_method!(522 token_owner(collection: CollectionId, token: TokenId) -> Option<CrossAccountId>, unique_api523 );524 pass_method!(525 topmost_token_owner(collection: CollectionId, token: TokenId) -> Option<CrossAccountId>, unique_api526 );527 pass_method!(token_children(collection: CollectionId, token: TokenId) -> Vec<TokenChild>, unique_api);528 pass_method!(total_supply(collection: CollectionId) -> u32, unique_api);529 pass_method!(account_balance(collection: CollectionId, account: CrossAccountId) -> u32, unique_api);530 pass_method!(balance(collection: CollectionId, account: CrossAccountId, token: TokenId) -> String => |v| v.to_string(), unique_api);531 pass_method!(532 allowance(collection: CollectionId, sender: CrossAccountId, spender: CrossAccountId, token: TokenId) -> String => |v| v.to_string(),533 unique_api534 );535536 pass_method!(collection_properties(537 collection: CollectionId,538539 #[map(|keys| string_keys_to_bytes_keys(keys))]540 keys: Option<Vec<String>>541 ) -> Vec<Property>, unique_api);542543 pass_method!(token_properties(544 collection: CollectionId,545 token_id: TokenId,546547 #[map(|keys| string_keys_to_bytes_keys(keys))]548 keys: Option<Vec<String>>549 ) -> Vec<Property>, unique_api);550551 pass_method!(property_permissions(552 collection: CollectionId,553554 #[map(|keys| string_keys_to_bytes_keys(keys))]555 keys: Option<Vec<String>>556 ) -> Vec<PropertyKeyPermission>, unique_api);557558 pass_method!(559 token_data(560 collection: CollectionId,561 token_id: TokenId,562563 #[map(|keys| string_keys_to_bytes_keys(keys))]564 keys: Option<Vec<String>>,565 ) -> TokenData<CrossAccountId>, unique_api;566 changed_in 3, token_data_before_version_3(collection, token_id, string_keys_to_bytes_keys(keys)) => |value| value.into()567 );568569 pass_method!(adminlist(collection: CollectionId) -> Vec<CrossAccountId>, unique_api);570 pass_method!(allowlist(collection: CollectionId) -> Vec<CrossAccountId>, unique_api);571 pass_method!(allowed(collection: CollectionId, user: CrossAccountId) -> bool, unique_api);572 pass_method!(last_token_id(collection: CollectionId) -> TokenId, unique_api);573 pass_method!(574 collection_by_id(collection: CollectionId) -> Option<RpcCollection<AccountId>>, unique_api;575 changed_in 3, collection_by_id_before_version_3(collection) => |value| value.map(|coll| coll.into())576 );577 pass_method!(collection_stats() -> CollectionStats, unique_api);578 pass_method!(next_sponsored(collection: CollectionId, account: CrossAccountId, token: TokenId) -> Option<u64>, unique_api);579 pass_method!(effective_collection_limits(collection_id: CollectionId) -> Option<CollectionLimits>, unique_api);580 pass_method!(total_pieces(collection_id: CollectionId, token_id: TokenId) -> Option<String> => |o| o.map(|number| number.to_string()) , unique_api);581 pass_method!(token_owners(collection: CollectionId, token: TokenId) -> Vec<CrossAccountId>, unique_api);582 pass_method!(allowance_for_all(collection: CollectionId, owner: CrossAccountId, operator: CrossAccountId) -> bool, unique_api);583}584585impl<C, Block, BlockNumber, CrossAccountId, AccountId>586 app_promotion_unique_rpc::AppPromotionApiServer<587 <Block as BlockT>::Hash,588 BlockNumber,589 CrossAccountId,590 AccountId,591 > for AppPromotion<C, Block>592where593 Block: BlockT,594 BlockNumber: Decode + Member + AtLeast32BitUnsigned,595 AccountId: Decode,596 C: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,597 CrossAccountId: pallet_evm::account::CrossAccountId<AccountId>,598 C::Api: AppPromotionRuntimeApi<Block, BlockNumber, CrossAccountId, AccountId>,599{600 pass_method!(total_staked(staker: Option<CrossAccountId>) -> String => |v| v.to_string(), app_promotion_api);601 pass_method!(total_staked_per_block(staker: CrossAccountId) -> Vec<(BlockNumber, String)> =>602 |v| v603 .into_iter()604 .map(|(b, a)| (b, a.to_string()))605 .collect::<Vec<_>>(), app_promotion_api);606 pass_method!(pending_unstake(staker: Option<CrossAccountId>) -> String => |v| v.to_string(), app_promotion_api);607 pass_method!(pending_unstake_per_block(staker: CrossAccountId) -> Vec<(BlockNumber, String)> =>608 |v| v609 .into_iter()610 .map(|(b, a)| (b, a.to_string()))611 .collect::<Vec<_>>(), app_promotion_api);612}613614#[allow(deprecated)]615impl<616 C,617 Block,618 AccountId,619 CollectionInfo,620 NftInfo,621 ResourceInfo,622 PropertyInfo,623 BaseInfo,624 PartType,625 Theme,626 >627 rmrk_unique_rpc::RmrkApiServer<628 <Block as BlockT>::Hash,629 AccountId,630 CollectionInfo,631 NftInfo,632 ResourceInfo,633 PropertyInfo,634 BaseInfo,635 PartType,636 Theme,637 > for Rmrk<C, Block>638where639 C: Send + Sync + 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,640 C::Api: RmrkRuntimeApi<641 Block,642 AccountId,643 CollectionInfo,644 NftInfo,645 ResourceInfo,646 PropertyInfo,647 BaseInfo,648 PartType,649 Theme,650 >,651 AccountId: Decode + Encode,652 CollectionInfo: Decode,653 NftInfo: Decode,654 ResourceInfo: Decode,655 PropertyInfo: Decode,656 BaseInfo: Decode,657 PartType: Decode,658 Theme: Decode,659 Block: BlockT,660{661 pass_method!(last_collection_idx() -> RmrkCollectionId, rmrk_api);662 pass_method!(collection_by_id(id: RmrkCollectionId) -> Option<CollectionInfo>, rmrk_api);663 pass_method!(nft_by_id(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Option<NftInfo>, rmrk_api);664 pass_method!(account_tokens(account_id: AccountId, collection_id: RmrkCollectionId) -> Vec<RmrkNftId>, rmrk_api);665 pass_method!(nft_children(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Vec<RmrkNftChild>, rmrk_api);666 pass_method!(667 collection_properties(668 collection_id: RmrkCollectionId,669670 #[map(|keys| string_keys_to_bytes_keys(keys))]671 filter_keys: Option<Vec<String>>672 ) -> Vec<PropertyInfo>,673 rmrk_api674 );675 pass_method!(676 nft_properties(677 collection_id: RmrkCollectionId,678 nft_id: RmrkNftId,679680 #[map(|keys| string_keys_to_bytes_keys(keys))]681 filter_keys: Option<Vec<String>>682 ) -> Vec<PropertyInfo>,683 rmrk_api684 );685 pass_method!(nft_resources(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Vec<ResourceInfo>, rmrk_api);686 pass_method!(nft_resource_priority(collection_id: RmrkCollectionId, nft_id: RmrkNftId, resource_id: RmrkResourceId) -> Option<u32>, rmrk_api);687 pass_method!(base(base_id: RmrkBaseId) -> Option<BaseInfo>, rmrk_api);688 pass_method!(base_parts(base_id: RmrkBaseId) -> Vec<PartType>, rmrk_api);689 pass_method!(theme_names(base_id: RmrkBaseId) -> Vec<RmrkThemeName>, rmrk_api);690 pass_method!(691 theme(692 base_id: RmrkBaseId,693694 #[map(|n| n.into_bytes())]695 theme_name: String,696697 #[map(|keys| string_keys_to_bytes_keys(keys))]698 filter_keys: Option<Vec<String>>699 ) -> Option<Theme>, rmrk_api);700}701702fn string_keys_to_bytes_keys(keys: Option<Vec<String>>) -> Option<Vec<Vec<u8>>> {703 keys.map(|keys| keys.into_iter().map(|key| key.into_bytes()).collect())704}1// 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 License18use std::sync::Arc;1920use codec::{Decode, Encode};21use jsonrpsee::{22 core::{RpcResult as Result},23 proc_macros::rpc,24};25use anyhow::anyhow;26use sp_runtime::traits::{AtLeast32BitUnsigned, Member};27use up_data_structs::{28 RpcCollection, CollectionId, CollectionStats, CollectionLimits, TokenId, Property,29 PropertyKeyPermission, TokenData, TokenChild,30};31use sp_api::{BlockId, BlockT, ProvideRuntimeApi, ApiExt};32use sp_blockchain::HeaderBackend;33use up_rpc::UniqueApi as UniqueRuntimeApi;34use app_promotion_rpc::AppPromotionApi as AppPromotionRuntimeApi;3536// RMRK37use rmrk_rpc::RmrkApi as RmrkRuntimeApi;38use up_data_structs::{39 RmrkCollectionId, RmrkNftId, RmrkBaseId, RmrkNftChild, RmrkThemeName, RmrkResourceId,40};4142pub use app_promotion_unique_rpc::AppPromotionApiServer;43pub use rmrk_unique_rpc::RmrkApiServer;4445#[cfg(feature = "pov-estimate")]46pub mod pov_estimate;4748#[rpc(server)]49#[async_trait]50pub trait UniqueApi<BlockHash, CrossAccountId, AccountId> {51 /// Get tokens owned by account.52 #[method(name = "unique_accountTokens")]53 fn account_tokens(54 &self,55 collection: CollectionId,56 account: CrossAccountId,57 at: Option<BlockHash>,58 ) -> Result<Vec<TokenId>>;5960 /// Get tokens contained within a collection.61 #[method(name = "unique_collectionTokens")]62 fn collection_tokens(63 &self,64 collection: CollectionId,65 at: Option<BlockHash>,66 ) -> Result<Vec<TokenId>>;6768 /// Check if the token exists.69 #[method(name = "unique_tokenExists")]70 fn token_exists(71 &self,72 collection: CollectionId,73 token: TokenId,74 at: Option<BlockHash>,75 ) -> Result<bool>;7677 /// Get the token owner.78 #[method(name = "unique_tokenOwner")]79 fn token_owner(80 &self,81 collection: CollectionId,82 token: TokenId,83 at: Option<BlockHash>,84 ) -> Result<Option<CrossAccountId>>;8586 /// Returns 10 tokens owners in no particular order.87 #[method(name = "unique_tokenOwners")]88 fn token_owners(89 &self,90 collection: CollectionId,91 token: TokenId,92 at: Option<BlockHash>,93 ) -> Result<Vec<CrossAccountId>>;9495 /// Get the topmost token owner in the hierarchy of a possibly nested token.96 #[method(name = "unique_topmostTokenOwner")]97 fn topmost_token_owner(98 &self,99 collection: CollectionId,100 token: TokenId,101 at: Option<BlockHash>,102 ) -> Result<Option<CrossAccountId>>;103104 /// Get tokens nested directly into the token.105 #[method(name = "unique_tokenChildren")]106 fn token_children(107 &self,108 collection: CollectionId,109 token: TokenId,110 at: Option<BlockHash>,111 ) -> Result<Vec<TokenChild>>;112113 /// Get collection properties, optionally limited to the provided keys.114 #[method(name = "unique_collectionProperties")]115 fn collection_properties(116 &self,117 collection: CollectionId,118 keys: Option<Vec<String>>,119 at: Option<BlockHash>,120 ) -> Result<Vec<Property>>;121122 /// Get token properties, optionally limited to the provided keys.123 #[method(name = "unique_tokenProperties")]124 fn token_properties(125 &self,126 collection: CollectionId,127 token_id: TokenId,128 keys: Option<Vec<String>>,129 at: Option<BlockHash>,130 ) -> Result<Vec<Property>>;131132 /// Get property permissions, optionally limited to the provided keys.133 #[method(name = "unique_propertyPermissions")]134 fn property_permissions(135 &self,136 collection: CollectionId,137 keys: Option<Vec<String>>,138 at: Option<BlockHash>,139 ) -> Result<Vec<PropertyKeyPermission>>;140141 /// Get token data, including properties, optionally limited to the provided keys, and total pieces for an RFT.142 #[method(name = "unique_tokenData")]143 fn token_data(144 &self,145 collection: CollectionId,146 token_id: TokenId,147 keys: Option<Vec<String>>,148 at: Option<BlockHash>,149 ) -> Result<TokenData<CrossAccountId>>;150151 /// Get the amount of distinctive tokens present in a collection.152 #[method(name = "unique_totalSupply")]153 fn total_supply(&self, collection: CollectionId, at: Option<BlockHash>) -> Result<u32>;154155 /// Get the amount of any user tokens owned by an account.156 #[method(name = "unique_accountBalance")]157 fn account_balance(158 &self,159 collection: CollectionId,160 account: CrossAccountId,161 at: Option<BlockHash>,162 ) -> Result<u32>;163164 /// Get the amount of a specific token owned by an account.165 #[method(name = "unique_balance")]166 fn balance(167 &self,168 collection: CollectionId,169 account: CrossAccountId,170 token: TokenId,171 at: Option<BlockHash>,172 ) -> Result<String>;173174 /// Get the amount of currently possible sponsored transactions on a token for the fee to be taken off a sponsor.175 #[method(name = "unique_allowance")]176 fn allowance(177 &self,178 collection: CollectionId,179 sender: CrossAccountId,180 spender: CrossAccountId,181 token: TokenId,182 at: Option<BlockHash>,183 ) -> Result<String>;184185 /// Get the list of admin accounts of a collection.186 #[method(name = "unique_adminlist")]187 fn adminlist(188 &self,189 collection: CollectionId,190 at: Option<BlockHash>,191 ) -> Result<Vec<CrossAccountId>>;192193 /// Get the list of accounts allowed to operate within a collection.194 #[method(name = "unique_allowlist")]195 fn allowlist(196 &self,197 collection: CollectionId,198 at: Option<BlockHash>,199 ) -> Result<Vec<CrossAccountId>>;200201 /// Check if a user is allowed to operate within a collection.202 #[method(name = "unique_allowed")]203 fn allowed(204 &self,205 collection: CollectionId,206 user: CrossAccountId,207 at: Option<BlockHash>,208 ) -> Result<bool>;209210 /// Get the last token ID created in a collection.211 #[method(name = "unique_lastTokenId")]212 fn last_token_id(&self, collection: CollectionId, at: Option<BlockHash>) -> Result<TokenId>;213214 /// Get collection info by the specified ID.215 #[method(name = "unique_collectionById")]216 fn collection_by_id(217 &self,218 collection: CollectionId,219 at: Option<BlockHash>,220 ) -> Result<Option<RpcCollection<AccountId>>>;221222 /// Get chain stats about collections.223 #[method(name = "unique_collectionStats")]224 fn collection_stats(&self, at: Option<BlockHash>) -> Result<CollectionStats>;225226 /// Get the number of blocks until sponsoring a transaction is available.227 #[method(name = "unique_nextSponsored")]228 fn next_sponsored(229 &self,230 collection: CollectionId,231 account: CrossAccountId,232 token: TokenId,233 at: Option<BlockHash>,234 ) -> Result<Option<u64>>;235236 /// Get effective collection limits. If not explicitly set, get the chain defaults.237 #[method(name = "unique_effectiveCollectionLimits")]238 fn effective_collection_limits(239 &self,240 collection_id: CollectionId,241 at: Option<BlockHash>,242 ) -> Result<Option<CollectionLimits>>;243244 /// Get the total amount of pieces of an RFT.245 #[method(name = "unique_totalPieces")]246 fn total_pieces(247 &self,248 collection_id: CollectionId,249 token_id: TokenId,250 at: Option<BlockHash>,251 ) -> Result<Option<String>>;252253 /// Get whether an operator is approved by a given owner.254 #[method(name = "unique_allowanceForAll")]255 fn allowance_for_all(256 &self,257 collection: CollectionId,258 owner: CrossAccountId,259 operator: CrossAccountId,260 at: Option<BlockHash>,261 ) -> Result<bool>;262}263264mod app_promotion_unique_rpc {265 use super::*;266267 #[rpc(server)]268 #[async_trait]269 pub trait AppPromotionApi<BlockHash, BlockNumber, CrossAccountId, AccountId> {270 /// Returns the total amount of staked tokens.271 #[method(name = "appPromotion_totalStaked")]272 fn total_staked(273 &self,274 staker: Option<CrossAccountId>,275 at: Option<BlockHash>,276 ) -> Result<String>;277278 ///Returns the total amount of staked tokens per block when staked.279 #[method(name = "appPromotion_totalStakedPerBlock")]280 fn total_staked_per_block(281 &self,282 staker: CrossAccountId,283 at: Option<BlockHash>,284 ) -> Result<Vec<(BlockNumber, String)>>;285286 /// Returns the total amount of tokens pending withdrawal from staking.287 #[method(name = "appPromotion_pendingUnstake")]288 fn pending_unstake(289 &self,290 staker: Option<CrossAccountId>,291 at: Option<BlockHash>,292 ) -> Result<String>;293294 /// Returns the total amount of tokens pending withdrawal from staking per block.295 #[method(name = "appPromotion_pendingUnstakePerBlock")]296 fn pending_unstake_per_block(297 &self,298 staker: CrossAccountId,299 at: Option<BlockHash>,300 ) -> Result<Vec<(BlockNumber, String)>>;301 }302}303304mod rmrk_unique_rpc {305 use super::*;306307 #[rpc(server)]308 #[async_trait]309 pub trait RmrkApi<310 BlockHash,311 AccountId,312 CollectionInfo,313 NftInfo,314 ResourceInfo,315 PropertyInfo,316 BaseInfo,317 PartType,318 Theme,319 >320 {321 /// Get the latest created collection ID.322 #[method(name = "rmrk_lastCollectionIdx")]323 fn last_collection_idx(&self, at: Option<BlockHash>) -> Result<RmrkCollectionId>;324325 /// Get collection info by ID.326 #[method(name = "rmrk_collectionById")]327 fn collection_by_id(328 &self,329 id: RmrkCollectionId,330 at: Option<BlockHash>,331 ) -> Result<Option<CollectionInfo>>;332333 /// Get NFT info by collection and NFT IDs.334 #[method(name = "rmrk_nftById")]335 fn nft_by_id(336 &self,337 collection_id: RmrkCollectionId,338 nft_id: RmrkNftId,339 at: Option<BlockHash>,340 ) -> Result<Option<NftInfo>>;341342 /// Get tokens owned by an account in a collection.343 #[method(name = "rmrk_accountTokens")]344 fn account_tokens(345 &self,346 account_id: AccountId,347 collection_id: RmrkCollectionId,348 at: Option<BlockHash>,349 ) -> Result<Vec<RmrkNftId>>;350351 /// Get tokens nested in an NFT - its direct children (not the children's children).352 #[method(name = "rmrk_nftChildren")]353 fn nft_children(354 &self,355 collection_id: RmrkCollectionId,356 nft_id: RmrkNftId,357 at: Option<BlockHash>,358 ) -> Result<Vec<RmrkNftChild>>;359360 /// Get collection properties, created by the user - not the proxy-specific properties.361 #[method(name = "rmrk_collectionProperties")]362 fn collection_properties(363 &self,364 collection_id: RmrkCollectionId,365 filter_keys: Option<Vec<String>>,366 at: Option<BlockHash>,367 ) -> Result<Vec<PropertyInfo>>;368369 /// Get NFT properties, created by the user - not the proxy-specific properties.370 #[method(name = "rmrk_nftProperties")]371 fn nft_properties(372 &self,373 collection_id: RmrkCollectionId,374 nft_id: RmrkNftId,375 filter_keys: Option<Vec<String>>,376 at: Option<BlockHash>,377 ) -> Result<Vec<PropertyInfo>>;378379 /// Get data of resources of an NFT.380 #[method(name = "rmrk_nftResources")]381 fn nft_resources(382 &self,383 collection_id: RmrkCollectionId,384 nft_id: RmrkNftId,385 at: Option<BlockHash>,386 ) -> Result<Vec<ResourceInfo>>;387388 /// Get the priority of a resource in an NFT.389 #[method(name = "rmrk_nftResourcePriority")]390 fn nft_resource_priority(391 &self,392 collection_id: RmrkCollectionId,393 nft_id: RmrkNftId,394 resource_id: RmrkResourceId,395 at: Option<BlockHash>,396 ) -> Result<Option<u32>>;397398 /// Get base info by its ID.399 #[method(name = "rmrk_base")]400 fn base(&self, base_id: RmrkBaseId, at: Option<BlockHash>) -> Result<Option<BaseInfo>>;401402 /// Get all parts of a base.403 #[method(name = "rmrk_baseParts")]404 fn base_parts(&self, base_id: RmrkBaseId, at: Option<BlockHash>) -> Result<Vec<PartType>>;405406 /// Get the theme names belonging to a base.407 #[method(name = "rmrk_themeNames")]408 fn theme_names(409 &self,410 base_id: RmrkBaseId,411 at: Option<BlockHash>,412 ) -> Result<Vec<RmrkThemeName>>;413414 /// Get theme info, including properties, optionally limited to the provided keys.415 #[method(name = "rmrk_themes")]416 fn theme(417 &self,418 base_id: RmrkBaseId,419 theme_name: String,420 filter_keys: Option<Vec<String>>,421 at: Option<BlockHash>,422 ) -> Result<Option<Theme>>;423 }424}425426#[macro_export]427macro_rules! define_struct_for_server_api {428 ($name:ident { $($arg:ident: $arg_ty:ty),+ $(,)? }) => {429 pub struct $name<Client, Block: BlockT> {430 $($arg: $arg_ty),+,431 _marker: std::marker::PhantomData<Block>,432 }433434 impl<Client, Block: BlockT> $name<Client, Block> {435 pub fn new($($arg: $arg_ty),+) -> Self {436 Self {437 $($arg),+,438 _marker: Default::default(),439 }440 }441 }442 };443}444445define_struct_for_server_api! {446 Unique {447 client: Arc<Client>448 }449}450451define_struct_for_server_api! {452 AppPromotion {453 client: Arc<Client>454 }455}456457define_struct_for_server_api! {458 Rmrk {459 client: Arc<Client>460 }461}462463macro_rules! pass_method {464 (465 $method_name:ident(466 $($(#[map(|$map_arg:ident| $map:expr)])? $name:ident: $ty:ty),* $(,)?467 ) -> $result:ty $(=> $mapper:expr)?,468 //$runtime_name:ident $(<$($lt: tt),+>)*469 $runtime_api_macro:ident470 $(; changed_in $ver:expr, $changed_method_name:ident ($($changed_name:expr), * $(,)?) => $fixer:expr)*471 ) => {472 fn $method_name(473 &self,474 $(475 $name: $ty,476 )*477 at: Option<<Block as BlockT>::Hash>,478 ) -> Result<$result> {479 let api = self.client.runtime_api();480 let at = BlockId::hash(at.unwrap_or_else(|| self.client.info().best_hash));481 let _api_version = if let Ok(Some(api_version)) =482 api.api_version::<$runtime_api_macro!()>(&at)483 {484 api_version485 } else {486 // unreachable for our runtime487 return Err(anyhow!("api is not available").into())488 };489490 let result = $(if _api_version < $ver {491 api.$changed_method_name(&at, $($changed_name),*).map(|r| r.map($fixer))492 } else)*493 { api.$method_name(&at, $($((|$map_arg: $ty| $map))? ($name)),*) };494495 Ok(result496 .map_err(|e| anyhow!("unable to query: {e}"))?497 .map_err(|e| anyhow!("runtime error: {e:?}"))$(.map($mapper))??)498 }499 };500}501502macro_rules! unique_api {503 () => {504 dyn UniqueRuntimeApi<Block, CrossAccountId, AccountId>505 };506}507508macro_rules! app_promotion_api {509 () => {510 dyn AppPromotionRuntimeApi<Block, BlockNumber, CrossAccountId, AccountId>511 };512}513514macro_rules! rmrk_api {515 () => {516 dyn RmrkRuntimeApi<Block, AccountId, CollectionInfo, NftInfo, ResourceInfo, PropertyInfo, BaseInfo, PartType, Theme>517 };518}519520#[allow(deprecated)]521impl<C, Block, CrossAccountId, AccountId>522 UniqueApiServer<<Block as BlockT>::Hash, CrossAccountId, AccountId> for Unique<C, Block>523where524 Block: BlockT,525 AccountId: Decode,526 C: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,527 C::Api: UniqueRuntimeApi<Block, CrossAccountId, AccountId>,528 CrossAccountId: pallet_evm::account::CrossAccountId<AccountId>,529{530 pass_method!(531 account_tokens(collection: CollectionId, account: CrossAccountId) -> Vec<TokenId>, unique_api532 );533 pass_method!(534 collection_tokens(collection: CollectionId) -> Vec<TokenId>, unique_api535 );536 pass_method!(537 token_exists(collection: CollectionId, token: TokenId) -> bool, unique_api538 );539 pass_method!(540 token_owner(collection: CollectionId, token: TokenId) -> Option<CrossAccountId>, unique_api541 );542 pass_method!(543 topmost_token_owner(collection: CollectionId, token: TokenId) -> Option<CrossAccountId>, unique_api544 );545 pass_method!(token_children(collection: CollectionId, token: TokenId) -> Vec<TokenChild>, unique_api);546 pass_method!(total_supply(collection: CollectionId) -> u32, unique_api);547 pass_method!(account_balance(collection: CollectionId, account: CrossAccountId) -> u32, unique_api);548 pass_method!(balance(collection: CollectionId, account: CrossAccountId, token: TokenId) -> String => |v| v.to_string(), unique_api);549 pass_method!(550 allowance(collection: CollectionId, sender: CrossAccountId, spender: CrossAccountId, token: TokenId) -> String => |v| v.to_string(),551 unique_api552 );553554 pass_method!(collection_properties(555 collection: CollectionId,556557 #[map(|keys| string_keys_to_bytes_keys(keys))]558 keys: Option<Vec<String>>559 ) -> Vec<Property>, unique_api);560561 pass_method!(token_properties(562 collection: CollectionId,563 token_id: TokenId,564565 #[map(|keys| string_keys_to_bytes_keys(keys))]566 keys: Option<Vec<String>>567 ) -> Vec<Property>, unique_api);568569 pass_method!(property_permissions(570 collection: CollectionId,571572 #[map(|keys| string_keys_to_bytes_keys(keys))]573 keys: Option<Vec<String>>574 ) -> Vec<PropertyKeyPermission>, unique_api);575576 pass_method!(577 token_data(578 collection: CollectionId,579 token_id: TokenId,580581 #[map(|keys| string_keys_to_bytes_keys(keys))]582 keys: Option<Vec<String>>,583 ) -> TokenData<CrossAccountId>, unique_api;584 changed_in 3, token_data_before_version_3(collection, token_id, string_keys_to_bytes_keys(keys)) => |value| value.into()585 );586587 pass_method!(adminlist(collection: CollectionId) -> Vec<CrossAccountId>, unique_api);588 pass_method!(allowlist(collection: CollectionId) -> Vec<CrossAccountId>, unique_api);589 pass_method!(allowed(collection: CollectionId, user: CrossAccountId) -> bool, unique_api);590 pass_method!(last_token_id(collection: CollectionId) -> TokenId, unique_api);591 pass_method!(592 collection_by_id(collection: CollectionId) -> Option<RpcCollection<AccountId>>, unique_api;593 changed_in 3, collection_by_id_before_version_3(collection) => |value| value.map(|coll| coll.into())594 );595 pass_method!(collection_stats() -> CollectionStats, unique_api);596 pass_method!(next_sponsored(collection: CollectionId, account: CrossAccountId, token: TokenId) -> Option<u64>, unique_api);597 pass_method!(effective_collection_limits(collection_id: CollectionId) -> Option<CollectionLimits>, unique_api);598 pass_method!(total_pieces(collection_id: CollectionId, token_id: TokenId) -> Option<String> => |o| o.map(|number| number.to_string()) , unique_api);599 pass_method!(token_owners(collection: CollectionId, token: TokenId) -> Vec<CrossAccountId>, unique_api);600 pass_method!(allowance_for_all(collection: CollectionId, owner: CrossAccountId, operator: CrossAccountId) -> bool, unique_api);601}602603impl<C, Block, BlockNumber, CrossAccountId, AccountId>604 app_promotion_unique_rpc::AppPromotionApiServer<605 <Block as BlockT>::Hash,606 BlockNumber,607 CrossAccountId,608 AccountId,609 > for AppPromotion<C, Block>610where611 Block: BlockT,612 BlockNumber: Decode + Member + AtLeast32BitUnsigned,613 AccountId: Decode,614 C: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,615 CrossAccountId: pallet_evm::account::CrossAccountId<AccountId>,616 C::Api: AppPromotionRuntimeApi<Block, BlockNumber, CrossAccountId, AccountId>,617{618 pass_method!(total_staked(staker: Option<CrossAccountId>) -> String => |v| v.to_string(), app_promotion_api);619 pass_method!(total_staked_per_block(staker: CrossAccountId) -> Vec<(BlockNumber, String)> =>620 |v| v621 .into_iter()622 .map(|(b, a)| (b, a.to_string()))623 .collect::<Vec<_>>(), app_promotion_api);624 pass_method!(pending_unstake(staker: Option<CrossAccountId>) -> String => |v| v.to_string(), app_promotion_api);625 pass_method!(pending_unstake_per_block(staker: CrossAccountId) -> Vec<(BlockNumber, String)> =>626 |v| v627 .into_iter()628 .map(|(b, a)| (b, a.to_string()))629 .collect::<Vec<_>>(), app_promotion_api);630}631632#[allow(deprecated)]633impl<634 C,635 Block,636 AccountId,637 CollectionInfo,638 NftInfo,639 ResourceInfo,640 PropertyInfo,641 BaseInfo,642 PartType,643 Theme,644 >645 rmrk_unique_rpc::RmrkApiServer<646 <Block as BlockT>::Hash,647 AccountId,648 CollectionInfo,649 NftInfo,650 ResourceInfo,651 PropertyInfo,652 BaseInfo,653 PartType,654 Theme,655 > for Rmrk<C, Block>656where657 C: Send + Sync + 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,658 C::Api: RmrkRuntimeApi<659 Block,660 AccountId,661 CollectionInfo,662 NftInfo,663 ResourceInfo,664 PropertyInfo,665 BaseInfo,666 PartType,667 Theme,668 >,669 AccountId: Decode + Encode,670 CollectionInfo: Decode,671 NftInfo: Decode,672 ResourceInfo: Decode,673 PropertyInfo: Decode,674 BaseInfo: Decode,675 PartType: Decode,676 Theme: Decode,677 Block: BlockT,678{679 pass_method!(last_collection_idx() -> RmrkCollectionId, rmrk_api);680 pass_method!(collection_by_id(id: RmrkCollectionId) -> Option<CollectionInfo>, rmrk_api);681 pass_method!(nft_by_id(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Option<NftInfo>, rmrk_api);682 pass_method!(account_tokens(account_id: AccountId, collection_id: RmrkCollectionId) -> Vec<RmrkNftId>, rmrk_api);683 pass_method!(nft_children(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Vec<RmrkNftChild>, rmrk_api);684 pass_method!(685 collection_properties(686 collection_id: RmrkCollectionId,687688 #[map(|keys| string_keys_to_bytes_keys(keys))]689 filter_keys: Option<Vec<String>>690 ) -> Vec<PropertyInfo>,691 rmrk_api692 );693 pass_method!(694 nft_properties(695 collection_id: RmrkCollectionId,696 nft_id: RmrkNftId,697698 #[map(|keys| string_keys_to_bytes_keys(keys))]699 filter_keys: Option<Vec<String>>700 ) -> Vec<PropertyInfo>,701 rmrk_api702 );703 pass_method!(nft_resources(collection_id: RmrkCollectionId, nft_id: RmrkNftId) -> Vec<ResourceInfo>, rmrk_api);704 pass_method!(nft_resource_priority(collection_id: RmrkCollectionId, nft_id: RmrkNftId, resource_id: RmrkResourceId) -> Option<u32>, rmrk_api);705 pass_method!(base(base_id: RmrkBaseId) -> Option<BaseInfo>, rmrk_api);706 pass_method!(base_parts(base_id: RmrkBaseId) -> Vec<PartType>, rmrk_api);707 pass_method!(theme_names(base_id: RmrkBaseId) -> Vec<RmrkThemeName>, rmrk_api);708 pass_method!(709 theme(710 base_id: RmrkBaseId,711712 #[map(|n| n.into_bytes())]713 theme_name: String,714715 #[map(|keys| string_keys_to_bytes_keys(keys))]716 filter_keys: Option<Vec<String>>717 ) -> Option<Theme>, rmrk_api);718}719720fn string_keys_to_bytes_keys(keys: Option<Vec<String>>) -> Option<Vec<Vec<u8>>> {721 keys.map(|keys| keys.into_iter().map(|key| key.into_bytes()).collect())722}client/rpc/src/pov_estimate.rsdiffbeforeafterboth--- /dev/null
+++ b/client/rpc/src/pov_estimate.rs
@@ -0,0 +1,205 @@
+// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
+// This file is part of Unique Network.
+
+// Unique Network 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.
+
+// Unique Network 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 Unique Network. If not, see <http://www.gnu.org/licenses/>.
+
+use std::sync::Arc;
+
+use codec::Encode;
+
+use up_pov_estimate_rpc::{PovEstimateApi as PovEstimateRuntimeApi};
+use up_common::types::opaque::RuntimeId;
+
+use sc_service::{NativeExecutionDispatch, config::ExecutionStrategy};
+use sp_state_machine::{StateMachine, TrieBackendBuilder};
+
+use jsonrpsee::{
+ core::RpcResult as Result,
+ proc_macros::rpc,
+};
+use anyhow::anyhow;
+
+use sc_client_api::backend::Backend;
+use sp_blockchain::HeaderBackend;
+use sp_api::{AsTrieBackend, BlockId, BlockT, ProvideRuntimeApi};
+
+use sc_executor::NativeElseWasmExecutor;
+use sc_rpc_api::DenyUnsafe;
+
+use sp_runtime::traits::Header;
+
+use up_pov_estimate_rpc::PovInfo;
+
+use crate::define_struct_for_server_api;
+
+type HasherOf<Block> = <<Block as BlockT>::Header as Header>::Hashing;
+type StateOf<Block> = <sc_service::TFullBackend<Block> as Backend<Block>>::State;
+
+pub struct ExecutorParams {
+ pub wasm_method: sc_service::config::WasmExecutionMethod,
+ pub default_heap_pages: Option<u64>,
+ pub max_runtime_instances: usize,
+ pub runtime_cache_size: u8,
+}
+
+#[cfg(feature = "unique-runtime")]
+pub struct UniqueRuntimeExecutor;
+
+#[cfg(feature = "quartz-runtime")]
+pub struct QuartzRuntimeExecutor;
+
+pub struct OpalRuntimeExecutor;
+
+#[cfg(feature = "unique-runtime")]
+impl NativeExecutionDispatch for UniqueRuntimeExecutor {
+ type ExtendHostFunctions = frame_benchmarking::benchmarking::HostFunctions;
+
+ fn dispatch(method: &str, data: &[u8]) -> Option<Vec<u8>> {
+ unique_runtime::api::dispatch(method, data)
+ }
+
+ fn native_version() -> sc_executor::NativeVersion {
+ unique_runtime::native_version()
+ }
+}
+
+#[cfg(feature = "quartz-runtime")]
+impl NativeExecutionDispatch for QuartzRuntimeExecutor {
+ type ExtendHostFunctions = frame_benchmarking::benchmarking::HostFunctions;
+
+ fn dispatch(method: &str, data: &[u8]) -> Option<Vec<u8>> {
+ quartz_runtime::api::dispatch(method, data)
+ }
+
+ fn native_version() -> sc_executor::NativeVersion {
+ quartz_runtime::native_version()
+ }
+}
+
+impl NativeExecutionDispatch for OpalRuntimeExecutor {
+ type ExtendHostFunctions = frame_benchmarking::benchmarking::HostFunctions;
+
+ fn dispatch(method: &str, data: &[u8]) -> Option<Vec<u8>> {
+ opal_runtime::api::dispatch(method, data)
+ }
+
+ fn native_version() -> sc_executor::NativeVersion {
+ opal_runtime::native_version()
+ }
+}
+
+#[cfg(feature = "pov-estimate")]
+define_struct_for_server_api! {
+ PovEstimate {
+ client: Arc<Client>,
+ backend: Arc<sc_service::TFullBackend<Block>>,
+ deny_unsafe: DenyUnsafe,
+ exec_params: ExecutorParams,
+ runtime_id: RuntimeId,
+ }
+}
+
+#[rpc(server)]
+#[async_trait]
+pub trait PovEstimateApi<BlockHash> {
+ #[method(name = "unique_povEstimate")]
+ fn pov_estimate(&self, encoded_xt: Vec<u8>, at: Option<BlockHash>) -> Result<PovInfo>;
+}
+
+#[allow(deprecated)]
+#[cfg(feature = "pov-estimate")]
+impl<C, Block>
+ PovEstimateApiServer<<Block as BlockT>::Hash> for PovEstimate<C, Block>
+where
+ Block: BlockT,
+ C: 'static + ProvideRuntimeApi<Block> + HeaderBackend<Block>,
+ C::Api: PovEstimateRuntimeApi<Block>,
+{
+ fn pov_estimate(&self, encoded_xt: Vec<u8>, at: Option<<Block as BlockT>::Hash>,) -> Result<PovInfo> {
+ self.deny_unsafe.check_if_safe()?;
+
+ let at = BlockId::<Block>::hash(at.unwrap_or_else(|| self.client.info().best_hash));
+ let state = self.backend.state_at(at).map_err(|_| anyhow!("unable to fetch the state at {at:?}"))?;
+ match &self.runtime_id {
+ #[cfg(feature = "unique-runtime")]
+ RuntimeId::Unique => execute_extrinsic_in_sandbox::<Block, UniqueRuntimeExecutor>(state, &self.exec_params, encoded_xt),
+
+ #[cfg(feature = "quartz-runtime")]
+ RuntimeId::Quartz => execute_extrinsic_in_sandbox::<Block, QuartzRuntimeExecutor>(state, &self.exec_params, encoded_xt),
+
+ RuntimeId::Opal => execute_extrinsic_in_sandbox::<Block, OpalRuntimeExecutor>(state, &self.exec_params, encoded_xt),
+
+ runtime_id => Err(anyhow!("unknown runtime id {:?}", runtime_id).into()),
+ }
+ }
+}
+
+fn execute_extrinsic_in_sandbox<Block, D>(state: StateOf<Block>, exec_params: &ExecutorParams, encoded_xt: Vec<u8>) -> Result<PovInfo>
+where
+ Block: BlockT,
+ D: NativeExecutionDispatch + 'static,
+{
+ let backend = state.as_trie_backend().clone();
+ let mut changes = Default::default();
+ let runtime_code_backend = sp_state_machine::backend::BackendRuntimeCode::new(backend);
+
+ let proving_backend =
+ TrieBackendBuilder::wrap(&backend).with_recorder(Default::default()).build();
+
+ let runtime_code = runtime_code_backend.runtime_code()
+ .map_err(|_| anyhow!("runtime code backend creation failed"))?;
+
+ let pre_root = *backend.root();
+
+ let executor = NativeElseWasmExecutor::<D>::new(
+ exec_params.wasm_method,
+ exec_params.default_heap_pages,
+ exec_params.max_runtime_instances,
+ exec_params.runtime_cache_size,
+ );
+ let execution = ExecutionStrategy::NativeElseWasm;
+
+ StateMachine::new(
+ &proving_backend,
+ &mut changes,
+ &executor,
+ "PovEstimateApi_pov_estimate",
+ encoded_xt.as_slice(),
+ sp_externalities::Extensions::default(),
+ &runtime_code,
+ sp_core::testing::TaskExecutor::new(),
+ )
+ .execute(execution.into())
+ .map_err(|e| anyhow!("failed to execute the extrinsic {:?}", e))?;
+
+ let proof = proving_backend
+ .extract_proof()
+ .expect("A recorder was set and thus, a storage proof can be extracted; qed");
+ let proof_size = proof.encoded_size();
+ let compact_proof = proof
+ .clone()
+ .into_compact_proof::<HasherOf<Block>>(pre_root)
+ .map_err(|e| anyhow!("failed to generate compact proof {:?}", e))?;
+ let compact_proof_size = compact_proof.encoded_size();
+
+ let compressed_proof = zstd::stream::encode_all(&compact_proof.encode()[..], 0)
+ .map_err(|e| anyhow!("failed to generate compact proof {:?}", e))?;
+ let compressed_proof_size = compressed_proof.len();
+
+ Ok(PovInfo {
+ proof_size: proof_size as u64,
+ compact_proof_size: compact_proof_size as u64,
+ compressed_proof_size: compressed_proof_size as u64,
+ })
+}
node/cli/Cargo.tomldiffbeforeafterboth--- a/node/cli/Cargo.toml
+++ b/node/cli/Cargo.toml
@@ -319,8 +319,10 @@
pallet-ethereum = { git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
unique-rpc = { default-features = false, path = "../rpc" }
+uc-rpc = { default-features = false, path = "../../client/rpc" }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc", default-features = false }
rmrk-rpc = { path = "../../primitives/rmrk-rpc" }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc", default-features = false }
[features]
default = ["opal-runtime"]
@@ -339,3 +341,10 @@
'try-runtime-cli/try-runtime',
]
sapphire-runtime = ['opal-runtime', 'opal-runtime/become-sapphire']
+pov-estimate = [
+ 'unique-runtime?/pov-estimate',
+ 'quartz-runtime?/pov-estimate',
+ 'opal-runtime/pov-estimate',
+ 'uc-rpc/pov-estimate',
+ 'unique-rpc/pov-estimate',
+]
node/cli/src/chain_spec.rsdiffbeforeafterboth--- a/node/cli/src/chain_spec.rs
+++ b/node/cli/src/chain_spec.rs
@@ -54,17 +54,6 @@
#[cfg(all(not(feature = "unique-runtime"), not(feature = "quartz-runtime")))]
pub type DefaultChainSpec = OpalChainSpec;
-pub enum RuntimeId {
- #[cfg(feature = "unique-runtime")]
- Unique,
-
- #[cfg(feature = "quartz-runtime")]
- Quartz,
-
- Opal,
- Unknown(String),
-}
-
#[cfg(not(feature = "unique-runtime"))]
/// PARA_ID for Opal/Sapphire/Quartz
const PARA_ID: u32 = 2095;
node/cli/src/command.rsdiffbeforeafterboth--- a/node/cli/src/command.rs
+++ b/node/cli/src/command.rs
@@ -33,7 +33,7 @@
// limitations under the License.
use crate::{
- chain_spec::{self, RuntimeId, RuntimeIdentification, ServiceId, ServiceIdentification},
+ chain_spec::{self, RuntimeIdentification, ServiceId, ServiceIdentification},
cli::{Cli, RelayChainCli, Subcommand},
service::{new_partial, start_node, start_dev_node},
};
@@ -66,13 +66,13 @@
use sp_runtime::traits::{AccountIdConversion, Block as BlockT};
use std::{net::SocketAddr, time::Duration};
-use up_common::types::opaque::Block;
+use up_common::types::opaque::{Block, RuntimeId};
macro_rules! no_runtime_err {
- ($chain_name:expr) => {
+ ($runtime_id:expr) => {
format!(
- "No runtime valid runtime was found for chain {}",
- $chain_name
+ "No runtime valid runtime was found for chain {:#?}",
+ $runtime_id
)
};
}
@@ -94,7 +94,7 @@
RuntimeId::Quartz => Box::new(chain_spec::QuartzChainSpec::from_json_file(path)?),
RuntimeId::Opal => chain_spec,
- RuntimeId::Unknown(chain) => return Err(no_runtime_err!(chain)),
+ runtime_id => return Err(no_runtime_err!(runtime_id)),
}
}
})
@@ -147,7 +147,7 @@
RuntimeId::Quartz => &quartz_runtime::VERSION,
RuntimeId::Opal => &opal_runtime::VERSION,
- RuntimeId::Unknown(chain) => panic!("{}", no_runtime_err!(chain)),
+ runtime_id => panic!("{}", no_runtime_err!(runtime_id)),
}
}
}
@@ -235,7 +235,7 @@
runner, $components, $cli, $cmd, $config, $( $code )*
),
- RuntimeId::Unknown(chain) => Err(no_runtime_err!(chain).into())
+ runtime_id => Err(no_runtime_err!(runtime_id).into())
}
}}
}
@@ -274,7 +274,7 @@
runner, $components, $cli, $cmd, $config, $( $code )*
),
- RuntimeId::Unknown(chain) => Err(no_runtime_err!(chain).into())
+ runtime_id => Err(no_runtime_err!(runtime_id).into())
}
}}
}
@@ -302,7 +302,7 @@
OpalRuntimeExecutor,
>($config $(, $($args),+)?) $($code)*,
- RuntimeId::Unknown(chain) => Err(no_runtime_err!(chain).into()),
+ runtime_id => Err(no_runtime_err!(runtime_id).into()),
}
};
}
@@ -445,7 +445,7 @@
sp_io::SubstrateHostFunctions,
<OpalRuntimeExecutor as NativeExecutionDispatch>::ExtendHostFunctions,
>>()),
- RuntimeId::Unknown(chain) => return Err(no_runtime_err!(chain).into()),
+ runtime_id => return Err(no_runtime_err!(runtime_id).into()),
},
task_manager,
))
node/cli/src/service.rsdiffbeforeafterboth--- a/node/cli/src/service.rs
+++ b/node/cli/src/service.rs
@@ -66,9 +66,8 @@
use fc_rpc_core::types::FilterPool;
use fc_mapping_sync::{MappingSyncWorker, SyncStrategy};
-use up_common::types::opaque::{
- AuraId, RuntimeInstance, AccountId, Balance, Index, Hash, Block, BlockNumber,
-};
+use up_common::types::opaque::*;
+use crate::chain_spec::RuntimeIdentification;
// RMRK
use up_data_structs::{
@@ -412,7 +411,8 @@
RmrkBaseInfo<AccountId>,
RmrkPartType,
RmrkTheme,
- > + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ > + up_pov_estimate_rpc::PovEstimateApi<Block>
+ + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ sp_api::Metadata<Block>
+ sp_offchain::OffchainWorkerApi<Block>
+ cumulus_primitives_core::CollectCollationInfo<Block>,
@@ -517,9 +517,25 @@
.for_each(|()| futures::future::ready(())),
);
+ let rpc_backend = backend.clone();
+ let runtime_id = parachain_config.chain_spec.runtime_id();
let rpc_builder = Box::new(move |deny_unsafe, subscription_task_executor| {
let full_deps = unique_rpc::FullDeps {
- backend: rpc_frontier_backend.clone(),
+ #[cfg(feature = "pov-estimate")]
+ runtime_id: runtime_id.clone(),
+
+ #[cfg(feature = "pov-estimate")]
+ exec_params: uc_rpc::pov_estimate::ExecutorParams {
+ wasm_method: parachain_config.wasm_method,
+ default_heap_pages: parachain_config.default_heap_pages,
+ max_runtime_instances: parachain_config.max_runtime_instances,
+ runtime_cache_size: parachain_config.runtime_cache_size,
+ },
+
+ #[cfg(feature = "pov-estimate")]
+ backend: rpc_backend.clone(),
+
+ eth_backend: rpc_frontier_backend.clone(),
deny_unsafe,
client: rpc_client.clone(),
pool: rpc_pool.clone(),
@@ -720,7 +736,8 @@
RmrkBaseInfo<AccountId>,
RmrkPartType,
RmrkTheme,
- > + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ > + up_pov_estimate_rpc::PovEstimateApi<Block>
+ + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ sp_api::Metadata<Block>
+ sp_offchain::OffchainWorkerApi<Block>
+ cumulus_primitives_core::CollectCollationInfo<Block>
@@ -869,7 +886,8 @@
RmrkBaseInfo<AccountId>,
RmrkPartType,
RmrkTheme,
- > + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ > + up_pov_estimate_rpc::PovEstimateApi<Block>
+ + substrate_frame_rpc_system::AccountNonceApi<Block, AccountId, Index>
+ sp_api::Metadata<Block>
+ sp_offchain::OffchainWorkerApi<Block>
+ cumulus_primitives_core::CollectCollationInfo<Block>
@@ -1040,9 +1058,24 @@
let rpc_pool = transaction_pool.clone();
let rpc_network = network.clone();
let rpc_frontier_backend = frontier_backend.clone();
+ let rpc_backend = backend.clone();
+ let runtime_id = config.chain_spec.runtime_id();
let rpc_builder = Box::new(move |deny_unsafe, subscription_executor| {
let full_deps = unique_rpc::FullDeps {
- backend: rpc_frontier_backend.clone(),
+ #[cfg(feature = "pov-estimate")]
+ runtime_id: runtime_id.clone(),
+
+ #[cfg(feature = "pov-estimate")]
+ exec_params: uc_rpc::pov_estimate::ExecutorParams {
+ wasm_method: config.wasm_method,
+ default_heap_pages: config.default_heap_pages,
+ max_runtime_instances: config.max_runtime_instances,
+ runtime_cache_size: config.runtime_cache_size,
+ },
+
+ #[cfg(feature = "pov-estimate")]
+ backend: rpc_backend.clone(),
+ eth_backend: rpc_frontier_backend.clone(),
deny_unsafe,
client: rpc_client.clone(),
pool: rpc_pool.clone(),
node/rpc/Cargo.tomldiffbeforeafterboth--- a/node/rpc/Cargo.toml
+++ b/node/rpc/Cargo.toml
@@ -55,6 +55,7 @@
up-rpc = { path = "../../primitives/rpc" }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc" }
rmrk-rpc = { path = "../../primitives/rmrk-rpc" }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc" }
up-data-structs = { default-features = false, path = "../../primitives/data-structs" }
[dependencies.serde]
@@ -65,3 +66,4 @@
default = []
std = []
unique-runtime = []
+pov-estimate = ['uc-rpc/pov-estimate']
node/rpc/src/lib.rsdiffbeforeafterboth--- a/node/rpc/src/lib.rs
+++ b/node/rpc/src/lib.rs
@@ -40,7 +40,7 @@
use sc_service::TransactionPool;
use std::{collections::BTreeMap, sync::Arc};
-use up_common::types::opaque::{Hash, AccountId, RuntimeInstance, Index, Block, BlockNumber, Balance};
+use up_common::types::opaque::*;
// RMRK
use up_data_structs::{
@@ -48,6 +48,8 @@
RmrkPartType, RmrkTheme,
};
+type FullBackend = sc_service::TFullBackend<Block>;
+
/// Extra dependencies for GRANDPA
pub struct GrandpaDeps<B> {
/// Voting round info.
@@ -82,8 +84,18 @@
pub deny_unsafe: DenyUnsafe,
/// EthFilterApi pool.
pub filter_pool: Option<FilterPool>,
- /// Backend.
- pub backend: Arc<fc_db::Backend<Block>>,
+
+ #[cfg(feature = "pov-estimate")]
+ pub runtime_id: RuntimeId,
+ /// Executor params for PoV estimating
+ #[cfg(feature = "pov-estimate")]
+ pub exec_params: uc_rpc::pov_estimate::ExecutorParams,
+ /// Substrate Backend.
+ #[cfg(feature = "pov-estimate")]
+ pub backend: Arc<FullBackend>,
+
+ /// Ethereum Backend.
+ pub eth_backend: Arc<fc_db::Backend<Block>>,
/// Maximum number of logs in a query.
pub max_past_logs: u32,
/// Maximum fee history cache size.
@@ -162,6 +174,7 @@
RmrkPartType,
RmrkTheme,
>,
+ C::Api: up_pov_estimate_rpc::PovEstimateApi<Block>,
B: sc_client_api::Backend<Block> + Send + Sync + 'static,
B::State: sc_client_api::backend::StateBackend<sp_runtime::traits::HashFor<Block>>,
P: TransactionPool<Block = Block> + 'static,
@@ -182,6 +195,9 @@
#[cfg(not(feature = "unique-runtime"))]
use uc_rpc::{RmrkApiServer, Rmrk};
+ #[cfg(feature = "pov-estimate")]
+ use uc_rpc::pov_estimate::{PovEstimateApiServer, PovEstimate};
+
// use pallet_contracts_rpc::{Contracts, ContractsApi};
use pallet_transaction_payment_rpc::{TransactionPayment, TransactionPaymentApiServer};
use substrate_frame_rpc_system::{System, SystemApiServer};
@@ -200,7 +216,17 @@
network,
deny_unsafe,
filter_pool,
+
+ #[cfg(feature = "pov-estimate")]
+ runtime_id,
+
+ #[cfg(feature = "pov-estimate")]
+ exec_params,
+
+ #[cfg(feature = "pov-estimate")]
backend,
+
+ eth_backend,
max_past_logs,
} = deps;
@@ -226,7 +252,7 @@
network.clone(),
signers,
overrides.clone(),
- backend.clone(),
+ eth_backend.clone(),
is_authority,
block_data_cache.clone(),
fee_history_cache,
@@ -244,11 +270,14 @@
#[cfg(not(feature = "unique-runtime"))]
io.merge(Rmrk::new(client.clone()).into_rpc())?;
+ #[cfg(feature = "pov-estimate")]
+ io.merge(PovEstimate::new(client.clone(), backend, deny_unsafe, exec_params, runtime_id).into_rpc())?;
+
if let Some(filter_pool) = filter_pool {
io.merge(
EthFilter::new(
client.clone(),
- backend,
+ eth_backend,
filter_pool,
500_usize, // max stored filters
max_past_logs,
pallets/common/Cargo.tomldiffbeforeafterboth--- a/pallets/common/Cargo.toml
+++ b/pallets/common/Cargo.toml
@@ -23,6 +23,7 @@
evm-coder = { default-features = false, path = '../../crates/evm-coder' }
ethereum = { version = "0.14.0", default-features = false }
pallet-evm = { default-features = false, git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
+up-pov-estimate-rpc = { default-features = false, path = "../../primitives/pov-estimate-rpc" }
serde = { version = "1.0.130", default-features = false }
scale-info = { version = "2.0.1", default-features = false, features = [
@@ -39,6 +40,7 @@
"fp-evm-mapping/std",
"up-data-structs/std",
"pallet-evm/std",
+ "up-pov-estimate-rpc/std",
]
runtime-benchmarks = [
"frame-benchmarking/runtime-benchmarks",
pallets/common/src/lib.rsdiffbeforeafterboth--- a/pallets/common/src/lib.rs
+++ b/pallets/common/src/lib.rs
@@ -115,6 +115,7 @@
RmrkNftChild,
CollectionPermissions,
};
+use up_pov_estimate_rpc::PovInfo;
pub use pallet::*;
use sp_core::H160;
@@ -881,6 +882,8 @@
RmrkPartType,
RmrkBoundedTheme,
RmrkNftChild,
+ // PoV Estimate Info
+ PovInfo,
)>,
),
QueryKind = OptionQuery,
primitives/common/src/types.rsdiffbeforeafterboth--- a/primitives/common/src/types.rs
+++ b/primitives/common/src/types.rs
@@ -29,6 +29,14 @@
pub use super::{BlockNumber, Signature, AccountId, Balance, Index, Hash, AuraId};
+ #[derive(Debug, Clone)]
+ pub enum RuntimeId {
+ Unique,
+ Quartz,
+ Opal,
+ Unknown(sp_std::vec::Vec<u8>),
+ }
+
/// Opaque block header type.
pub type Header = generic::Header<BlockNumber, BlakeTwo256>;
primitives/pov-estimate-rpc/Cargo.tomldiffbeforeafterboth--- /dev/null
+++ b/primitives/pov-estimate-rpc/Cargo.toml
@@ -0,0 +1,28 @@
+[package]
+name = "up-pov-estimate-rpc"
+version = "0.1.0"
+license = "GPLv3"
+edition = "2021"
+
+[dependencies]
+codec = { package = "parity-scale-codec", version = "3.1.2", default-features = false, features = [
+ "derive",
+] }
+serde = { version = "1.0.130", features = ["derive"], default-features = false, optional = true }
+scale-info = { version = "2.0.1", default-features = false, features = ["derive"] }
+sp-core = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sp-std = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sp-api = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+sp-runtime = { default-features = false, git = "https://github.com/paritytech/substrate", branch = "polkadot-v0.9.36" }
+
+[features]
+default = ["std"]
+std = [
+ "codec/std",
+ "serde/std",
+ "scale-info/std",
+ "sp-core/std",
+ "sp-std/std",
+ "sp-api/std",
+ "sp-runtime/std",
+]
primitives/pov-estimate-rpc/src/lib.rsdiffbeforeafterboth--- /dev/null
+++ b/primitives/pov-estimate-rpc/src/lib.rs
@@ -0,0 +1,39 @@
+// Copyright 2019-2022 Unique Network (Gibraltar) Ltd.
+// This file is part of Unique Network.
+
+// Unique Network 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.
+
+// Unique Network 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 Unique Network. If not, see <http://www.gnu.org/licenses/>.
+
+#![cfg_attr(not(feature = "std"), no_std)]
+
+use codec::{Decode, Encode, MaxEncodedLen};
+use scale_info::TypeInfo;
+
+#[cfg(feature = "std")]
+use serde::Serialize;
+
+use sp_runtime::ApplyExtrinsicResult;
+
+#[cfg_attr(feature = "std", derive(Serialize))]
+#[derive(Encode, Decode, Debug, TypeInfo, MaxEncodedLen)]
+pub struct PovInfo {
+ pub proof_size: u64,
+ pub compact_proof_size: u64,
+ pub compressed_proof_size: u64,
+}
+
+sp_api::decl_runtime_apis! {
+ pub trait PovEstimateApi {
+ fn pov_estimate(uxt: Block::Extrinsic) -> ApplyExtrinsicResult;
+ }
+}
runtime/common/runtime_apis.rsdiffbeforeafterboth--- a/runtime/common/runtime_apis.rs
+++ b/runtime/common/runtime_apis.rs
@@ -39,7 +39,7 @@
use sp_runtime::{
Permill,
traits::Block as BlockT,
- transaction_validity::{TransactionSource, TransactionValidity},
+ transaction_validity::{TransactionSource, TransactionValidity, TransactionValidityError, InvalidTransaction},
ApplyExtrinsicResult, DispatchError,
};
use fp_rpc::TransactionStatus;
@@ -778,6 +778,17 @@
}
}
+ impl up_pov_estimate_rpc::PovEstimateApi<Block> for Runtime {
+ #[allow(unused_variables)]
+ fn pov_estimate(uxt: <Block as BlockT>::Extrinsic) -> ApplyExtrinsicResult {
+ #[cfg(feature = "pov-estimate")]
+ return Executive::apply_extrinsic(uxt);
+
+ #[cfg(not(feature = "pov-estimate"))]
+ return Err(TransactionValidityError::Invalid(InvalidTransaction::Call))
+ }
+ }
+
#[cfg(feature = "try-runtime")]
impl frame_try_runtime::TryRuntime<Block> for Runtime {
fn on_runtime_upgrade(checks: bool) -> (frame_support::pallet_prelude::Weight, frame_support::pallet_prelude::Weight) {
runtime/opal/Cargo.tomldiffbeforeafterboth--- a/runtime/opal/Cargo.toml
+++ b/runtime/opal/Cargo.toml
@@ -127,6 +127,7 @@
'pallet-base-fee/std',
'fp-rpc/std',
'up-rpc/std',
+ 'up-pov-estimate-rpc/std',
'app-promotion-rpc/std',
'fp-evm-mapping/std',
'fp-self-contained/std',
@@ -184,6 +185,7 @@
'pallet-test-utils',
]
become-sapphire = []
+pov-estimate = []
refungible = []
scheduler = []
@@ -468,6 +470,7 @@
derivative = "2.2.0"
pallet-unique = { path = '../../pallets/unique', default-features = false }
up-rpc = { path = "../../primitives/rpc", default-features = false }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc", default-features = false }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc", default-features = false }
rmrk-rpc = { path = "../../primitives/rmrk-rpc", default-features = false }
fp-evm = { default-features = false, git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
runtime/quartz/Cargo.tomldiffbeforeafterboth--- a/runtime/quartz/Cargo.toml
+++ b/runtime/quartz/Cargo.toml
@@ -122,6 +122,7 @@
'pallet-base-fee/std',
'fp-rpc/std',
'up-rpc/std',
+ 'up-pov-estimate-rpc/std',
'app-promotion-rpc/std',
'fp-evm-mapping/std',
'fp-self-contained/std',
@@ -169,6 +170,7 @@
]
limit-testing = ['pallet-unique/limit-testing', 'up-data-structs/limit-testing']
quartz-runtime = ['refungible', 'app-promotion', 'foreign-assets']
+pov-estimate = []
refungible = []
scheduler = []
@@ -461,6 +463,7 @@
derivative = "2.2.0"
pallet-unique = { path = '../../pallets/unique', default-features = false }
up-rpc = { path = "../../primitives/rpc", default-features = false }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc", default-features = false }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc", default-features = false }
fp-evm = { default-features = false, git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
fp-evm-mapping = { default-features = false, git = "https://github.com/uniquenetwork/frontier", branch = "unique-polkadot-v0.9.36" }
runtime/unique/Cargo.tomldiffbeforeafterboth--- a/runtime/unique/Cargo.toml
+++ b/runtime/unique/Cargo.toml
@@ -123,6 +123,7 @@
'pallet-base-fee/std',
'fp-rpc/std',
'up-rpc/std',
+ 'up-pov-estimate-rpc/std',
'app-promotion-rpc/std',
'fp-evm-mapping/std',
'fp-self-contained/std',
@@ -170,6 +171,7 @@
]
limit-testing = ['pallet-unique/limit-testing', 'up-data-structs/limit-testing']
unique-runtime = ['foreign-assets']
+pov-estimate = []
stubgen = ["evm-coder/stubgen"]
refungible = []
@@ -454,6 +456,7 @@
derivative = "2.2.0"
pallet-unique = { path = '../../pallets/unique', default-features = false }
up-rpc = { path = "../../primitives/rpc", default-features = false }
+up-pov-estimate-rpc = { path = "../../primitives/pov-estimate-rpc", default-features = false }
app-promotion-rpc = { path = "../../primitives/app_promotion_rpc", default-features = false }
rmrk-rpc = { path = "../../primitives/rmrk-rpc", default-features = false }
pallet-inflation = { path = '../../pallets/inflation', default-features = false }