123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354#![cfg_attr(not(feature = "std"), no_std)]5556use pallet_common::CommonCollectionOperations;57use sp_std::collections::btree_set::BTreeSet;5859use frame_support::dispatch::{DispatchError, DispatchResult, DispatchResultWithPostInfo};60use frame_support::fail;61pub use pallet::*;62use pallet_common::{dispatch::CollectionDispatch, CollectionHandle};63use up_data_structs::{CollectionId, TokenId, mapping::TokenAddressMapping, budget::Budget};6465#[cfg(feature = "runtime-benchmarks")]66pub mod benchmarking;67pub mod weights;6869pub type SelfWeightOf<T> = <T as crate::Config>::WeightInfo;7071#[frame_support::pallet]72pub mod pallet {73 use frame_support::Parameter;74 use frame_support::dispatch::{GetDispatchInfo, UnfilteredDispatchable};75 use frame_support::pallet_prelude::*;7677 use super::*;7879 #[pallet::error]80 pub enum Error<T> {81 82 OuroborosDetected,83 84 DepthLimit,85 86 BreadthLimit,87 88 TokenNotFound,89 }9091 #[pallet::event]92 pub enum Event<T> {93 94 Executed(DispatchResult),95 }9697 #[pallet::config]98 pub trait Config: frame_system::Config + pallet_common::Config {99 type WeightInfo: weights::WeightInfo;100 type RuntimeEvent: IsType<<Self as frame_system::Config>::RuntimeEvent> + From<Event<Self>>;101 type RuntimeCall: Parameter102 + UnfilteredDispatchable<RuntimeOrigin = Self::RuntimeOrigin>103 + GetDispatchInfo;104 }105106 #[pallet::pallet]107 pub struct Pallet<T>(_);108109 #[pallet::call]110 impl<T: Config> Pallet<T> {111 112 113114 115 116 117 118 119 120 121 122 123 124 125 126 }127}128129#[derive(PartialEq)]130pub enum Parent<CrossAccountId> {131 132 User(CrossAccountId),133 134 TokenNotFound,135 136 Token(CollectionId, TokenId),137}138139impl<T: Config> Pallet<T> {140 141 142 143 144 145 146 pub fn find_parent(147 collection: CollectionId,148 token: TokenId,149 ) -> Result<Parent<T::CrossAccountId>, DispatchError> {150 151 let handle = match CollectionHandle::try_get(collection) {152 Ok(v) => v,153 Err(_) => return Ok(Parent::TokenNotFound),154 };155 let handle = T::CollectionDispatch::dispatch(handle);156 let handle = handle.as_dyn();157158 Ok(match handle.token_owner(token) {159 Some(owner) => match T::CrossTokenAddressMapping::address_to_token(&owner) {160 Some((collection, token)) => Parent::Token(collection, token),161 None => Parent::User(owner),162 },163 None => Parent::TokenNotFound,164 })165 }166167 168 169 170 171 172 pub fn parent_chain(173 mut collection: CollectionId,174 mut token: TokenId,175 ) -> impl Iterator<Item = Result<Parent<T::CrossAccountId>, DispatchError>> {176 let mut finished = false;177 let mut visited = BTreeSet::new();178 visited.insert((collection, token));179 core::iter::from_fn(move || {180 if finished {181 return None;182 }183 let parent = Self::find_parent(collection, token);184 match parent {185 Ok(Parent::Token(new_collection, new_token)) => {186 collection = new_collection;187 token = new_token;188 if !visited.insert((new_collection, new_token)) {189 finished = true;190 return Some(Err(<Error<T>>::OuroborosDetected.into()));191 }192 }193 _ => finished = true,194 }195 Some(parent as Result<_, DispatchError>)196 })197 }198199 200 201 202 203 204 pub fn find_topmost_owner(205 collection: CollectionId,206 token: TokenId,207 budget: &dyn Budget,208 ) -> Result<T::CrossAccountId, DispatchError> {209 let owner = Self::parent_chain(collection, token)210 .take_while(|_| budget.consume())211 .find(|p| matches!(p, Ok(Parent::User(_) | Parent::TokenNotFound)))212 .ok_or(<Error<T>>::DepthLimit)??;213214 Ok(match owner {215 Parent::User(v) => v,216 _ => fail!(<Error<T>>::TokenNotFound),217 })218 }219220 221 222 223 224 pub fn get_checked_topmost_owner(225 collection: CollectionId,226 token: TokenId,227 for_nest: Option<(CollectionId, TokenId)>,228 budget: &dyn Budget,229 ) -> Result<T::CrossAccountId, DispatchError> {230 231 if Some((collection, token)) == for_nest {232 return Err(<Error<T>>::OuroborosDetected.into());233 }234235 for parent in Self::parent_chain(collection, token).take_while(|_| budget.consume()) {236 match parent? {237 238 Parent::Token(collection, token) if Some((collection, token)) == for_nest => {239 return Err(<Error<T>>::OuroborosDetected.into())240 }241 242 Parent::User(user) => return Ok(user),243 Parent::TokenNotFound => return Err(<Error<T>>::TokenNotFound.into()),244 245 Parent::Token(_, _) => {}246 }247 }248249 Err(<Error<T>>::DepthLimit.into())250 }251252 253 254 255 256 pub fn burn_item_recursively(257 from: T::CrossAccountId,258 collection: CollectionId,259 token: TokenId,260 self_budget: &dyn Budget,261 breadth_budget: &dyn Budget,262 ) -> DispatchResultWithPostInfo {263 let handle = <CollectionHandle<T>>::try_get(collection)?;264 let dispatch = T::CollectionDispatch::dispatch(handle);265 let dispatch = dispatch.as_dyn();266 dispatch.burn_item_recursively(from.clone(), token, self_budget, breadth_budget)267 }268269 270 271 272 273 274 275 276 pub fn check_indirectly_owned(277 user: T::CrossAccountId,278 collection: CollectionId,279 token: TokenId,280 for_nest: Option<(CollectionId, TokenId)>,281 budget: &dyn Budget,282 ) -> Result<bool, DispatchError> {283 let target_parent = match T::CrossTokenAddressMapping::address_to_token(&user) {284 Some((collection, token)) => Self::find_topmost_owner(collection, token, budget)?,285 None => user,286 };287288 Self::get_checked_topmost_owner(collection, token, for_nest, budget)289 .map(|indirect_owner| indirect_owner == target_parent)290 }291292 293 294 295 296 297 298 pub fn check_nesting(299 from: T::CrossAccountId,300 under: &T::CrossAccountId,301 collection_id: CollectionId,302 token_id: TokenId,303 nesting_budget: &dyn Budget,304 ) -> DispatchResult {305 Self::try_exec_if_owner_is_valid_nft(under, |collection, parent_id| {306 collection.check_nesting(from, (collection_id, token_id), parent_id, nesting_budget)307 })308 }309310 311 312 313 314 315 pub fn nest_if_sent_to_token(316 from: T::CrossAccountId,317 under: &T::CrossAccountId,318 collection_id: CollectionId,319 token_id: TokenId,320 nesting_budget: &dyn Budget,321 ) -> DispatchResult {322 Self::try_exec_if_owner_is_valid_nft(under, |collection, parent_id| {323 collection.check_nesting(from, (collection_id, token_id), parent_id, nesting_budget)?;324325 collection.nest(parent_id, (collection_id, token_id));326327 Ok(())328 })329 }330331 332 333 334 pub fn nest_if_sent_to_token_unchecked(335 owner: &T::CrossAccountId,336 collection_id: CollectionId,337 token_id: TokenId,338 ) {339 Self::exec_if_owner_is_valid_nft(owner, |collection, parent_id| {340 collection.nest(parent_id, (collection_id, token_id))341 });342 }343344 345 pub fn unnest_if_nested(346 owner: &T::CrossAccountId,347 collection_id: CollectionId,348 token_id: TokenId,349 ) {350 Self::exec_if_owner_is_valid_nft(owner, |collection, parent_id| {351 collection.unnest(parent_id, (collection_id, token_id))352 });353 }354355 fn exec_if_owner_is_valid_nft(356 account: &T::CrossAccountId,357 action: impl FnOnce(&dyn CommonCollectionOperations<T>, TokenId),358 ) {359 Self::try_exec_if_owner_is_valid_nft(account, |collection, id| {360 action(collection, id);361 Ok(())362 })363 .unwrap();364 }365366 fn try_exec_if_owner_is_valid_nft(367 account: &T::CrossAccountId,368 action: impl FnOnce(&dyn CommonCollectionOperations<T>, TokenId) -> DispatchResult,369 ) -> DispatchResult {370 let account = T::CrossTokenAddressMapping::address_to_token(account);371372 if account.is_none() {373 return Ok(());374 }375376 let account = account.unwrap();377378 let handle = <CollectionHandle<T>>::try_get(account.0);379380 if handle.is_err() {381 return Ok(());382 }383384 let handle = handle.unwrap();385386 let dispatch = T::CollectionDispatch::dispatch(handle);387 let dispatch = dispatch.as_dyn();388389 action(dispatch, account.1)390 }391}