difftreelog
Remove duplicate methods
in: master
1 file changed
pallets/nft/src/lib.rsdiffbeforeafterboth1#![cfg_attr(not(feature = "std"), no_std)]23/// For more guidance on Substrate FRAME, see the example pallet4/// https://github.com/paritytech/substrate/blob/master/frame/example/src/lib.rs56use codec::{Decode, Encode};7pub use frame_support::{8 decl_event, decl_module, decl_storage,9 construct_runtime, parameter_types,10 traits::{Currency, Get, ExistenceRequirement, KeyOwnerProofSystem, OnUnbalanced, Randomness, WithdrawReason, Imbalance},11 weights::{12 DispatchInfo, PostDispatchInfo, constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},13 IdentityFee, Weight, WeightToFeePolynomial, GetDispatchInfo, Pays,14 },15 StorageValue,16 dispatch::DispatchResult, 17 IsSubType,18 ensure19};2021use frame_system::{self as system, ensure_signed};22use sp_runtime::sp_std::prelude::Vec;23use sp_std::prelude::*;24use sp_runtime::{25 FixedU128, FixedPointOperand, 26 transaction_validity::{27 TransactionPriority, ValidTransaction, InvalidTransaction, TransactionValidityError, TransactionValidity28 },29 traits::{30 Saturating, Dispatchable, DispatchInfoOf, PostDispatchInfoOf, SignedExtension, Zero, SaturatedConversion,31 },32};3334#[cfg(test)]35mod mock;3637#[cfg(test)]38mod tests;3940#[derive(Encode, Decode, Debug, Eq, Clone, PartialEq)]41pub enum CollectionMode {42 Invalid,43 // custom data size44 NFT(u32),45 // decimal points46 Fungible(u32),47 // custom data size and decimal points48 ReFungible(u32, u32),49}5051impl Into<u8> for CollectionMode {52 fn into(self) -> u8{53 match self {54 CollectionMode::Invalid => 0,55 CollectionMode::NFT(_) => 1,56 CollectionMode::Fungible(_) => 2,57 CollectionMode::ReFungible(_, _) => 3,58 }59 }60}6162#[derive(Encode, Decode, Debug, Clone, PartialEq)]63pub enum AccessMode {64 Normal,65 WhiteList,66}67impl Default for AccessMode { fn default() -> Self { Self::Normal } }6869impl Default for CollectionMode { fn default() -> Self { Self::Invalid } }7071#[derive(Encode, Decode, Default, Clone, PartialEq)]72#[cfg_attr(feature = "std", derive(Debug))]73pub struct Ownership<AccountId> {74 pub owner: AccountId,75 pub fraction: u12876}7778#[derive(Encode, Decode, Default, Clone, PartialEq)]79#[cfg_attr(feature = "std", derive(Debug))]80pub struct CollectionType<AccountId> {81 pub owner: AccountId,82 pub mode: CollectionMode,83 pub access: AccessMode,84 pub next_item_id: u64,85 pub decimal_points: u32,86 pub name: Vec<u16>, // 64 include null escape char87 pub description: Vec<u16>, // 256 include null escape char88 pub token_prefix: Vec<u8>, // 16 include null escape char89 pub custom_data_size: u32,90 pub offchain_schema: Vec<u8>,91 pub sponsor: AccountId, // Who pays fees. If set to default address, the fees are applied to the transaction sender92 pub unconfirmed_sponsor: AccountId, // Sponsor address that has not yet confirmed sponsorship93}9495#[derive(Encode, Decode, Default, Clone, PartialEq)]96#[cfg_attr(feature = "std", derive(Debug))]97pub struct CollectionAdminsType<AccountId> {98 pub admin: AccountId,99 pub collection_id: u64,100}101102#[derive(Encode, Decode, Default, Clone, PartialEq)]103#[cfg_attr(feature = "std", derive(Debug))]104pub struct NftItemType<AccountId> {105 pub collection: u64,106 pub owner: AccountId,107 pub data: Vec<u8>,108}109110#[derive(Encode, Decode, Default, Clone, PartialEq)]111#[cfg_attr(feature = "std", derive(Debug))]112pub struct FungibleItemType<AccountId> {113 pub collection: u64,114 pub owner: AccountId,115 pub value: u128,116}117118#[derive(Encode, Decode, Default, Clone, PartialEq)]119#[cfg_attr(feature = "std", derive(Debug))]120pub struct ReFungibleItemType<AccountId> {121 pub collection: u64,122 pub owner: Vec<Ownership<AccountId>>,123 pub data: Vec<u8>,124}125126pub trait Trait: system::Trait {127 type Event: From<Event<Self>> + Into<<Self as system::Trait>::Event>;128129}130131decl_storage! {132 trait Store for Module<T: Trait> as Nft {133134 // Private members135 NextCollectionID: u64;136 ItemListIndex: map hasher(blake2_128_concat) u64 => u64;137138 pub Collection get(fn collection): map hasher(identity) u64 => CollectionType<T::AccountId>;139 pub AdminList get(fn admin_list_collection): map hasher(identity) u64 => Vec<T::AccountId>;140 pub WhiteList get(fn white_list): map hasher(identity) u64 => Vec<T::AccountId>;141142 // Balance owner per collection map143 pub Balance get(fn balance_count): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => u64;144 pub ApprovedList get(fn approved): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => Vec<T::AccountId>;145146 // Item collections147 pub NftItemList get(fn nft_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => NftItemType<T::AccountId>;148 pub FungibleItemList get(fn fungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => FungibleItemType<T::AccountId>;149 pub ReFungibleItemList get(fn refungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => ReFungibleItemType<T::AccountId>;150151 pub AddressTokens get(fn address_tokens): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => Vec<u64>;152153 // Sponsorship154 pub ContractSponsor get(fn contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;155 pub UnconfirmedContractSponsor get(fn unconfirmed_contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;156 }157}158159decl_event!(160 pub enum Event<T>161 where162 AccountId = <T as system::Trait>::AccountId,163 {164 Created(u64, u8, AccountId),165 ItemCreated(u64, u64),166 ItemDestroyed(u64, u64),167 }168);169170decl_module! {171 pub struct Module<T: Trait> for enum Call where origin: T::Origin {172173 fn deposit_event() = default;174175 // Create collection of NFT with given parameters176 //177 // @param customDataSz size of custom data in each collection item178 // returns collection ID179 #[weight = 0]180 pub fn create_collection( origin,181 collection_name: Vec<u16>,182 collection_description: Vec<u16>,183 token_prefix: Vec<u8>,184 mode: CollectionMode) -> DispatchResult {185186 // Anyone can create a collection187 let who = ensure_signed(origin)?;188 let custom_data_size = match mode {189 CollectionMode::NFT(size) => size,190 CollectionMode::ReFungible(size, _) => size,191 _ => 0192 };193194 let decimal_points = match mode {195 CollectionMode::Fungible(points) => points,196 CollectionMode::ReFungible(_, points) => points,197 _ => 0198 };199200 // check params201 ensure!(decimal_points <= 4, "decimal_points parameter must be lower than 4"); 202203 let mut name = collection_name.to_vec();204 name.push(0);205 ensure!(name.len() <= 64, "Collection name can not be longer than 63 char");206207 let mut description = collection_description.to_vec();208 description.push(0);209 ensure!(name.len() <= 256, "Collection description can not be longer than 255 char");210211 let mut prefix = token_prefix.to_vec();212 prefix.push(0);213 ensure!(prefix.len() <= 16, "Token prefix can not be longer than 15 char");214215 // Generate next collection ID216 let next_id = NextCollectionID::get()217 .checked_add(1)218 .expect("collection id error");219220 NextCollectionID::put(next_id);221222 // Create new collection223 let new_collection = CollectionType {224 owner: who.clone(),225 name: name,226 mode: mode.clone(),227 access: AccessMode::Normal,228 description: description,229 decimal_points: decimal_points,230 token_prefix: prefix,231 next_item_id: next_id,232 offchain_schema: Vec::new(),233 custom_data_size: custom_data_size,234 sponsor: T::AccountId::default(),235 unconfirmed_sponsor: T::AccountId::default(),236 };237238 // Add new collection to map239 <Collection<T>>::insert(next_id, new_collection);240241 // call event242 Self::deposit_event(RawEvent::Created(next_id, mode.into(), who.clone()));243244 Ok(())245 }246247 #[weight = 0]248 pub fn destroy_collection(origin, collection_id: u64) -> DispatchResult {249250 let sender = ensure_signed(origin)?;251 Self::check_owner_permissions(collection_id, sender)?;252253 <AddressTokens<T>>::remove_prefix(collection_id);254 <ApprovedList<T>>::remove_prefix(collection_id);255 <Balance<T>>::remove_prefix(collection_id);256 <ItemListIndex>::remove(collection_id);257 <AdminList<T>>::remove(collection_id);258 <Collection<T>>::remove(collection_id);259 <WhiteList<T>>::remove(collection_id);260261 Ok(())262 }263264 #[weight = 0]265 pub fn change_collection_owner(origin, collection_id: u64, new_owner: T::AccountId) -> DispatchResult {266267 let sender = ensure_signed(origin)?;268 Self::check_owner_permissions(collection_id, sender)?;269 let mut target_collection = <Collection<T>>::get(collection_id);270 target_collection.owner = new_owner;271 <Collection<T>>::insert(collection_id, target_collection);272273 Ok(())274 }275276 #[weight = 0]277 pub fn add_collection_admin(origin, collection_id: u64, new_admin_id: T::AccountId) -> DispatchResult {278279 let sender = ensure_signed(origin)?;280 Self::check_owner_or_admin_permissions(collection_id, sender)?;281 let mut admin_arr: Vec<T::AccountId> = Vec::new();282283 if <AdminList<T>>::contains_key(collection_id)284 {285 admin_arr = <AdminList<T>>::get(collection_id);286 ensure!(!admin_arr.contains(&new_admin_id), "Account already has admin role");287 }288289 admin_arr.push(new_admin_id);290 <AdminList<T>>::insert(collection_id, admin_arr);291292 Ok(())293 }294295 #[weight = 0]296 pub fn remove_collection_admin(origin, collection_id: u64, account_id: T::AccountId) -> DispatchResult {297298 let sender = ensure_signed(origin)?;299 Self::check_owner_or_admin_permissions(collection_id, sender)?;300301 if <AdminList<T>>::contains_key(collection_id)302 {303 let mut admin_arr = <AdminList<T>>::get(collection_id);304 admin_arr.retain(|i| *i != account_id);305 <AdminList<T>>::insert(collection_id, admin_arr);306 }307308 Ok(())309 }310311 #[weight = 0]312 pub fn set_collection_sponsor(origin, collection_id: u64, new_sponsor: T::AccountId) -> DispatchResult {313314 let sender = ensure_signed(origin)?;315 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");316317 let mut target_collection = <Collection<T>>::get(collection_id);318 ensure!(sender == target_collection.owner, "You do not own this collection");319320 target_collection.unconfirmed_sponsor = new_sponsor;321 <Collection<T>>::insert(collection_id, target_collection);322323 Ok(())324 }325326 #[weight = 0]327 pub fn confirm_sponsorship(origin, collection_id: u64) -> DispatchResult {328329 let sender = ensure_signed(origin)?;330 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");331332 let mut target_collection = <Collection<T>>::get(collection_id);333 ensure!(sender == target_collection.unconfirmed_sponsor, "This address is not set as sponsor, use setCollectionSponsor first");334335 target_collection.sponsor = target_collection.unconfirmed_sponsor;336 target_collection.unconfirmed_sponsor = T::AccountId::default();337 <Collection<T>>::insert(collection_id, target_collection);338339 Ok(())340 }341342 #[weight = 0]343 pub fn remove_collection_sponsor(origin, collection_id: u64) -> DispatchResult {344345 let sender = ensure_signed(origin)?;346 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");347348 let mut target_collection = <Collection<T>>::get(collection_id);349 ensure!(sender == target_collection.owner, "You do not own this collection");350351 target_collection.sponsor = T::AccountId::default();352 <Collection<T>>::insert(collection_id, target_collection);353354 Ok(())355 }356 357 #[weight = 0]358 pub fn create_item(origin, collection_id: u64, properties: Vec<u8>, owner: T::AccountId) -> DispatchResult {359360 let sender = ensure_signed(origin)?;361362 // check size363 let target_collection = <Collection<T>>::get(collection_id);364 ensure!(target_collection.custom_data_size >= properties.len() as u32, "Size of item is too large");365366 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;367368 let new_balance = <Balance<T>>::get(collection_id, owner.clone()).checked_add(1).unwrap();369 <Balance<T>>::insert(collection_id, owner.clone(), new_balance);370371 // TODO: implement other modes372 match target_collection.mode 373 {374 CollectionMode::NFT(_) => {375 // Create nft item376 let item = NftItemType {377 collection: collection_id,378 owner: owner,379 data: properties,380 };381 382 Self::add_nft_item(item)?;383 384 },385 CollectionMode::ReFungible(_, _) => {386 let mut owner_list = Vec::new();387 let value = (10 as u128).pow(target_collection.decimal_points);388 owner_list.push(Ownership {owner: owner, fraction: value});389390 let item = ReFungibleItemType {391 collection: collection_id,392 owner: owner_list,393 data: properties394 };395 396 Self::add_refungible_item(item)?;397 },398 _ => ()399 };400401 // call event402 Self::deposit_event(RawEvent::ItemCreated(collection_id, <ItemListIndex>::get(collection_id)));403404 Ok(())405 }406407 #[weight = 0]408 pub fn burn_item(origin, collection_id: u64, item_id: u64) -> DispatchResult {409410 let sender = ensure_signed(origin)?;411 let item_owner = Self::is_item_owner(sender.clone(), collection_id, item_id);412 if !item_owner413 {414 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;415 }416 let target_collection = <Collection<T>>::get(collection_id);417418 match target_collection.mode 419 {420 CollectionMode::NFT(_) => Self::burn_nft_item(collection_id, item_id)?,421 CollectionMode::ReFungible(_, _) => Self::burn_refungible_item(collection_id, item_id, sender.clone())?,422 _ => ()423 };424425 // call event426 Self::deposit_event(RawEvent::ItemDestroyed(collection_id, item_id));427428 Ok(())429 }430431 #[weight = 0]432 pub fn transfer(origin, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64) -> DispatchResult {433434 let sender = ensure_signed(origin)?;435 ensure!(Self::is_item_owner(sender.clone(), collection_id, item_id), "Only item owner can call transfer method");436437 let target_collection = <Collection<T>>::get(collection_id);438439 // TODO: implement other modes440 match target_collection.mode 441 {442 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, sender.clone(), recipient)?,443 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, sender.clone(), recipient)?,444 _ => ()445 };446447 Ok(())448 }449450 #[weight = 0]451 pub fn approve(origin, approved: T::AccountId, collection_id: u64, item_id: u64) -> DispatchResult {452453 let sender = ensure_signed(origin)?;454455 let item_owner = Self::is_item_owner(sender.clone(), collection_id, item_id);456 if !item_owner457 {458 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;459 }460461 let list_exists = <ApprovedList<T>>::contains_key(collection_id, item_id);462 if list_exists {463464 let mut list = <ApprovedList<T>>::get(collection_id, item_id);465 let item_contains = list.contains(&approved.clone());466467 if !item_contains {468 list.push(approved.clone());469 }470 } else {471472 let mut itm = Vec::new();473 itm.push(approved.clone());474 <ApprovedList<T>>::insert(collection_id, item_id, itm);475 }476477 Ok(())478 }479480 #[weight = 0]481 pub fn transfer_from(origin, from: T::AccountId, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64 ) -> DispatchResult {482483 let mut approved: bool = false; 484 let sender = ensure_signed(origin)?;485 let approved_list_exists = <ApprovedList<T>>::contains_key(collection_id, item_id);486 if approved_list_exists487 {488 let list_itm = <ApprovedList<T>>::get(collection_id, item_id);489 approved = list_itm.contains(&recipient.clone());490 }491492 if !approved493 {494 Self::check_owner_or_admin_permissions(collection_id, sender)?;495 }496 497 let target_collection = <Collection<T>>::get(collection_id);498499 match target_collection.mode500 {501 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, from, recipient)?,502 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, from, recipient)?,503 // TODO: implement other modes504 _ => ()505 };506507 Ok(())508 }509510 #[weight = 0]511 pub fn safe_transfer_from(origin, collection_id: u64, item_id: u64, new_owner: T::AccountId) -> DispatchResult {512513 // let no_perm_mes = "You do not have permissions to modify this collection";514 // ensure!(<ApprovedList<T>>::contains_key((collection_id, item_id)), no_perm_mes);515 // let list_itm = <ApprovedList<T>>::get((collection_id, item_id));516 // ensure!(list_itm.contains(&new_owner.clone()), no_perm_mes);517518 // // on_nft_received call519520 // Self::transfer(origin, collection_id, item_id, new_owner)?;521522 Ok(())523 }524525 #[weight = 0]526 pub fn set_offchain_schema(527 origin,528 collection_id: u64,529 schema: Vec<u8>530 ) -> DispatchResult {531 let sender = ensure_signed(origin)?;532 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;533 534 let mut target_collection = <Collection<T>>::get(collection_id);535 target_collection.offchain_schema = schema;536 <Collection<T>>::insert(collection_id, target_collection);537538 Ok(()) 539 }540541 // Shonsorship methods542 #[weight = 0]543 pub fn set_collection_sponsor(544 origin,545 collection_id: u64,546 address: T::AccountId547 ) -> DispatchResult {548 let sender = ensure_signed(origin)?;549 Self::check_owner_permissions(collection_id, sender)?;550 let mut collection = <Collection<T>>::get(collection_id);551 collection.unconfirmed_sponsor = address;552 <Collection<T>>::insert(collection_id, collection);553554 Ok(()) 555 }556557 #[weight = 0]558 pub fn confirm_sponsorship(559 origin,560 collection_id: u64,561 address: T::AccountId562 ) -> DispatchResult {563 let sender = ensure_signed(origin)?;564 let mut collection = <Collection<T>>::get(collection_id);565566 ensure!(collection.unconfirmed_sponsor == sender, "Only sponsor can confirm sponsorship");567568 collection.sponsor = collection.unconfirmed_sponsor;569 collection.unconfirmed_sponsor = T::AccountId::default();570 <Collection<T>>::insert(collection_id, collection);571572 Ok(()) 573 }574575 #[weight = 0]576 pub fn remove_collection_sponsor(577 origin,578 collection_id: u64579 ) -> DispatchResult {580 let sender = ensure_signed(origin)?;581 Self::check_owner_permissions(collection_id, sender)?;582 let mut collection = <Collection<T>>::get(collection_id);583 collection.unconfirmed_sponsor = T::AccountId::default();584 collection.sponsor = T::AccountId::default();585 <Collection<T>>::insert(collection_id, collection);586587 Ok(()) 588 }589590 }591}592593impl<T: Trait> Module<T> {594595 fn collection_exists(collection_id: u64) -> DispatchResult{596 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");597 Ok(())598 }599600 fn check_owner_permissions(collection_id: u64, subject: T::AccountId) -> DispatchResult {601602 Self::collection_exists(collection_id)?;603604 let target_collection = <Collection<T>>::get(collection_id);605 ensure!(subject == target_collection.owner, "You do not own this collection");606607 Ok(())608 }609610 fn check_owner_or_admin_permissions(collection_id: u64, subject: T::AccountId) -> DispatchResult {611612 Self::collection_exists(collection_id)?;613614 let target_collection = <Collection<T>>::get(collection_id);615 let is_owner = subject == target_collection.owner;616617 let no_perm_mes = "You do not have permissions to modify this collection";618 let exists = <AdminList<T>>::contains_key(collection_id);619620 if !is_owner621 {622 ensure!(exists, no_perm_mes);623 ensure!(<AdminList<T>>::get(collection_id).contains(&subject), no_perm_mes);624 }625 Ok(())626 }627628 fn is_item_owner(subject: T::AccountId, collection_id: u64, item_id: u64) -> bool{629630 let target_collection = <Collection<T>>::get(collection_id);631632 match target_collection.mode {633 CollectionMode::NFT(_) => <NftItemList<T>>::get(collection_id, item_id).owner == subject,634 CollectionMode::Fungible(_) => <FungibleItemList<T>>::get(collection_id, item_id).owner == subject,635 CollectionMode::ReFungible(_, _) => <ReFungibleItemList<T>>::get(collection_id, item_id).owner.iter().any(|i| i.owner == subject),636 CollectionMode::Invalid => false637 }638 }639640 fn add_refungible_item(item: ReFungibleItemType<T::AccountId>) -> DispatchResult {641642 let current_index = <ItemListIndex>::get(item.collection)643 .checked_add(1)644 .expect("Item list index id error");645646 Self::add_token_index(item.collection, current_index, item.owner.first().unwrap().owner.clone())?;647648 <ItemListIndex>::insert(item.collection, current_index);649 <ReFungibleItemList<T>>::insert(item.collection, current_index, item); 650651 Ok(())652 }653654 fn burn_refungible_item(collection_id: u64, item_id: u64, owner: T::AccountId) -> DispatchResult {655 656 let collection = <ReFungibleItemList<T>>::get(collection_id, item_id);657 let item = collection.owner.iter().filter(|&i| i.owner == owner).next().unwrap();658 Self::remove_token_index(collection_id, item_id, owner)?;659660 // update balance661 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(item.fraction as u64).unwrap();662 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);663664 // TODO665 <ReFungibleItemList<T>>::remove(collection_id, item_id);666667 Ok(())668 }669670 fn transfer_refungible(collection_id: u64, item_id: u64, value: u64, owner: T::AccountId, new_owner: T::AccountId) -> DispatchResult {671672 let full_item = <ReFungibleItemList<T>>::get(collection_id, item_id);673 let item = full_item.owner.iter().filter(|i| i.owner == owner).next().unwrap();674 let amount = item.fraction;675676 ensure!(amount < value.into(),"Item balance not enouth");677678 // update balance679 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(value).unwrap();680 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);681682 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone()).checked_add(value).unwrap();683 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);684685 let old_owner = item.owner.clone();686 let new_owner_has_account = full_item.owner.iter().any(|i| i.owner == new_owner);687688 // transfer689 if amount == value.into() && !new_owner_has_account690 {691 // change owner692 // new owner do not have account693 let mut new_full_item = full_item.clone();694 new_full_item.owner.iter_mut().find(|i| i.owner == owner).unwrap().owner = new_owner.clone();695 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);696697 // update index collection698 Self::move_token_index(collection_id, item_id, old_owner.clone(), new_owner.clone())?;699 }700 else701 {702 let mut new_full_item = full_item.clone();703 new_full_item.owner.iter_mut().find(|i| i.owner == owner).unwrap().fraction -= amount;704705 // separate amount706 if new_owner_has_account {707 // new owner has account708 new_full_item.owner.iter_mut().find(|i| i.owner == new_owner).unwrap().fraction += amount;709 }710 else711 {712 // new owner do not have account713 new_full_item.owner.push(Ownership { owner: new_owner.clone(), fraction: amount});714 Self::add_token_index(collection_id, item_id, new_owner.clone())?;715 }716717 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);718 }719720 Ok(())721 }722 723 fn add_nft_item(item: NftItemType<T::AccountId>) -> DispatchResult {724725 let current_index = <ItemListIndex>::get(item.collection)726 .checked_add(1)727 .expect("Item list index id error");728729 Self::add_token_index(item.collection, current_index, item.owner.clone())?;730731 <ItemListIndex>::insert(item.collection, current_index);732 <NftItemList<T>>::insert(item.collection, current_index, item);733734 Ok(())735 }736737 fn burn_nft_item(collection_id: u64, item_id: u64) -> DispatchResult {738 739 let item = <NftItemList<T>>::get(collection_id, item_id);740 Self::remove_token_index(collection_id, item_id, item.owner.clone())?;741742 // update balance743 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(1).unwrap();744 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);745 <NftItemList<T>>::remove(collection_id, item_id);746747 Ok(())748 }749750 fn transfer_nft(collection_id: u64, item_id: u64, sender: T::AccountId, new_owner: T::AccountId) -> DispatchResult {751752 let mut item = <NftItemList<T>>::get(collection_id, item_id);753754 ensure!(sender == item.owner,"sender parameter and item owner must be equal");755756 // update balance757 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(1).unwrap();758 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);759760 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone()).checked_add(1).unwrap();761 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);762763 // change owner764 let old_owner = item.owner.clone();765 item.owner = new_owner.clone();766 <NftItemList<T>>::insert(collection_id, item_id, item);767768 // update index collection769 Self::move_token_index(collection_id, item_id, old_owner, new_owner.clone())?;770771 // reset approved list772 let itm: Vec<T::AccountId> = Vec::new();773 <ApprovedList<T>>::insert(collection_id, item_id, itm);774775 Ok(())776 }777778 fn add_token_index(collection_id: u64, item_index: u64, owner: T::AccountId) -> DispatchResult {779 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());780 if list_exists {781 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());782 let item_contains = list.contains(&item_index.clone());783784 if !item_contains {785 list.push(item_index.clone());786 }787788 <AddressTokens<T>>::insert(collection_id, owner.clone(), list);789 } else {790 let mut itm = Vec::new();791 itm.push(item_index.clone());792 <AddressTokens<T>>::insert(collection_id, owner, itm);793 }794795 Ok(())796 }797798 fn remove_token_index(799 collection_id: u64,800 item_index: u64,801 owner: T::AccountId,802 ) -> DispatchResult {803 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());804 if list_exists {805 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());806 let item_contains = list.contains(&item_index.clone());807808 if item_contains {809 list.retain(|&item| item != item_index);810 <AddressTokens<T>>::insert(collection_id, owner, list);811 }812 }813814 Ok(())815 }816817 fn move_token_index(818 collection_id: u64,819 item_index: u64,820 old_owner: T::AccountId,821 new_owner: T::AccountId,822 ) -> DispatchResult {823 Self::remove_token_index(collection_id, item_index, old_owner)?;824 Self::add_token_index(collection_id, item_index, new_owner)?;825826 Ok(())827 }828}829830831////////////////////////////////////////////////////////////////////////////////////////////////////832// Economic models833834/// Fee multiplier.835pub type Multiplier = FixedU128;836837type BalanceOf<T> =838 <<T as transaction_payment::Trait>::Currency as Currency<<T as system::Trait>::AccountId>>::Balance;839type NegativeImbalanceOf<T> = <<T as transaction_payment::Trait>::Currency as Currency<840 <T as system::Trait>::AccountId,>>::NegativeImbalance;841842843844/// Require the transactor pay for themselves and maybe include a tip to gain additional priority845/// in the queue.846#[derive(Encode, Decode, Clone, Eq, PartialEq)]847pub struct ChargeTransactionPayment<T: transaction_payment::Trait + Send + Sync>(#[codec(compact)] BalanceOf<T>);848849impl<T:Trait + transaction_payment::Trait + Send + Sync> sp_std::fmt::Debug for ChargeTransactionPayment<T> {850 #[cfg(feature = "std")]851 fn fmt(&self, f: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {852 write!(f, "ChargeTransactionPayment<{:?}>", self.0)853 }854 #[cfg(not(feature = "std"))]855 fn fmt(&self, _: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {856 Ok(())857 }858}859860impl<T:Trait + transaction_payment::Trait + Send + Sync> ChargeTransactionPayment<T> where861 T::Call: Dispatchable<Info=DispatchInfo, PostInfo=PostDispatchInfo> + IsSubType<Module<T>, T>,862 BalanceOf<T>: Send + Sync + FixedPointOperand,863{864 /// utility constructor. Used only in client/factory code.865 pub fn from(fee: BalanceOf<T>) -> Self {866 Self(fee)867 }868869 pub fn traditional_fee(870 len: usize,871 info: &DispatchInfoOf<T::Call>,872 tip: BalanceOf<T>,873 ) -> BalanceOf<T> where874 T::Call: Dispatchable<Info=DispatchInfo>,875 {876 <transaction_payment::Module<T>>::compute_fee(len as u32, info, tip)877 }878879 fn withdraw_fee(880 &self,881 who: &T::AccountId,882 call: &T::Call,883 info: &DispatchInfoOf<T::Call>,884 len: usize,885 ) -> Result<(BalanceOf<T>, Option<NegativeImbalanceOf<T>>), TransactionValidityError> {886 let tip = self.0;887888 // Set fee based on call type. Creating collection costs 1 Unique.889 // All other transactions have traditional fees so far890 let fee = match call.is_sub_type() {891 Some(Call::create_collection(..)) => <BalanceOf<T>>::from(1_000_000_000),892 _ => Self::traditional_fee(len, info, tip)893894 // Flat fee model, use only for testing purposes895 // _ => <BalanceOf<T>>::from(100)896 };897898 // Determine who is paying transaction fee based on ecnomic model899 // Parse call to extract collection ID and access collection sponsor900 let sponsor: T::AccountId = match call.is_sub_type() {901 Some(Call::create_item(collection_id, _properties, _owner)) => {902 <Collection<T>>::get(collection_id).sponsor903 },904 Some(Call::transfer(_new_owner, collection_id, _item_id, _value)) => {905 <Collection<T>>::get(collection_id).sponsor906 },907908 _ => T::AccountId::default()909 };910911 let mut who_pays_fee: T::AccountId = sponsor.clone();912 if sponsor == T::AccountId::default() {913 who_pays_fee = who.clone();914 }915916 // Only mess with balances if fee is not zero.917 if fee.is_zero() {918 return Ok((fee, None));919 }920921 match <T as transaction_payment::Trait>::Currency::withdraw(922 &who_pays_fee,923 fee,924 if tip.is_zero() {925 WithdrawReason::TransactionPayment.into()926 } else {927 WithdrawReason::TransactionPayment | WithdrawReason::Tip928 },929 ExistenceRequirement::KeepAlive,930 ) {931 Ok(imbalance) => Ok((fee, Some(imbalance))),932 Err(_) => Err(InvalidTransaction::Payment.into()),933 }934 }935}936937impl<T:Trait + transaction_payment::Trait + Send + Sync> SignedExtension for ChargeTransactionPayment<T> where938 BalanceOf<T>: Send + Sync + From<u64> + FixedPointOperand,939 T::Call: Dispatchable<Info=DispatchInfo, PostInfo=PostDispatchInfo> + IsSubType<Module<T>, T>,940{941 const IDENTIFIER: &'static str = "ChargeTransactionPayment";942 type AccountId = T::AccountId;943 type Call = T::Call;944 type AdditionalSigned = ();945 type Pre = (BalanceOf<T>, Self::AccountId, Option<NegativeImbalanceOf<T>>, BalanceOf<T>);946 fn additional_signed(&self) -> sp_std::result::Result<(), TransactionValidityError> { Ok(()) }947948 fn validate(949 &self,950 who: &Self::AccountId,951 call: &Self::Call,952 info: &DispatchInfoOf<Self::Call>,953 len: usize,954 ) -> TransactionValidity {955 let (fee, _) = self.withdraw_fee(who, call, info, len)?;956957 let mut r = ValidTransaction::default();958 // NOTE: we probably want to maximize the _fee (of any type) per weight unit_ here, which959 // will be a bit more than setting the priority to tip. For now, this is enough.960 r.priority = fee.saturated_into::<TransactionPriority>();961 Ok(r)962 }963964 fn pre_dispatch(965 self,966 who: &Self::AccountId,967 call: &Self::Call,968 info: &DispatchInfoOf<Self::Call>,969 len: usize970 ) -> Result<Self::Pre, TransactionValidityError> {971 let (fee, imbalance) = self.withdraw_fee(who, call, info, len)?;972 Ok((self.0, who.clone(), imbalance, fee))973 }974975 fn post_dispatch(976 pre: Self::Pre,977 info: &DispatchInfoOf<Self::Call>,978 post_info: &PostDispatchInfoOf<Self::Call>,979 len: usize,980 _result: &DispatchResult,981 ) -> Result<(), TransactionValidityError> {982 let (tip, who, imbalance, fee) = pre;983 if let Some(payed) = imbalance {984 let actual_fee = <transaction_payment::Module<T>>::compute_actual_fee(985 len as u32,986 info,987 post_info,988 tip,989 );990 let refund = fee.saturating_sub(actual_fee);991 let actual_payment = match <T as transaction_payment::Trait>::Currency::deposit_into_existing(&who, refund) {992 Ok(refund_imbalance) => {993 // The refund cannot be larger than the up front payed max weight.994 // `PostDispatchInfo::calc_unspent` guards against such a case.995 match payed.offset(refund_imbalance) {996 Ok(actual_payment) => actual_payment,997 Err(_) => return Err(InvalidTransaction::Payment.into()),998 }999 }1000 // We do not recreate the account using the refund. The up front payment1001 // is gone in that case.1002 Err(_) => payed,1003 };1004 let imbalances = actual_payment.split(tip);1005 <T as transaction_payment::Trait>::OnTransactionPayment::on_unbalanceds(Some(imbalances.0).into_iter()1006 .chain(Some(imbalances.1)));1007 }1008 Ok(())1009 }1010}1#![cfg_attr(not(feature = "std"), no_std)]23/// For more guidance on Substrate FRAME, see the example pallet4/// https://github.com/paritytech/substrate/blob/master/frame/example/src/lib.rs56use codec::{Decode, Encode};7pub use frame_support::{8 decl_event, decl_module, decl_storage,9 construct_runtime, parameter_types,10 traits::{Currency, Get, ExistenceRequirement, KeyOwnerProofSystem, OnUnbalanced, Randomness, WithdrawReason, Imbalance},11 weights::{12 DispatchInfo, PostDispatchInfo, constants::{BlockExecutionWeight, ExtrinsicBaseWeight, RocksDbWeight, WEIGHT_PER_SECOND},13 IdentityFee, Weight, WeightToFeePolynomial, GetDispatchInfo, Pays,14 },15 StorageValue,16 dispatch::DispatchResult, 17 IsSubType,18 ensure19};2021use frame_system::{self as system, ensure_signed};22use sp_runtime::sp_std::prelude::Vec;23use sp_std::prelude::*;24use sp_runtime::{25 FixedU128, FixedPointOperand, 26 transaction_validity::{27 TransactionPriority, ValidTransaction, InvalidTransaction, TransactionValidityError, TransactionValidity28 },29 traits::{30 Saturating, Dispatchable, DispatchInfoOf, PostDispatchInfoOf, SignedExtension, Zero, SaturatedConversion,31 },32};3334#[cfg(test)]35mod mock;3637#[cfg(test)]38mod tests;3940#[derive(Encode, Decode, Debug, Eq, Clone, PartialEq)]41pub enum CollectionMode {42 Invalid,43 // custom data size44 NFT(u32),45 // decimal points46 Fungible(u32),47 // custom data size and decimal points48 ReFungible(u32, u32),49}5051impl Into<u8> for CollectionMode {52 fn into(self) -> u8{53 match self {54 CollectionMode::Invalid => 0,55 CollectionMode::NFT(_) => 1,56 CollectionMode::Fungible(_) => 2,57 CollectionMode::ReFungible(_, _) => 3,58 }59 }60}6162#[derive(Encode, Decode, Debug, Clone, PartialEq)]63pub enum AccessMode {64 Normal,65 WhiteList,66}67impl Default for AccessMode { fn default() -> Self { Self::Normal } }6869impl Default for CollectionMode { fn default() -> Self { Self::Invalid } }7071#[derive(Encode, Decode, Default, Clone, PartialEq)]72#[cfg_attr(feature = "std", derive(Debug))]73pub struct Ownership<AccountId> {74 pub owner: AccountId,75 pub fraction: u12876}7778#[derive(Encode, Decode, Default, Clone, PartialEq)]79#[cfg_attr(feature = "std", derive(Debug))]80pub struct CollectionType<AccountId> {81 pub owner: AccountId,82 pub mode: CollectionMode,83 pub access: AccessMode,84 pub next_item_id: u64,85 pub decimal_points: u32,86 pub name: Vec<u16>, // 64 include null escape char87 pub description: Vec<u16>, // 256 include null escape char88 pub token_prefix: Vec<u8>, // 16 include null escape char89 pub custom_data_size: u32,90 pub offchain_schema: Vec<u8>,91 pub sponsor: AccountId, // Who pays fees. If set to default address, the fees are applied to the transaction sender92 pub unconfirmed_sponsor: AccountId, // Sponsor address that has not yet confirmed sponsorship93}9495#[derive(Encode, Decode, Default, Clone, PartialEq)]96#[cfg_attr(feature = "std", derive(Debug))]97pub struct CollectionAdminsType<AccountId> {98 pub admin: AccountId,99 pub collection_id: u64,100}101102#[derive(Encode, Decode, Default, Clone, PartialEq)]103#[cfg_attr(feature = "std", derive(Debug))]104pub struct NftItemType<AccountId> {105 pub collection: u64,106 pub owner: AccountId,107 pub data: Vec<u8>,108}109110#[derive(Encode, Decode, Default, Clone, PartialEq)]111#[cfg_attr(feature = "std", derive(Debug))]112pub struct FungibleItemType<AccountId> {113 pub collection: u64,114 pub owner: AccountId,115 pub value: u128,116}117118#[derive(Encode, Decode, Default, Clone, PartialEq)]119#[cfg_attr(feature = "std", derive(Debug))]120pub struct ReFungibleItemType<AccountId> {121 pub collection: u64,122 pub owner: Vec<Ownership<AccountId>>,123 pub data: Vec<u8>,124}125126pub trait Trait: system::Trait {127 type Event: From<Event<Self>> + Into<<Self as system::Trait>::Event>;128129}130131decl_storage! {132 trait Store for Module<T: Trait> as Nft {133134 // Private members135 NextCollectionID: u64;136 ItemListIndex: map hasher(blake2_128_concat) u64 => u64;137138 pub Collection get(fn collection): map hasher(identity) u64 => CollectionType<T::AccountId>;139 pub AdminList get(fn admin_list_collection): map hasher(identity) u64 => Vec<T::AccountId>;140 pub WhiteList get(fn white_list): map hasher(identity) u64 => Vec<T::AccountId>;141142 // Balance owner per collection map143 pub Balance get(fn balance_count): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => u64;144 pub ApprovedList get(fn approved): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => Vec<T::AccountId>;145146 // Item collections147 pub NftItemList get(fn nft_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => NftItemType<T::AccountId>;148 pub FungibleItemList get(fn fungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => FungibleItemType<T::AccountId>;149 pub ReFungibleItemList get(fn refungible_item_id): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) u64 => ReFungibleItemType<T::AccountId>;150151 pub AddressTokens get(fn address_tokens): double_map hasher(blake2_128_concat) u64, hasher(blake2_128_concat) T::AccountId => Vec<u64>;152153 // Sponsorship154 pub ContractSponsor get(fn contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;155 pub UnconfirmedContractSponsor get(fn unconfirmed_contract_sponsor): map hasher(identity) T::AccountId => T::AccountId;156 }157}158159decl_event!(160 pub enum Event<T>161 where162 AccountId = <T as system::Trait>::AccountId,163 {164 Created(u64, u8, AccountId),165 ItemCreated(u64, u64),166 ItemDestroyed(u64, u64),167 }168);169170decl_module! {171 pub struct Module<T: Trait> for enum Call where origin: T::Origin {172173 fn deposit_event() = default;174175 // Create collection of NFT with given parameters176 //177 // @param customDataSz size of custom data in each collection item178 // returns collection ID179 #[weight = 0]180 pub fn create_collection( origin,181 collection_name: Vec<u16>,182 collection_description: Vec<u16>,183 token_prefix: Vec<u8>,184 mode: CollectionMode) -> DispatchResult {185186 // Anyone can create a collection187 let who = ensure_signed(origin)?;188 let custom_data_size = match mode {189 CollectionMode::NFT(size) => size,190 CollectionMode::ReFungible(size, _) => size,191 _ => 0192 };193194 let decimal_points = match mode {195 CollectionMode::Fungible(points) => points,196 CollectionMode::ReFungible(_, points) => points,197 _ => 0198 };199200 // check params201 ensure!(decimal_points <= 4, "decimal_points parameter must be lower than 4"); 202203 let mut name = collection_name.to_vec();204 name.push(0);205 ensure!(name.len() <= 64, "Collection name can not be longer than 63 char");206207 let mut description = collection_description.to_vec();208 description.push(0);209 ensure!(name.len() <= 256, "Collection description can not be longer than 255 char");210211 let mut prefix = token_prefix.to_vec();212 prefix.push(0);213 ensure!(prefix.len() <= 16, "Token prefix can not be longer than 15 char");214215 // Generate next collection ID216 let next_id = NextCollectionID::get()217 .checked_add(1)218 .expect("collection id error");219220 NextCollectionID::put(next_id);221222 // Create new collection223 let new_collection = CollectionType {224 owner: who.clone(),225 name: name,226 mode: mode.clone(),227 access: AccessMode::Normal,228 description: description,229 decimal_points: decimal_points,230 token_prefix: prefix,231 next_item_id: next_id,232 offchain_schema: Vec::new(),233 custom_data_size: custom_data_size,234 sponsor: T::AccountId::default(),235 unconfirmed_sponsor: T::AccountId::default(),236 };237238 // Add new collection to map239 <Collection<T>>::insert(next_id, new_collection);240241 // call event242 Self::deposit_event(RawEvent::Created(next_id, mode.into(), who.clone()));243244 Ok(())245 }246247 #[weight = 0]248 pub fn destroy_collection(origin, collection_id: u64) -> DispatchResult {249250 let sender = ensure_signed(origin)?;251 Self::check_owner_permissions(collection_id, sender)?;252253 <AddressTokens<T>>::remove_prefix(collection_id);254 <ApprovedList<T>>::remove_prefix(collection_id);255 <Balance<T>>::remove_prefix(collection_id);256 <ItemListIndex>::remove(collection_id);257 <AdminList<T>>::remove(collection_id);258 <Collection<T>>::remove(collection_id);259 <WhiteList<T>>::remove(collection_id);260261 Ok(())262 }263264 #[weight = 0]265 pub fn change_collection_owner(origin, collection_id: u64, new_owner: T::AccountId) -> DispatchResult {266267 let sender = ensure_signed(origin)?;268 Self::check_owner_permissions(collection_id, sender)?;269 let mut target_collection = <Collection<T>>::get(collection_id);270 target_collection.owner = new_owner;271 <Collection<T>>::insert(collection_id, target_collection);272273 Ok(())274 }275276 #[weight = 0]277 pub fn add_collection_admin(origin, collection_id: u64, new_admin_id: T::AccountId) -> DispatchResult {278279 let sender = ensure_signed(origin)?;280 Self::check_owner_or_admin_permissions(collection_id, sender)?;281 let mut admin_arr: Vec<T::AccountId> = Vec::new();282283 if <AdminList<T>>::contains_key(collection_id)284 {285 admin_arr = <AdminList<T>>::get(collection_id);286 ensure!(!admin_arr.contains(&new_admin_id), "Account already has admin role");287 }288289 admin_arr.push(new_admin_id);290 <AdminList<T>>::insert(collection_id, admin_arr);291292 Ok(())293 }294295 #[weight = 0]296 pub fn remove_collection_admin(origin, collection_id: u64, account_id: T::AccountId) -> DispatchResult {297298 let sender = ensure_signed(origin)?;299 Self::check_owner_or_admin_permissions(collection_id, sender)?;300301 if <AdminList<T>>::contains_key(collection_id)302 {303 let mut admin_arr = <AdminList<T>>::get(collection_id);304 admin_arr.retain(|i| *i != account_id);305 <AdminList<T>>::insert(collection_id, admin_arr);306 }307308 Ok(())309 }310311 #[weight = 0]312 pub fn set_collection_sponsor(origin, collection_id: u64, new_sponsor: T::AccountId) -> DispatchResult {313314 let sender = ensure_signed(origin)?;315 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");316317 let mut target_collection = <Collection<T>>::get(collection_id);318 ensure!(sender == target_collection.owner, "You do not own this collection");319320 target_collection.unconfirmed_sponsor = new_sponsor;321 <Collection<T>>::insert(collection_id, target_collection);322323 Ok(())324 }325326 #[weight = 0]327 pub fn confirm_sponsorship(origin, collection_id: u64) -> DispatchResult {328329 let sender = ensure_signed(origin)?;330 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");331332 let mut target_collection = <Collection<T>>::get(collection_id);333 ensure!(sender == target_collection.unconfirmed_sponsor, "This address is not set as sponsor, use setCollectionSponsor first");334335 target_collection.sponsor = target_collection.unconfirmed_sponsor;336 target_collection.unconfirmed_sponsor = T::AccountId::default();337 <Collection<T>>::insert(collection_id, target_collection);338339 Ok(())340 }341342 #[weight = 0]343 pub fn remove_collection_sponsor(origin, collection_id: u64) -> DispatchResult {344345 let sender = ensure_signed(origin)?;346 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");347348 let mut target_collection = <Collection<T>>::get(collection_id);349 ensure!(sender == target_collection.owner, "You do not own this collection");350351 target_collection.sponsor = T::AccountId::default();352 <Collection<T>>::insert(collection_id, target_collection);353354 Ok(())355 }356 357 #[weight = 0]358 pub fn create_item(origin, collection_id: u64, properties: Vec<u8>, owner: T::AccountId) -> DispatchResult {359360 let sender = ensure_signed(origin)?;361362 // check size363 let target_collection = <Collection<T>>::get(collection_id);364 ensure!(target_collection.custom_data_size >= properties.len() as u32, "Size of item is too large");365366 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;367368 let new_balance = <Balance<T>>::get(collection_id, owner.clone()).checked_add(1).unwrap();369 <Balance<T>>::insert(collection_id, owner.clone(), new_balance);370371 // TODO: implement other modes372 match target_collection.mode 373 {374 CollectionMode::NFT(_) => {375 // Create nft item376 let item = NftItemType {377 collection: collection_id,378 owner: owner,379 data: properties,380 };381 382 Self::add_nft_item(item)?;383 384 },385 CollectionMode::ReFungible(_, _) => {386 let mut owner_list = Vec::new();387 let value = (10 as u128).pow(target_collection.decimal_points);388 owner_list.push(Ownership {owner: owner, fraction: value});389390 let item = ReFungibleItemType {391 collection: collection_id,392 owner: owner_list,393 data: properties394 };395 396 Self::add_refungible_item(item)?;397 },398 _ => ()399 };400401 // call event402 Self::deposit_event(RawEvent::ItemCreated(collection_id, <ItemListIndex>::get(collection_id)));403404 Ok(())405 }406407 #[weight = 0]408 pub fn burn_item(origin, collection_id: u64, item_id: u64) -> DispatchResult {409410 let sender = ensure_signed(origin)?;411 let item_owner = Self::is_item_owner(sender.clone(), collection_id, item_id);412 if !item_owner413 {414 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;415 }416 let target_collection = <Collection<T>>::get(collection_id);417418 match target_collection.mode 419 {420 CollectionMode::NFT(_) => Self::burn_nft_item(collection_id, item_id)?,421 CollectionMode::ReFungible(_, _) => Self::burn_refungible_item(collection_id, item_id, sender.clone())?,422 _ => ()423 };424425 // call event426 Self::deposit_event(RawEvent::ItemDestroyed(collection_id, item_id));427428 Ok(())429 }430431 #[weight = 0]432 pub fn transfer(origin, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64) -> DispatchResult {433434 let sender = ensure_signed(origin)?;435 ensure!(Self::is_item_owner(sender.clone(), collection_id, item_id), "Only item owner can call transfer method");436437 let target_collection = <Collection<T>>::get(collection_id);438439 // TODO: implement other modes440 match target_collection.mode 441 {442 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, sender.clone(), recipient)?,443 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, sender.clone(), recipient)?,444 _ => ()445 };446447 Ok(())448 }449450 #[weight = 0]451 pub fn approve(origin, approved: T::AccountId, collection_id: u64, item_id: u64) -> DispatchResult {452453 let sender = ensure_signed(origin)?;454455 let item_owner = Self::is_item_owner(sender.clone(), collection_id, item_id);456 if !item_owner457 {458 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;459 }460461 let list_exists = <ApprovedList<T>>::contains_key(collection_id, item_id);462 if list_exists {463464 let mut list = <ApprovedList<T>>::get(collection_id, item_id);465 let item_contains = list.contains(&approved.clone());466467 if !item_contains {468 list.push(approved.clone());469 }470 } else {471472 let mut itm = Vec::new();473 itm.push(approved.clone());474 <ApprovedList<T>>::insert(collection_id, item_id, itm);475 }476477 Ok(())478 }479480 #[weight = 0]481 pub fn transfer_from(origin, from: T::AccountId, recipient: T::AccountId, collection_id: u64, item_id: u64, value: u64 ) -> DispatchResult {482483 let mut approved: bool = false; 484 let sender = ensure_signed(origin)?;485 let approved_list_exists = <ApprovedList<T>>::contains_key(collection_id, item_id);486 if approved_list_exists487 {488 let list_itm = <ApprovedList<T>>::get(collection_id, item_id);489 approved = list_itm.contains(&recipient.clone());490 }491492 if !approved493 {494 Self::check_owner_or_admin_permissions(collection_id, sender)?;495 }496 497 let target_collection = <Collection<T>>::get(collection_id);498499 match target_collection.mode500 {501 CollectionMode::NFT(_) => Self::transfer_nft(collection_id, item_id, from, recipient)?,502 CollectionMode::ReFungible(_, _) => Self::transfer_refungible(collection_id, item_id, value, from, recipient)?,503 // TODO: implement other modes504 _ => ()505 };506507 Ok(())508 }509510 #[weight = 0]511 pub fn safe_transfer_from(origin, collection_id: u64, item_id: u64, new_owner: T::AccountId) -> DispatchResult {512513 // let no_perm_mes = "You do not have permissions to modify this collection";514 // ensure!(<ApprovedList<T>>::contains_key((collection_id, item_id)), no_perm_mes);515 // let list_itm = <ApprovedList<T>>::get((collection_id, item_id));516 // ensure!(list_itm.contains(&new_owner.clone()), no_perm_mes);517518 // // on_nft_received call519520 // Self::transfer(origin, collection_id, item_id, new_owner)?;521522 Ok(())523 }524525 #[weight = 0]526 pub fn set_offchain_schema(527 origin,528 collection_id: u64,529 schema: Vec<u8>530 ) -> DispatchResult {531 let sender = ensure_signed(origin)?;532 Self::check_owner_or_admin_permissions(collection_id, sender.clone())?;533 534 let mut target_collection = <Collection<T>>::get(collection_id);535 target_collection.offchain_schema = schema;536 <Collection<T>>::insert(collection_id, target_collection);537538 Ok(()) 539 }540 }541}542543impl<T: Trait> Module<T> {544545 fn collection_exists(collection_id: u64) -> DispatchResult{546 ensure!(<Collection<T>>::contains_key(collection_id), "This collection does not exist");547 Ok(())548 }549550 fn check_owner_permissions(collection_id: u64, subject: T::AccountId) -> DispatchResult {551552 Self::collection_exists(collection_id)?;553554 let target_collection = <Collection<T>>::get(collection_id);555 ensure!(subject == target_collection.owner, "You do not own this collection");556557 Ok(())558 }559560 fn check_owner_or_admin_permissions(collection_id: u64, subject: T::AccountId) -> DispatchResult {561562 Self::collection_exists(collection_id)?;563564 let target_collection = <Collection<T>>::get(collection_id);565 let is_owner = subject == target_collection.owner;566567 let no_perm_mes = "You do not have permissions to modify this collection";568 let exists = <AdminList<T>>::contains_key(collection_id);569570 if !is_owner571 {572 ensure!(exists, no_perm_mes);573 ensure!(<AdminList<T>>::get(collection_id).contains(&subject), no_perm_mes);574 }575 Ok(())576 }577578 fn is_item_owner(subject: T::AccountId, collection_id: u64, item_id: u64) -> bool{579580 let target_collection = <Collection<T>>::get(collection_id);581582 match target_collection.mode {583 CollectionMode::NFT(_) => <NftItemList<T>>::get(collection_id, item_id).owner == subject,584 CollectionMode::Fungible(_) => <FungibleItemList<T>>::get(collection_id, item_id).owner == subject,585 CollectionMode::ReFungible(_, _) => <ReFungibleItemList<T>>::get(collection_id, item_id).owner.iter().any(|i| i.owner == subject),586 CollectionMode::Invalid => false587 }588 }589590 fn add_refungible_item(item: ReFungibleItemType<T::AccountId>) -> DispatchResult {591592 let current_index = <ItemListIndex>::get(item.collection)593 .checked_add(1)594 .expect("Item list index id error");595596 Self::add_token_index(item.collection, current_index, item.owner.first().unwrap().owner.clone())?;597598 <ItemListIndex>::insert(item.collection, current_index);599 <ReFungibleItemList<T>>::insert(item.collection, current_index, item); 600601 Ok(())602 }603604 fn burn_refungible_item(collection_id: u64, item_id: u64, owner: T::AccountId) -> DispatchResult {605 606 let collection = <ReFungibleItemList<T>>::get(collection_id, item_id);607 let item = collection.owner.iter().filter(|&i| i.owner == owner).next().unwrap();608 Self::remove_token_index(collection_id, item_id, owner)?;609610 // update balance611 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(item.fraction as u64).unwrap();612 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);613614 // TODO615 <ReFungibleItemList<T>>::remove(collection_id, item_id);616617 Ok(())618 }619620 fn transfer_refungible(collection_id: u64, item_id: u64, value: u64, owner: T::AccountId, new_owner: T::AccountId) -> DispatchResult {621622 let full_item = <ReFungibleItemList<T>>::get(collection_id, item_id);623 let item = full_item.owner.iter().filter(|i| i.owner == owner).next().unwrap();624 let amount = item.fraction;625626 ensure!(amount < value.into(),"Item balance not enouth");627628 // update balance629 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(value).unwrap();630 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);631632 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone()).checked_add(value).unwrap();633 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);634635 let old_owner = item.owner.clone();636 let new_owner_has_account = full_item.owner.iter().any(|i| i.owner == new_owner);637638 // transfer639 if amount == value.into() && !new_owner_has_account640 {641 // change owner642 // new owner do not have account643 let mut new_full_item = full_item.clone();644 new_full_item.owner.iter_mut().find(|i| i.owner == owner).unwrap().owner = new_owner.clone();645 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);646647 // update index collection648 Self::move_token_index(collection_id, item_id, old_owner.clone(), new_owner.clone())?;649 }650 else651 {652 let mut new_full_item = full_item.clone();653 new_full_item.owner.iter_mut().find(|i| i.owner == owner).unwrap().fraction -= amount;654655 // separate amount656 if new_owner_has_account {657 // new owner has account658 new_full_item.owner.iter_mut().find(|i| i.owner == new_owner).unwrap().fraction += amount;659 }660 else661 {662 // new owner do not have account663 new_full_item.owner.push(Ownership { owner: new_owner.clone(), fraction: amount});664 Self::add_token_index(collection_id, item_id, new_owner.clone())?;665 }666667 <ReFungibleItemList<T>>::insert(collection_id, item_id, new_full_item);668 }669670 Ok(())671 }672 673 fn add_nft_item(item: NftItemType<T::AccountId>) -> DispatchResult {674675 let current_index = <ItemListIndex>::get(item.collection)676 .checked_add(1)677 .expect("Item list index id error");678679 Self::add_token_index(item.collection, current_index, item.owner.clone())?;680681 <ItemListIndex>::insert(item.collection, current_index);682 <NftItemList<T>>::insert(item.collection, current_index, item);683684 Ok(())685 }686687 fn burn_nft_item(collection_id: u64, item_id: u64) -> DispatchResult {688 689 let item = <NftItemList<T>>::get(collection_id, item_id);690 Self::remove_token_index(collection_id, item_id, item.owner.clone())?;691692 // update balance693 let new_balance = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(1).unwrap();694 <Balance<T>>::insert(collection_id, item.owner.clone(), new_balance);695 <NftItemList<T>>::remove(collection_id, item_id);696697 Ok(())698 }699700 fn transfer_nft(collection_id: u64, item_id: u64, sender: T::AccountId, new_owner: T::AccountId) -> DispatchResult {701702 let mut item = <NftItemList<T>>::get(collection_id, item_id);703704 ensure!(sender == item.owner,"sender parameter and item owner must be equal");705706 // update balance707 let balance_old_owner = <Balance<T>>::get(collection_id, item.owner.clone()).checked_sub(1).unwrap();708 <Balance<T>>::insert(collection_id, item.owner.clone(), balance_old_owner);709710 let balance_new_owner = <Balance<T>>::get(collection_id, new_owner.clone()).checked_add(1).unwrap();711 <Balance<T>>::insert(collection_id, new_owner.clone(), balance_new_owner);712713 // change owner714 let old_owner = item.owner.clone();715 item.owner = new_owner.clone();716 <NftItemList<T>>::insert(collection_id, item_id, item);717718 // update index collection719 Self::move_token_index(collection_id, item_id, old_owner, new_owner.clone())?;720721 // reset approved list722 let itm: Vec<T::AccountId> = Vec::new();723 <ApprovedList<T>>::insert(collection_id, item_id, itm);724725 Ok(())726 }727728 fn add_token_index(collection_id: u64, item_index: u64, owner: T::AccountId) -> DispatchResult {729 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());730 if list_exists {731 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());732 let item_contains = list.contains(&item_index.clone());733734 if !item_contains {735 list.push(item_index.clone());736 }737738 <AddressTokens<T>>::insert(collection_id, owner.clone(), list);739 } else {740 let mut itm = Vec::new();741 itm.push(item_index.clone());742 <AddressTokens<T>>::insert(collection_id, owner, itm);743 }744745 Ok(())746 }747748 fn remove_token_index(749 collection_id: u64,750 item_index: u64,751 owner: T::AccountId,752 ) -> DispatchResult {753 let list_exists = <AddressTokens<T>>::contains_key(collection_id, owner.clone());754 if list_exists {755 let mut list = <AddressTokens<T>>::get(collection_id, owner.clone());756 let item_contains = list.contains(&item_index.clone());757758 if item_contains {759 list.retain(|&item| item != item_index);760 <AddressTokens<T>>::insert(collection_id, owner, list);761 }762 }763764 Ok(())765 }766767 fn move_token_index(768 collection_id: u64,769 item_index: u64,770 old_owner: T::AccountId,771 new_owner: T::AccountId,772 ) -> DispatchResult {773 Self::remove_token_index(collection_id, item_index, old_owner)?;774 Self::add_token_index(collection_id, item_index, new_owner)?;775776 Ok(())777 }778}779780781////////////////////////////////////////////////////////////////////////////////////////////////////782// Economic models783784/// Fee multiplier.785pub type Multiplier = FixedU128;786787type BalanceOf<T> =788 <<T as transaction_payment::Trait>::Currency as Currency<<T as system::Trait>::AccountId>>::Balance;789type NegativeImbalanceOf<T> = <<T as transaction_payment::Trait>::Currency as Currency<790 <T as system::Trait>::AccountId,>>::NegativeImbalance;791792793794/// Require the transactor pay for themselves and maybe include a tip to gain additional priority795/// in the queue.796#[derive(Encode, Decode, Clone, Eq, PartialEq)]797pub struct ChargeTransactionPayment<T: transaction_payment::Trait + Send + Sync>(#[codec(compact)] BalanceOf<T>);798799impl<T:Trait + transaction_payment::Trait + Send + Sync> sp_std::fmt::Debug for ChargeTransactionPayment<T> {800 #[cfg(feature = "std")]801 fn fmt(&self, f: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {802 write!(f, "ChargeTransactionPayment<{:?}>", self.0)803 }804 #[cfg(not(feature = "std"))]805 fn fmt(&self, _: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {806 Ok(())807 }808}809810impl<T:Trait + transaction_payment::Trait + Send + Sync> ChargeTransactionPayment<T> where811 T::Call: Dispatchable<Info=DispatchInfo, PostInfo=PostDispatchInfo> + IsSubType<Module<T>, T>,812 BalanceOf<T>: Send + Sync + FixedPointOperand,813{814 /// utility constructor. Used only in client/factory code.815 pub fn from(fee: BalanceOf<T>) -> Self {816 Self(fee)817 }818819 pub fn traditional_fee(820 len: usize,821 info: &DispatchInfoOf<T::Call>,822 tip: BalanceOf<T>,823 ) -> BalanceOf<T> where824 T::Call: Dispatchable<Info=DispatchInfo>,825 {826 <transaction_payment::Module<T>>::compute_fee(len as u32, info, tip)827 }828829 fn withdraw_fee(830 &self,831 who: &T::AccountId,832 call: &T::Call,833 info: &DispatchInfoOf<T::Call>,834 len: usize,835 ) -> Result<(BalanceOf<T>, Option<NegativeImbalanceOf<T>>), TransactionValidityError> {836 let tip = self.0;837838 // Set fee based on call type. Creating collection costs 1 Unique.839 // All other transactions have traditional fees so far840 let fee = match call.is_sub_type() {841 Some(Call::create_collection(..)) => <BalanceOf<T>>::from(1_000_000_000),842 _ => Self::traditional_fee(len, info, tip)843844 // Flat fee model, use only for testing purposes845 // _ => <BalanceOf<T>>::from(100)846 };847848 // Determine who is paying transaction fee based on ecnomic model849 // Parse call to extract collection ID and access collection sponsor850 let sponsor: T::AccountId = match call.is_sub_type() {851 Some(Call::create_item(collection_id, _properties, _owner)) => {852 <Collection<T>>::get(collection_id).sponsor853 },854 Some(Call::transfer(_new_owner, collection_id, _item_id, _value)) => {855 <Collection<T>>::get(collection_id).sponsor856 },857858 _ => T::AccountId::default()859 };860861 let mut who_pays_fee: T::AccountId = sponsor.clone();862 if sponsor == T::AccountId::default() {863 who_pays_fee = who.clone();864 }865866 // Only mess with balances if fee is not zero.867 if fee.is_zero() {868 return Ok((fee, None));869 }870871 match <T as transaction_payment::Trait>::Currency::withdraw(872 &who_pays_fee,873 fee,874 if tip.is_zero() {875 WithdrawReason::TransactionPayment.into()876 } else {877 WithdrawReason::TransactionPayment | WithdrawReason::Tip878 },879 ExistenceRequirement::KeepAlive,880 ) {881 Ok(imbalance) => Ok((fee, Some(imbalance))),882 Err(_) => Err(InvalidTransaction::Payment.into()),883 }884 }885}886887impl<T:Trait + transaction_payment::Trait + Send + Sync> SignedExtension for ChargeTransactionPayment<T> where888 BalanceOf<T>: Send + Sync + From<u64> + FixedPointOperand,889 T::Call: Dispatchable<Info=DispatchInfo, PostInfo=PostDispatchInfo> + IsSubType<Module<T>, T>,890{891 const IDENTIFIER: &'static str = "ChargeTransactionPayment";892 type AccountId = T::AccountId;893 type Call = T::Call;894 type AdditionalSigned = ();895 type Pre = (BalanceOf<T>, Self::AccountId, Option<NegativeImbalanceOf<T>>, BalanceOf<T>);896 fn additional_signed(&self) -> sp_std::result::Result<(), TransactionValidityError> { Ok(()) }897898 fn validate(899 &self,900 who: &Self::AccountId,901 call: &Self::Call,902 info: &DispatchInfoOf<Self::Call>,903 len: usize,904 ) -> TransactionValidity {905 let (fee, _) = self.withdraw_fee(who, call, info, len)?;906907 let mut r = ValidTransaction::default();908 // NOTE: we probably want to maximize the _fee (of any type) per weight unit_ here, which909 // will be a bit more than setting the priority to tip. For now, this is enough.910 r.priority = fee.saturated_into::<TransactionPriority>();911 Ok(r)912 }913914 fn pre_dispatch(915 self,916 who: &Self::AccountId,917 call: &Self::Call,918 info: &DispatchInfoOf<Self::Call>,919 len: usize920 ) -> Result<Self::Pre, TransactionValidityError> {921 let (fee, imbalance) = self.withdraw_fee(who, call, info, len)?;922 Ok((self.0, who.clone(), imbalance, fee))923 }924925 fn post_dispatch(926 pre: Self::Pre,927 info: &DispatchInfoOf<Self::Call>,928 post_info: &PostDispatchInfoOf<Self::Call>,929 len: usize,930 _result: &DispatchResult,931 ) -> Result<(), TransactionValidityError> {932 let (tip, who, imbalance, fee) = pre;933 if let Some(payed) = imbalance {934 let actual_fee = <transaction_payment::Module<T>>::compute_actual_fee(935 len as u32,936 info,937 post_info,938 tip,939 );940 let refund = fee.saturating_sub(actual_fee);941 let actual_payment = match <T as transaction_payment::Trait>::Currency::deposit_into_existing(&who, refund) {942 Ok(refund_imbalance) => {943 // The refund cannot be larger than the up front payed max weight.944 // `PostDispatchInfo::calc_unspent` guards against such a case.945 match payed.offset(refund_imbalance) {946 Ok(actual_payment) => actual_payment,947 Err(_) => return Err(InvalidTransaction::Payment.into()),948 }949 }950 // We do not recreate the account using the refund. The up front payment951 // is gone in that case.952 Err(_) => payed,953 };954 let imbalances = actual_payment.split(tip);955 <T as transaction_payment::Trait>::OnTransactionPayment::on_unbalanceds(Some(imbalances.0).into_iter()956 .chain(Some(imbalances.1)));957 }958 Ok(())959 }960}