1234567891011121314151617use core::marker::PhantomData;18use up_sponsorship::SponsorshipHandler;19use frame_support::{20 traits::{IsSubType},21 storage::{StorageMap, StorageDoubleMap, StorageNMap},22};23use up_data_structs::{24 CollectionId, FUNGIBLE_SPONSOR_TRANSFER_TIMEOUT, NFT_SPONSOR_TRANSFER_TIMEOUT,25 REFUNGIBLE_SPONSOR_TRANSFER_TIMEOUT, TokenId, CollectionMode, CreateItemData,26};27use sp_runtime::traits::Saturating;28use pallet_common::{CollectionHandle};29use pallet_evm::account::CrossAccountId;30use pallet_unique::{31 Call as UniqueCall, Config as UniqueConfig, FungibleApproveBasket, RefungibleApproveBasket,32 NftApproveBasket, CreateItemBasket, ReFungibleTransferBasket, FungibleTransferBasket,33 NftTransferBasket, TokenPropertyBasket,34};35use pallet_fungible::Config as FungibleConfig;36use pallet_nonfungible::Config as NonfungibleConfig;37use pallet_refungible::Config as RefungibleConfig;3839pub trait Config: UniqueConfig + FungibleConfig + NonfungibleConfig + RefungibleConfig {}40impl<T> Config for T where T: UniqueConfig + FungibleConfig + NonfungibleConfig + RefungibleConfig {}414243pub fn withdraw_set_token_property<T: Config>(44 collection: &CollectionHandle<T>,45 who: &T::CrossAccountId,46 item_id: &TokenId,47 data_size: usize,48) -> Option<()> {49 50 match collection.mode {51 CollectionMode::NFT => {52 let owner = pallet_nonfungible::TokenData::<T>::get((collection.id, item_id))?.owner;53 if !owner.conv_eq(who) {54 return None;55 }56 }57 CollectionMode::Fungible(_) => {58 59 return None;60 }61 CollectionMode::ReFungible => {62 if !<pallet_refungible::Owned<T>>::get((collection.id, who, item_id)) {63 return None;64 }65 }66 }6768 if data_size > collection.limits.sponsored_data_size() as usize {69 return None;70 }7172 let block_number = <frame_system::Pallet<T>>::block_number() as T::BlockNumber;73 let limit = collection.limits.sponsored_data_rate_limit()?;7475 if let Some(last_tx_block) = TokenPropertyBasket::<T>::get(collection.id, item_id) {76 let timeout = last_tx_block + limit.into();77 if block_number < timeout {78 return None;79 }80 }8182 <TokenPropertyBasket<T>>::insert(collection.id, item_id, block_number);8384 Some(())85}8687pub fn withdraw_transfer<T: Config>(88 collection: &CollectionHandle<T>,89 who: &T::CrossAccountId,90 item_id: &TokenId,91) -> Option<()> {92 93 match collection.mode {94 CollectionMode::NFT => {95 let owner = pallet_nonfungible::TokenData::<T>::get((collection.id, item_id))?.owner;96 if !owner.conv_eq(who) {97 return None;98 }99 }100 CollectionMode::Fungible(_) => {101 if item_id != &TokenId::default() {102 return None;103 }104 if <pallet_fungible::Balance<T>>::get((collection.id, who)) == 0 {105 return None;106 }107 }108 CollectionMode::ReFungible => {109 if !<pallet_refungible::Owned<T>>::get((collection.id, who, item_id)) {110 return None;111 }112 }113 }114115 116 let block_number = <frame_system::Pallet<T>>::block_number() as T::BlockNumber;117 let limit = collection118 .limits119 .sponsor_transfer_timeout(match collection.mode {120 CollectionMode::NFT => NFT_SPONSOR_TRANSFER_TIMEOUT,121 CollectionMode::Fungible(_) => FUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,122 CollectionMode::ReFungible => REFUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,123 });124125 let last_tx_block = match collection.mode {126 CollectionMode::NFT => <NftTransferBasket<T>>::get(collection.id, item_id),127 CollectionMode::Fungible(_) => {128 <FungibleTransferBasket<T>>::get(collection.id, who.as_sub())129 }130 CollectionMode::ReFungible => {131 <ReFungibleTransferBasket<T>>::get((collection.id, item_id, who.as_sub()))132 }133 };134135 if let Some(last_tx_block) = last_tx_block {136 let timeout = last_tx_block + limit.into();137 if block_number < timeout {138 return None;139 }140 }141142 match collection.mode {143 CollectionMode::NFT => <NftTransferBasket<T>>::insert(collection.id, item_id, block_number),144 CollectionMode::Fungible(_) => {145 <FungibleTransferBasket<T>>::insert(collection.id, who.as_sub(), block_number)146 }147 CollectionMode::ReFungible => <ReFungibleTransferBasket<T>>::insert(148 (collection.id, item_id, who.as_sub()),149 block_number,150 ),151 };152153 Some(())154}155156pub fn withdraw_create_item<T: Config>(157 collection: &CollectionHandle<T>,158 who: &T::CrossAccountId,159 properties: &CreateItemData,160) -> Option<()> {161 162 let block_number = <frame_system::Pallet<T>>::block_number() as T::BlockNumber;163 let limit = collection164 .limits165 .sponsor_transfer_timeout(match properties {166 CreateItemData::NFT(_) => NFT_SPONSOR_TRANSFER_TIMEOUT,167 CreateItemData::Fungible(_) => FUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,168 CreateItemData::ReFungible(_) => REFUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,169 });170171 if let Some(last_tx_block) = <CreateItemBasket<T>>::get((collection.id, who.as_sub())) {172 let timeout = last_tx_block + limit.into();173 if block_number < timeout {174 return None;175 }176 }177178 CreateItemBasket::<T>::insert((collection.id, who.as_sub()), block_number);179180 Some(())181}182183pub fn withdraw_approve<T: Config>(184 collection: &CollectionHandle<T>,185 who: &T::AccountId,186 item_id: &TokenId,187) -> Option<()> {188 189 let block_number = <frame_system::Pallet<T>>::block_number() as T::BlockNumber;190 let limit = collection.limits.sponsor_approve_timeout();191192 let last_tx_block = match collection.mode {193 CollectionMode::NFT => <NftApproveBasket<T>>::get(collection.id, item_id),194 CollectionMode::Fungible(_) => <FungibleApproveBasket<T>>::get(collection.id, who),195 CollectionMode::ReFungible => {196 <RefungibleApproveBasket<T>>::get((collection.id, item_id, who))197 }198 };199200 if let Some(last_tx_block) = last_tx_block {201 let timeout = last_tx_block + limit.into();202 if block_number < timeout {203 return None;204 }205 }206207 match collection.mode {208 CollectionMode::NFT => <NftApproveBasket<T>>::insert(collection.id, item_id, block_number),209 CollectionMode::Fungible(_) => {210 <FungibleApproveBasket<T>>::insert(collection.id, who, block_number)211 }212 CollectionMode::ReFungible => {213 <RefungibleApproveBasket<T>>::insert((collection.id, item_id, who), block_number)214 }215 };216217 Some(())218}219220fn load<T: UniqueConfig>(id: CollectionId) -> Option<(T::AccountId, CollectionHandle<T>)> {221 let collection = CollectionHandle::new(id)?;222 let sponsor = collection.sponsorship.sponsor().cloned()?;223 Some((sponsor, collection))224}225226pub struct UniqueSponsorshipHandler<T>(PhantomData<T>);227impl<T, C> SponsorshipHandler<T::AccountId, C> for UniqueSponsorshipHandler<T>228where229 T: Config,230 C: IsSubType<UniqueCall<T>>,231{232 fn get_sponsor(who: &T::AccountId, call: &C) -> Option<T::AccountId> {233 match IsSubType::<UniqueCall<T>>::is_sub_type(call)? {234 UniqueCall::set_token_properties {235 collection_id,236 token_id,237 properties,238 ..239 } => {240 let (sponsor, collection) = load::<T>(*collection_id)?;241 withdraw_set_token_property(242 &collection,243 &T::CrossAccountId::from_sub(who.clone()),244 &token_id,245 246 properties.iter().map(|p| p.key.len() + p.value.len()).sum(),247 )248 .map(|()| sponsor)249 }250 UniqueCall::create_item {251 collection_id,252 data,253 ..254 } => {255 let (sponsor, collection) = load(*collection_id)?;256 withdraw_create_item::<T>(257 &collection,258 &T::CrossAccountId::from_sub(who.clone()),259 data,260 )261 .map(|()| sponsor)262 }263 UniqueCall::transfer {264 collection_id,265 item_id,266 ..267 } => {268 let (sponsor, collection) = load(*collection_id)?;269 withdraw_transfer::<T>(270 &collection,271 &T::CrossAccountId::from_sub(who.clone()),272 item_id,273 )274 .map(|()| sponsor)275 }276 UniqueCall::transfer_from {277 collection_id,278 item_id,279 from,280 ..281 } => {282 let (sponsor, collection) = load(*collection_id)?;283 withdraw_transfer::<T>(&collection, from, item_id).map(|()| sponsor)284 }285 UniqueCall::approve {286 collection_id,287 item_id,288 ..289 } => {290 let (sponsor, collection) = load(*collection_id)?;291 withdraw_approve::<T>(&collection, who, item_id).map(|()| sponsor)292 }293 _ => None,294 }295 }296}297298pub trait SponsorshipPredict<T: Config> {299 fn predict(collection: CollectionId, account: T::CrossAccountId, token: TokenId) -> Option<u64>300 where301 u64: From<<T as frame_system::Config>::BlockNumber>;302}303304pub struct UniqueSponsorshipPredict<T>(PhantomData<T>);305306impl<T: Config> SponsorshipPredict<T> for UniqueSponsorshipPredict<T> {307 fn predict(collection_id: CollectionId, who: T::CrossAccountId, token: TokenId) -> Option<u64>308 where309 u64: From<<T as frame_system::Config>::BlockNumber>,310 {311 let collection = <CollectionHandle<T>>::try_get(collection_id).ok()?;312 let _ = collection.sponsorship.sponsor()?;313314 315 let block_number = <frame_system::Pallet<T>>::block_number() as T::BlockNumber;316 let limit = collection317 .limits318 .sponsor_transfer_timeout(match collection.mode {319 CollectionMode::NFT => NFT_SPONSOR_TRANSFER_TIMEOUT,320 CollectionMode::Fungible(_) => FUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,321 CollectionMode::ReFungible => REFUNGIBLE_SPONSOR_TRANSFER_TIMEOUT,322 });323324 let last_tx_block = match collection.mode {325 CollectionMode::NFT => <NftTransferBasket<T>>::get(collection.id, token),326 CollectionMode::Fungible(_) => {327 <FungibleTransferBasket<T>>::get(collection.id, who.as_sub())328 }329 CollectionMode::ReFungible => {330 <ReFungibleTransferBasket<T>>::get((collection.id, token, who.as_sub()))331 }332 };333334 if let Some(last_tx_block) = last_tx_block {335 return Some(336 last_tx_block337 .saturating_add(limit.into())338 .saturating_sub(block_number)339 .into(),340 );341 }342343 let token_exists = match collection.mode {344 CollectionMode::NFT => {345 <pallet_nonfungible::TokenData<T>>::contains_key((collection.id, token))346 }347 CollectionMode::Fungible(_) => token == TokenId::default(),348 CollectionMode::ReFungible => {349 <pallet_refungible::TotalSupply<T>>::contains_key((collection.id, token))350 }351 };352353 if token_exists {354 Some(0)355 } else {356 None357 }358 }359}