1#![cfg_attr(not(feature = "std"), no_std)]2345use codec::{Decode, Encode};6pub use frame_support::{7 construct_runtime, decl_event, decl_module, decl_storage,8 dispatch::DispatchResult,9 ensure, parameter_types,10 traits::{11 Currency, ExistenceRequirement, Get, Imbalance, KeyOwnerProofSystem, OnUnbalanced,12 Randomness, WithdrawReason,13 },14 weights::{15 constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},16 DispatchInfo, GetDispatchInfo, IdentityFee, Pays, PostDispatchInfo, Weight,17 WeightToFeePolynomial,18 },19 IsSubType, StorageValue,20};2122use frame_system::{self as system, ensure_signed};23use sp_runtime::sp_std::prelude::Vec;24use sp_runtime::{25 traits::{26 DispatchInfoOf, Dispatchable, PostDispatchInfoOf, SaturatedConversion, Saturating,27 SignedExtension, Zero,28 },29 transaction_validity::{30 InvalidTransaction, TransactionPriority, TransactionValidity, TransactionValidityError,31 ValidTransaction,32 },33 FixedPointOperand, FixedU128,34};35use sp_std::prelude::*;3637#[cfg(test)]38mod mock;3940#[cfg(test)]41mod tests;4243#[derive(Encode, Decode, Debug, Eq, Clone, PartialEq)]44pub enum CollectionMode {45 Invalid,46 47 NFT(u32),48 49 Fungible(u32),50 51 ReFungible(u32, u32),52}5354impl Into<u8> for CollectionMode {55 fn into(self) -> u8 {56 match self {57 CollectionMode::Invalid => 0,58 CollectionMode::NFT(_) => 1,59 CollectionMode::Fungible(_) => 2,60 CollectionMode::ReFungible(_, _) => 3,61 }62 }63}6465#[derive(Encode, Decode, Debug, Clone, PartialEq)]66pub enum AccessMode {67 Normal,68 WhiteList,69}70impl Default for AccessMode {71 fn default() -> Self {72 Self::Normal73 }74}7576impl Default for CollectionMode {77 fn default() -> Self {78 Self::Invalid79 }80}8182#[derive(Encode, Decode, Default, Clone, PartialEq)]83#[cfg_attr(feature = "std", derive(Debug))]84pub struct Ownership<AccountId> {85 pub owner: AccountId,86 pub fraction: u128,87}8889#[derive(Encode, Decode, Default, Clone, PartialEq)]90#[cfg_attr(feature = "std", derive(Debug))]91pub struct CollectionType<AccountId> {92 pub owner: AccountId,93 pub mode: CollectionMode,94 pub access: AccessMode,95 pub decimal_points: u32,96 pub name: Vec<u16>, 97 pub description: Vec<u16>, 98 pub token_prefix: Vec<u8>, 99 pub custom_data_size: u32,100 pub offchain_schema: Vec<u8>,101 pub sponsor: AccountId, 102 pub unconfirmed_sponsor: AccountId, 103}104105#[derive(Encode, Decode, Default, Clone, PartialEq)]106#[cfg_attr(feature = "std", derive(Debug))]107pub struct CollectionAdminsType<AccountId> {108 pub admin: AccountId,109 pub collection_id: u64,110}111112#[derive(Encode, Decode, Default, Clone, PartialEq)]113#[cfg_attr(feature = "std", derive(Debug))]114pub struct NftItemType<AccountId> {115 pub collection: u64,116 pub owner: AccountId,117 pub data: Vec<u8>,118}119120#[derive(Encode, Decode, Default, Clone, PartialEq)]121#[cfg_attr(feature = "std", derive(Debug))]122pub struct FungibleItemType<AccountId> {123 pub collection: u64,124 pub owner: AccountId,125 pub value: u128,126}127128#[derive(Encode, Decode, Default, Clone, PartialEq)]129#[cfg_attr(feature = "std", derive(Debug))]130pub struct ReFungibleItemType<AccountId> {131 pub collection: u64,132 pub owner: Vec<Ownership<AccountId>>,133 pub data: Vec<u8>,134}135136#[derive(Encode, Decode, Default, Clone, PartialEq)]137#[cfg_attr(feature = "std", derive(Debug))]138pub struct ApprovePermissions<AccountId> {139 pub approved: AccountId,140 pub amount: u64,141}142143#[derive(Encode, Decode, Default, Clone, PartialEq)]144#[cfg_attr(feature = "std", derive(Debug))]145pub struct VestingItem<AccountId, Moment> {146 pub sender: AccountId,147 pub recipient: AccountId,148 pub collection_id: u64,149 pub item_id: u64,150 pub amount: u64,151 pub vesting_date: Moment,152}153154pub trait Trait: system::Trait {155 type Event: From<Event<Self>> + Into<<Self as system::Trait>::Event>;156}157158decl_storage! {159 trait Store for Module<T: Trait> as Nft {160161 162 NextCollectionID: u64;163 CreatedCollectionCount: u64;164 ChainVersion: u64;165 ItemListIndex: map hasher(blake2_128_concat) u64 => u64;166167 pub Collection get(fn collection): map hasher(identity) u64 => CollectionType<T::AccountId>;168 pub AdminList get(fn admin_list_collection): map hasher(identity) u64 => Vec<T::AccountId>;169 pub WhiteList get(fn white_list): map hasher(identity) u64 => Vec<T::AccountId>;170171 172 pub Balance get(fn balance_count): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => u64;173174 175 pub ApprovedList get(fn approved): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) (u64, T::AccountId) => Vec<ApprovePermissions<T::AccountId>>;176177 178 pub NftItemList get(fn nft_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => NftItemType<T::AccountId>;179 pub FungibleItemList get(fn fungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => FungibleItemType<T::AccountId>;180 pub ReFungibleItemList get(fn refungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => ReFungibleItemType<T::AccountId>;181182 183 184185 186 pub AddressTokens get(fn address_tokens): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => Vec<u64>;187188 189 pub ContractSponsor get(fn contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;190 pub UnconfirmedContractSponsor get(fn unconfirmed_contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;191 }192}193194decl_event!(195 pub enum Event<T>196 where197 AccountId = <T as system::Trait>::AccountId,198 {199 Created(u64, u8, AccountId),200 ItemCreated(u64, u64),201 ItemDestroyed(u64, u64),202 }203);204205decl_module! {206 pub struct Module<T: Trait> for enum Call where origin: T::Origin {207208 fn deposit_event() = default;209210 fn on_initialize(now: T::BlockNumber) -> Weight {211212 if ChainVersion::get() == 0213 {214 let value = NextCollectionID::get();215 CreatedCollectionCount::put(value);216 ChainVersion::put(2);217 }218219 0220 }221222 223 224 225 226 #[weight = 0]227 pub fn create_collection( origin,228 collection_name: Vec<u16>,229 collection_description: Vec<u16>,230 token_prefix: Vec<u8>,231 mode: CollectionMode) -> DispatchResult {232233 234 let who = ensure_signed(origin)?;235 let custom_data_size = match mode {236 CollectionMode::NFT(size) => size,237 CollectionMode::ReFungible(size, _) => size,238 _ => 0239 };240241 let decimal_points = match mode {242 CollectionMode::Fungible(points) => points,243 CollectionMode::ReFungible(_, points) => points,244 _ => 0245 };246247 248 ensure!(decimal_points <= 4, "decimal_points parameter must be lower than 4");249250 let mut name = collection_name.to_vec();251 name.push(0);252 ensure!(name.len() <= 64, "Collection name can not be longer than 63 char");253254 let mut description = collection_description.to_vec();255 description.push(0);256 ensure!(name.len() <= 256, "Collection description can not be longer than 255 char");257258 let mut prefix = token_prefix.to_vec();259 prefix.push(0);260 ensure!(prefix.len() <= 16, "Token prefix can not be longer than 15 char");261262 263 let next_id = NextCollectionID::get()264 .checked_add(1)265 .expect("collection id error");266267 NextCollectionID::put(next_id);268269 270 let new_collection = CollectionType {271 owner: who.clone(),272 name: name,273 mode: mode.clone(),274 access: AccessMode::Normal,275 description: description,276 decimal_points: decimal_points,277 token_prefix: prefix,278 offchain_schema: Vec::new(),279 custom_data_size: custom_data_size,280 sponsor: T::AccountId::default(),281 unconfirmed_sponsor: T::AccountId::default(),282 };283284 285 <Collection<T>>::insert(next_id, new_collection);286287 288 Self::deposit_event(RawEvent::Created(next_id, mode.into(), who.clone()));289290 Ok(())291 }292293 #[weight = 0]294 pub fn destroy_collection(origin, collection_id: u64) -> DispatchResult {295296 let sender = ensure_signed(origin)?;297 Self::check_owner_permissions(collection_id, sender)?;298299 300 <AddressTokens<T>>::remove_prefix(collection_id);301 <ApprovedList<T>>::remove_prefix(collection_id);302 <Balance<T>>::remove_prefix(collection_id);303 <ItemListIndex>::remove(collection_id);304 <AdminList<T>>::remove(collection_id);305 <Collection<T>>::remove(collection_id);306 <WhiteList<T>>::remove(collection_id);307308 Ok(())309 }310311 #[weight = 0]312 pub fn change_collection_owner(origin, collection_id: u64, new_owner: T::AccountId) -> DispatchResult {313314 let sender = ensure_signed(origin)?;315 Self::check_owner_permissions(collection_id, sender)?;316 let mut target_collection = <Collection<T>>::get(collection_id);317 target_collection.owner = new_owner;318 <Collection<T>>::insert(collection_id, target_collection);319320 Ok(())321 }322323 #[weight = 0]324 pub fn add_collection_admin(origin, collection_id: u64, new_admin_id: T::AccountId) -> DispatchResult {325326 let sender = ensure_signed(origin)?;327 Self::check_owner_or_admin_permissions(collection_id, sender)?;328 let mut admin_arr: Vec<T::AccountId> = Vec::new();329330 if <AdminList<T>>::contains_key(collection_id)331 {332 admin_arr = <AdminList<T>>::get(collection_id);333 ensure!(!admin_arr.contains(&new_admin_id), "Account already has admin role");334 }335336 admin_arr.push(new_admin_id);337 <AdminList<T>>::insert(collection_id, admin_arr);338339 Ok(())340 }341342 #[weight = 0]343 pub fn remove_collection_admin(origin, collection_id: u64, account_id: T::AccountId) -> DispatchResult {344345 let sender = ensure_signed(origin)?;346 Self::check_owner_or_admin_permissions(collection_id, sender)?;347348 if <AdminList<T>>::contains_key(collection_id)349 {350 let mut admin_arr = <AdminList<T>>::get(collection_id);351 admin_arr.retain(|i| *i != account_id);352 <AdminList<T>>::insert(collection_id, admin_arr);353 }354355 Ok(())356 }357358 #[weight = 0]359 pub fn set_collection_sponsor(origin, collection_id: u64, new_sponsor: T::AccountId) -> DispatchResult {360361 let sender = ensure_signed(origin)?;362 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");363364 let mut target_collection = <Collection<T>>::get(collection_id);365 ensure!(sender == target_collection.owner, "You do not own this collection");366367 target_collection.unconfirmed_sponsor = new_sponsor;368 <Collection<T>>::insert(collection_id, target_collection);369370 Ok(())371 }372373 #[weight = 0]374 pub fn confirm_sponsorship(origin, collection_id: u64) -> DispatchResult {375376 let sender = ensure_signed(origin)?;377 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");378379 let mut target_collection = <Collection<T>>::get(collection_id);380 ensure!(sender == target_collection.unconfirmed_sponsor, "This address is not set as sponsor, use setCollectionSponsor first");381382 target_collection.sponsor = target_collection.unconfirmed_sponsor;383 target_collection.unconfirmed_sponsor = T::AccountId::default();384 <Collection<T>>::insert(collection_id, target_collection);385386 Ok(())387 }388389 #[weight = 0]390 pub fn remove_collection_sponsor(origin, collection_id: u64) -> DispatchResult {391392 let sender = ensure_signed(origin)?;393 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");394395 let mut target_collection = <Collection<T>>::get(collection_id);396 ensure!(sender == target_collection.owner, "You do not own this collection");397398 target_collection.sponsor = T::AccountId::default();399 <Collection<T>>::insert(collection_id, target_collection);400401 Ok(())402 }403404 #[weight = 0]405 pub fn create_item(origin, collection_id: u64, properties: Vec<u8>, owner: T::AccountId) -> DispatchResult {406407 let sender = ensure_signed(origin)?;408 let target_collection = <Collection<T>>::get(collection_id);409 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;410411 match target_collection.mode412 {413 CollectionMode::NFT(_) => {414415 416 ensure!(target_collection.custom_data_size >= properties.len() as u32, "Size of item is too large");417418 419 let item = NftItemType {420 collection: collection_id,421 owner: owner,422 data: properties,423 };424425 Self::add_nft_item(item)?;426427 },428 CollectionMode::Fungible(_) => {429430 431 ensure!(properties.len() as u32 == 0, "Size of item must be 0 with fungible type");432433 let item = FungibleItemType {434 collection: collection_id,435 owner: owner,436 value: (10 as u128).pow(target_collection.decimal_points)437 };438439 Self::add_fungible_item(item)?;440 },441 CollectionMode::ReFungible(_, _) => {442443 444 ensure!(target_collection.custom_data_size >= properties.len() as u32, "Size of item is too large");445446 let mut owner_list = Vec::new();447 let value = (10 as u128).pow(target_collection.decimal_points);448 owner_list.push(Ownership {owner: owner, fraction: value});449450 let item = ReFungibleItemType {451 collection: collection_id,452 owner: owner_list,453 data: properties454 };455456 Self::add_refungible_item(item)?;457 },458 _ => ()459 };460461 462 Self::deposit_event(RawEvent::ItemCreated(collection_id, <ItemListIndex>::get(collection_id)));463464 Ok(())465 }466467 #[weight = 0]468 pub fn burn_item(origin, collection_id: u64, item_id: u64) -> DispatchResult {469470 let sender = ensure_signed(origin)?;471 let item_owner = Self::is_item_owner(sender.clone(), collection_id, item_id);472 if !item_owner473 {474 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;475 }476 let target_collection = <Collection<T>>::get(collection_id);477478 match target_collection.mode479 {480 CollectionMode::NFT(_) => Self::burn_nft_item(collection_id, item_id)?,481 CollectionMode::Fungible(_) => Self::burn_fungible_item(collection_id, item_id)?,482 CollectionMode::ReFungible(_, _) => Self::burn_refungible_item(collection_id, item_id, sender.clone())?,483 _ => ()484 };485486 487 Self::deposit_event(RawEvent::ItemDestroyed(collection_id, item_id));488489 Ok(())490 }491492 #[weight = 0]493 pub fn transfer(origin, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64) -> DispatchResult {494495 let sender = ensure_signed(origin)?;496 ensure!(Self::is_item_owner(sender.clone(), collection_id, item_id), "Only item owner can call transfer method");497498 let target_collection = <Collection<T>>::get(collection_id);499500 501 match target_collection.mode502 {503 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, sender.clone(), recipient)?,504 CollectionMode::Fungible(_) => Self::transfer_fungible(collection_id, item_id, value, sender.clone(), recipient)?,505 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, sender.clone(), recipient)?,506 _ => ()507 };508509 Ok(())510 }511512 #[weight = 0]513 pub fn approve(origin, approved: T::AccountId, collection_id: u64, item_id: u64) -> DispatchResult {514515 let sender = ensure_signed(origin)?;516517 518 let amount = 100000000;519520 ensure!(Self::is_item_owner(sender.clone(), collection_id, item_id), "Only item owner can call transfer method");521522 let list_exists = <ApprovedList<T>>::contains_key(collection_id, (item_id, sender.clone()));523 if list_exists {524525 let mut list = <ApprovedList<T>>::get(collection_id, (item_id, sender.clone()));526 let item_contains = list.iter().any(|i| i.approved == approved);527528 if !item_contains {529 list.push(ApprovePermissions { approved: approved.clone(), amount: amount });530 <ApprovedList<T>>::insert(collection_id, (item_id, sender.clone()), list);531 }532 } else {533534 let mut list = Vec::new();535 list.push(ApprovePermissions { approved: approved.clone(), amount: amount });536 <ApprovedList<T>>::insert(collection_id, (item_id, sender.clone()), list);537 }538539 Ok(())540 }541542 #[weight = 0]543 pub fn transfer_from(origin, from: T::AccountId, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64 ) -> DispatchResult {544545 let sender = ensure_signed(origin)?;546 let approved_list_exists = <ApprovedList<T>>::contains_key(collection_id, (item_id, from.clone()));547 if approved_list_exists548 {549 let list_itm = <ApprovedList<T>>::get(collection_id, (item_id, from.clone()));550 let opt_item = list_itm.iter().find(|i| i.approved == sender.clone());551 ensure!(opt_item.is_some(), "No approve found");552 ensure!(opt_item.unwrap().amount >= value, "Requested value more than approved");553554 555 let approve_list: Vec<ApprovePermissions<T::AccountId>> = <ApprovedList<T>>::get(collection_id, (item_id, from.clone()))556 .into_iter().filter(|i| i.approved != sender.clone()).collect();557 <ApprovedList<T>>::insert(collection_id, (item_id, from.clone()), approve_list);558 }559 else560 {561 Self::check_owner_or_admin_permissions(collection_id, sender)?;562 }563564 let target_collection = <Collection<T>>::get(collection_id);565566 match target_collection.mode567 {568 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, from, recipient)?,569 CollectionMode::Fungible(_) => Self::transfer_fungible(collection_id, item_id, value, from.clone(), recipient)?,570 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, from.clone(), recipient)?,571 _ => ()572 };573574 Ok(())575 }576577 #[weight = 0]578 pub fn safe_transfer_from(origin, collection_id: u64, item_id: u64, new_owner: T::AccountId) -> DispatchResult {579580 581 582 583 584585 586587 588589 Ok(())590 }591592 #[weight = 0]593 pub fn set_offchain_schema(594 origin,595 collection_id: u64,596 schema: Vec<u8>597 ) -> DispatchResult {598 let sender = ensure_signed(origin)?;599 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;600601 let mut target_collection = <Collection<T>>::get(collection_id);602 target_collection.offchain_schema = schema;603 <Collection<T>>::insert(collection_id, target_collection);604605 Ok(())606 }607 }608}609610impl<T: Trait> Module<T> {611 fn add_fungible_item(item: FungibleItemType<T::AccountId>) -> DispatchResult {612 let current_index = <ItemListIndex>::get(item.collection)613 .checked_add(1)614 .expect("Item list index id error");615 let itemcopy = item.clone();616 let owner = item.owner.clone();617 let value = item.value as u64;618619 Self::add_token_index(item.collection, current_index, owner.clone())?;620621 <ItemListIndex>::insert(item.collection, current_index);622 <FungibleItemList<T>>::insert(item.collection, current_index, itemcopy);623624 625 let new_balance = <Balance<T>>::get(item.collection, owner.clone())626 .checked_add(value)627 .unwrap();628 <Balance<T>>::insert(item.collection, owner.clone(), new_balance);629630 Ok(())631 }632633 fn add_refungible_item(item: ReFungibleItemType<T::AccountId>) -> DispatchResult {634 let current_index = <ItemListIndex>::get(item.collection)635 .checked_add(1)636 .expect("Item list index id error");637 let itemcopy = item.clone();638639 let value = item.owner.first().unwrap().fraction as u64;640 let owner = item.owner.first().unwrap().owner.clone();641642 Self::add_token_index(item.collection, current_index, owner.clone())?;643644 <ItemListIndex>::insert(item.collection, current_index);645 <ReFungibleItemList<T>>::insert(item.collection, current_index, itemcopy);646647 648 let new_balance = <Balance<T>>::get(item.collection, owner.clone())649 .checked_add(value)650 .unwrap();651 <Balance<T>>::insert(item.collection, owner.clone(), new_balance);652653 Ok(())654 }655656 fn add_nft_item(item: NftItemType<T::AccountId>) -> DispatchResult {657 let current_index = <ItemListIndex>::get(item.collection)658 .checked_add(1)659 .expect("Item list index id error");660661 let item_owner = item.owner.clone();662 let collection_id = item.collection.clone();663 Self::add_token_index(collection_id, current_index, item.owner.clone())?;664665 <ItemListIndex>::insert(collection_id, current_index);666 <NftItemList<T>>::insert(collection_id, current_index, item);667668 669 let new_balance = <Balance<T>>::get(collection_id, item_owner.clone())670 .checked_add(1)671 .unwrap();672 <Balance<T>>::insert(collection_id, item_owner.clone(), new_balance);673674 Ok(())675 }676677 fn burn_refungible_item(678 collection_id: u64,679 item_id: u64,680 owner: T::AccountId,681 ) -> DispatchResult {682 ensure!(683 <ReFungibleItemList<T>>::contains_key(collection_id, item_id),684 "Item does not exists"685 );686 let collection = <ReFungibleItemList<T>>::get(collection_id, item_id);687 let item = collection688 .owner689 .iter()690 .filter(|&i| i.owner == owner)691 .next()692 .unwrap();693 Self::remove_token_index(collection_id, item_id, owner.clone())?;694695 696 <ApprovedList<T>>::remove(collection_id, (item_id, owner.clone()));697698 699 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone())700 .checked_sub(item.fraction as u64)701 .unwrap();702 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);703704 <ReFungibleItemList<T>>::remove(collection_id, item_id);705706 Ok(())707 }708709 fn burn_nft_item(collection_id: u64, item_id: u64) -> DispatchResult {710 ensure!(711 <NftItemList<T>>::contains_key(collection_id, item_id),712 "Item does not exists"713 );714 let item = <NftItemList<T>>::get(collection_id, item_id);715 Self::remove_token_index(collection_id, item_id, item.owner.clone())?;716717 718 <ApprovedList<T>>::remove(collection_id, (item_id, item.owner.clone()));719720 721 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone())722 .checked_sub(1)723 .unwrap();724 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);725 <NftItemList<T>>::remove(collection_id, item_id);726727 Ok(())728 }729730 fn burn_fungible_item(collection_id: u64, item_id: u64) -> DispatchResult {731 ensure!(732 <FungibleItemList<T>>::contains_key(collection_id, item_id),733 "Item does not exists"734 );735 let item = <FungibleItemList<T>>::get(collection_id, item_id);736 Self::remove_token_index(collection_id, item_id, item.owner.clone())?;737738 739 <ApprovedList<T>>::remove(collection_id, (item_id, item.owner.clone()));740741 742 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone())743 .checked_sub(item.value as u64)744 .unwrap();745 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);746747 <FungibleItemList<T>>::remove(collection_id, item_id);748749 Ok(())750 }751752 fn collection_exists(collection_id: u64) -> DispatchResult {753 ensure!(754 <Collection<T>>::contains_key(collection_id),755 "This collection does not exist"756 );757 Ok(())758 }759760 fn check_owner_permissions(collection_id: u64, subject: T::AccountId) -> DispatchResult {761 Self::collection_exists(collection_id)?;762763 let target_collection = <Collection<T>>::get(collection_id);764 ensure!(765 subject == target_collection.owner,766 "You do not own this collection"767 );768769 Ok(())770 }771772 fn check_owner_or_admin_permissions(773 collection_id: u64,774 subject: T::AccountId,775 ) -> DispatchResult {776 Self::collection_exists(collection_id)?;777778 let target_collection = <Collection<T>>::get(collection_id);779 let is_owner = subject == target_collection.owner;780781 let no_perm_mes = "You do not have permissions to modify this collection";782 let exists = <AdminList<T>>::contains_key(collection_id);783784 if !is_owner {785 ensure!(exists, no_perm_mes);786 ensure!(787 <AdminList<T>>::get(collection_id).contains(&subject),788 no_perm_mes789 );790 }791 Ok(())792 }793794 fn is_item_owner(subject: T::AccountId, collection_id: u64, item_id: u64) -> bool {795 let target_collection = <Collection<T>>::get(collection_id);796797 match target_collection.mode {798 CollectionMode::NFT(_) => {799 <NftItemList<T>>::get(collection_id, item_id).owner == subject800 }801 CollectionMode::Fungible(_) => {802 <FungibleItemList<T>>::get(collection_id, item_id).owner == subject803 }804 CollectionMode::ReFungible(_, _) => {805 <ReFungibleItemList<T>>::get(collection_id, item_id)806 .owner807 .iter()808 .any(|i| i.owner == subject)809 }810 CollectionMode::Invalid => false,811 }812 }813814 fn transfer_fungible(815 collection_id: u64,816 item_id: u64,817 value: u64,818 owner: T::AccountId,819 new_owner: T::AccountId,820 ) -> DispatchResult {821 let full_item = <FungibleItemList<T>>::get(collection_id, item_id);822 let amount = full_item.value;823824 ensure!(amount >= value.into(), "Item balance not enouth");825826 827 let balance_old_owner = <Balance<T>>::get(collection_id, owner.clone())828 .checked_sub(value)829 .unwrap();830 <Balance<T>>::insert(collection_id, owner.clone(), balance_old_owner);831832 let mut new_owner_account_id = 0;833 let new_owner_items = <AddressTokens<T>>::get(collection_id, new_owner.clone());834 if new_owner_items.len() > 0 {835 new_owner_account_id = new_owner_items[0];836 }837838 let val64 = value.into();839840 841 if amount == val64 && new_owner_account_id == 0 {842 843 844 let mut new_full_item = full_item.clone();845 new_full_item.owner = new_owner.clone();846 <FungibleItemList<T>>::insert(collection_id, item_id, new_full_item);847848 849 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone())850 .checked_add(value)851 .unwrap();852 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);853854 855 Self::move_token_index(collection_id, item_id, owner.clone(), new_owner.clone())?;856 } else {857 let mut new_full_item = full_item.clone();858 new_full_item.value -= val64;859860 861 if new_owner_account_id > 0 {862 863 let mut item = <FungibleItemList<T>>::get(collection_id, new_owner_account_id);864 item.value += val64;865866 867 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone())868 .checked_add(value)869 .unwrap();870 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);871872 <FungibleItemList<T>>::insert(collection_id, new_owner_account_id, item);873 } else {874 875 let item = FungibleItemType {876 collection: collection_id,877 owner: new_owner.clone(),878 value: val64,879 };880881 Self::add_fungible_item(item)?;882 }883884 if amount == val64 {885 Self::remove_token_index(collection_id, item_id, full_item.owner.clone())?;886887 888 <ApprovedList<T>>::remove(collection_id, (item_id, full_item.owner.clone()));889 <FungibleItemList<T>>::remove(collection_id, item_id);890 }891892 <FungibleItemList<T>>::insert(collection_id, item_id, new_full_item);893 }894895 Ok(())896 }897898 fn transfer_refungible(899 collection_id: u64,900 item_id: u64,901 value: u64,902 owner: T::AccountId,903 new_owner: T::AccountId,904 ) -> DispatchResult {905 let full_item = <ReFungibleItemList<T>>::get(collection_id, item_id);906 let item = full_item907 .owner908 .iter()909 .filter(|i| i.owner == owner)910 .next()911 .unwrap();912 let amount = item.fraction;913914 ensure!(amount >= value.into(), "Item balance not enouth");915916 917 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone())918 .checked_sub(value)919 .unwrap();920 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);921922 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone())923 .checked_add(value)924 .unwrap();925 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);926927 let old_owner = item.owner.clone();928 let new_owner_has_account = full_item.owner.iter().any(|i| i.owner == new_owner);929 let val64 = value.into();930931 932 if amount == val64 && !new_owner_has_account {933 934 935 let mut new_full_item = full_item.clone();936 new_full_item937 .owner938 .iter_mut()939 .find(|i| i.owner == owner)940 .unwrap()941 .owner = new_owner.clone();942 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);943944 945 Self::move_token_index(collection_id, item_id, old_owner.clone(), new_owner.clone())?;946 } else {947 let mut new_full_item = full_item.clone();948 new_full_item949 .owner950 .iter_mut()951 .find(|i| i.owner == owner)952 .unwrap()953 .fraction -= val64;954955 956 if new_owner_has_account {957 958 new_full_item959 .owner960 .iter_mut()961 .find(|i| i.owner == new_owner)962 .unwrap()963 .fraction += val64;964 } else {965 966 new_full_item.owner.push(Ownership {967 owner: new_owner.clone(),968 fraction: val64,969 });970 Self::add_token_index(collection_id, item_id, new_owner.clone())?;971 }972973 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);974 }975976 Ok(())977 }978979 fn transfer_nft(980 collection_id: u64,981 item_id: u64,982 sender: T::AccountId,983 new_owner: T::AccountId,984 ) -> DispatchResult {985 let mut item = <NftItemList<T>>::get(collection_id, item_id);986987 ensure!(988 sender == item.owner,989 "sender parameter and item owner must be equal"990 );991992 993 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone())994 .checked_sub(1)995 .unwrap();996 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);997998 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone())999 .checked_add(1)1000 .unwrap();1001 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);10021003 1004 let old_owner = item.owner.clone();1005 item.owner = new_owner.clone();1006 <NftItemList<T>>::insert(collection_id, item_id, item);10071008 1009 Self::move_token_index(collection_id, item_id, old_owner.clone(), new_owner.clone())?;10101011 1012 <ApprovedList<T>>::remove(collection_id, (item_id, old_owner));1013 Ok(())1014 }10151016 fn add_token_index(collection_id: u64, item_index: u64, owner: T::AccountId) -> DispatchResult {1017 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());1018 if list_exists {1019 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());1020 let item_contains = list.contains(&item_index.clone());10211022 if !item_contains {1023 list.push(item_index.clone());1024 }10251026 <AddressTokens<T>>::insert(collection_id, owner.clone(), list);1027 } else {1028 let mut itm = Vec::new();1029 itm.push(item_index.clone());1030 <AddressTokens<T>>::insert(collection_id, owner, itm);1031 }10321033 Ok(())1034 }10351036 fn remove_token_index(1037 collection_id: u64,1038 item_index: u64,1039 owner: T::AccountId,1040 ) -> DispatchResult {1041 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());1042 if list_exists {1043 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());1044 let item_contains = list.contains(&item_index.clone());10451046 if item_contains {1047 list.retain(|&item| item != item_index);1048 <AddressTokens<T>>::insert(collection_id, owner, list);1049 }1050 }10511052 Ok(())1053 }10541055 fn move_token_index(1056 collection_id: u64,1057 item_index: u64,1058 old_owner: T::AccountId,1059 new_owner: T::AccountId,1060 ) -> DispatchResult {1061 Self::remove_token_index(collection_id, item_index, old_owner)?;1062 Self::add_token_index(collection_id, item_index, new_owner)?;10631064 Ok(())1065 }1066}106710681069107010711072pub type Multiplier = FixedU128;10731074type BalanceOf<T> = <<T as transaction_payment::Trait>::Currency as Currency<1075 <T as system::Trait>::AccountId,1076>>::Balance;1077type NegativeImbalanceOf<T> = <<T as transaction_payment::Trait>::Currency as Currency<1078 <T as system::Trait>::AccountId,1079>>::NegativeImbalance;1080108110821083#[derive(Encode, Decode, Clone, Eq, PartialEq)]1084pub struct ChargeTransactionPayment<T: transaction_payment::Trait + Send + Sync>(1085 #[codec(compact)] BalanceOf<T>,1086);10871088impl<T: Trait + transaction_payment::Trait + Send + Sync> sp_std::fmt::Debug1089 for ChargeTransactionPayment<T>1090{1091 #[cfg(feature = "std")]1092 fn fmt(&self, f: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {1093 write!(f, "ChargeTransactionPayment<{:?}>", self.0)1094 }1095 #[cfg(not(feature = "std"))]1096 fn fmt(&self, _: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {1097 Ok(())1098 }1099}11001101impl<T: Trait + transaction_payment::Trait + Send + Sync> ChargeTransactionPayment<T>1102where1103 T::Call:1104 Dispatchable<Info = DispatchInfo, PostInfo = PostDispatchInfo> + IsSubType<Module<T>, T>,1105 BalanceOf<T>: Send + Sync + FixedPointOperand,1106{1107 1108 pub fn from(fee: BalanceOf<T>) -> Self {1109 Self(fee)1110 }11111112 pub fn traditional_fee(1113 len: usize,1114 info: &DispatchInfoOf<T::Call>,1115 tip: BalanceOf<T>,1116 ) -> BalanceOf<T>1117 where1118 T::Call: Dispatchable<Info = DispatchInfo>,1119 {1120 <transaction_payment::Module<T>>::compute_fee(len as u32, info, tip)1121 }11221123 fn withdraw_fee(1124 &self,1125 who: &T::AccountId,1126 call: &T::Call,1127 info: &DispatchInfoOf<T::Call>,1128 len: usize,1129 ) -> Result<(BalanceOf<T>, Option<NegativeImbalanceOf<T>>), TransactionValidityError> {1130 let tip = self.0;11311132 1133 1134 let fee = match call.is_sub_type() {1135 Some(Call::create_collection(..)) => <BalanceOf<T>>::from(1_000_000_000),1136 _ => Self::traditional_fee(len, info, tip), 1137 1138 };11391140 1141 1142 let sponsor: T::AccountId = match call.is_sub_type() {1143 Some(Call::create_item(collection_id, _properties, _owner)) => {1144 <Collection<T>>::get(collection_id).sponsor1145 }1146 Some(Call::transfer(_new_owner, collection_id, _item_id, _value)) => {1147 <Collection<T>>::get(collection_id).sponsor1148 }11491150 _ => T::AccountId::default(),1151 };11521153 let mut who_pays_fee: T::AccountId = sponsor.clone();1154 if sponsor == T::AccountId::default() {1155 who_pays_fee = who.clone();1156 }11571158 1159 if fee.is_zero() {1160 return Ok((fee, None));1161 }11621163 match <T as transaction_payment::Trait>::Currency::withdraw(1164 &who_pays_fee,1165 fee,1166 if tip.is_zero() {1167 WithdrawReason::TransactionPayment.into()1168 } else {1169 WithdrawReason::TransactionPayment | WithdrawReason::Tip1170 },1171 ExistenceRequirement::KeepAlive,1172 ) {1173 Ok(imbalance) => Ok((fee, Some(imbalance))),1174 Err(_) => Err(InvalidTransaction::Payment.into()),1175 }1176 }1177}11781179impl<T: Trait + transaction_payment::Trait + Send + Sync> SignedExtension1180 for ChargeTransactionPayment<T>1181where1182 BalanceOf<T>: Send + Sync + From<u64> + FixedPointOperand,1183 T::Call:1184 Dispatchable<Info = DispatchInfo, PostInfo = PostDispatchInfo> + IsSubType<Module<T>, T>,1185{1186 const IDENTIFIER: &'static str = "ChargeTransactionPayment";1187 type AccountId = T::AccountId;1188 type Call = T::Call;1189 type AdditionalSigned = ();1190 type Pre = (1191 BalanceOf<T>,1192 Self::AccountId,1193 Option<NegativeImbalanceOf<T>>,1194 BalanceOf<T>,1195 );1196 fn additional_signed(&self) -> sp_std::result::Result<(), TransactionValidityError> {1197 Ok(())1198 }11991200 fn validate(1201 &self,1202 who: &Self::AccountId,1203 call: &Self::Call,1204 info: &DispatchInfoOf<Self::Call>,1205 len: usize,1206 ) -> TransactionValidity {1207 let (fee, _) = self.withdraw_fee(who, call, info, len)?;12081209 let mut r = ValidTransaction::default();1210 1211 1212 r.priority = fee.saturated_into::<TransactionPriority>();1213 Ok(r)1214 }12151216 fn pre_dispatch(1217 self,1218 who: &Self::AccountId,1219 call: &Self::Call,1220 info: &DispatchInfoOf<Self::Call>,1221 len: usize,1222 ) -> Result<Self::Pre, TransactionValidityError> {1223 let (fee, imbalance) = self.withdraw_fee(who, call, info, len)?;1224 Ok((self.0, who.clone(), imbalance, fee))1225 }12261227 fn post_dispatch(1228 pre: Self::Pre,1229 info: &DispatchInfoOf<Self::Call>,1230 post_info: &PostDispatchInfoOf<Self::Call>,1231 len: usize,1232 _result: &DispatchResult,1233 ) -> Result<(), TransactionValidityError> {1234 let (tip, who, imbalance, fee) = pre;1235 if let Some(payed) = imbalance {1236 let actual_fee = <transaction_payment::Module<T>>::compute_actual_fee(1237 len as u32, info, post_info, tip,1238 );1239 let refund = fee.saturating_sub(actual_fee);1240 let actual_payment =1241 match <T as transaction_payment::Trait>::Currency::deposit_into_existing(1242 &who, refund,1243 ) {1244 Ok(refund_imbalance) => {1245 1246 1247 match payed.offset(refund_imbalance) {1248 Ok(actual_payment) => actual_payment,1249 Err(_) => return Err(InvalidTransaction::Payment.into()),1250 }1251 }1252 1253 1254 Err(_) => payed,1255 };1256 let imbalances = actual_payment.split(tip);1257 <T as transaction_payment::Trait>::OnTransactionPayment::on_unbalanceds(1258 Some(imbalances.0).into_iter().chain(Some(imbalances.1)),1259 );1260 }1261 Ok(())1262 }1263}