From 66c4cec625ac9e5553a8d737ad49f256cb908744 Mon Sep 17 00:00:00 2001 From: Harshad Patil Date: Tue, 17 Oct 2023 21:34:17 -0700 Subject: [PATCH] Fix failure for DefineAsset and IssueAsset operation sent in same txn (#1022) * Fix failure for DefineAsset and IssueAsset operation sent in same txn The DefineAsset Operation has the raw asset code whereas IssueAsset Operation has the derived asset code. Currently if both the operations are sent in the same txn for a new asset it fails because the Asset code don't match. This is fixed by comparing the derived asset code from newly defined assets in the txn. * lint * fix docker image build * fix lint * lint * lint * Remove fix for testing * trigger build * trigger github actions * Revert "Remove fix for testing" This reverts commit df1f070c45f5ff02b8c848c5782d9f244d4394e7. * fix typo in yaml of CLI * Update mod.rs --------- Co-authored-by: Weikeng Chen --- .../abciapp/src/abci/server/callback/mod.rs | 1 + .../abciapp/src/abci/staking/mod.rs | 1 + src/components/finutils/src/bins/fn.yml | 36 +++++++++---------- src/ledger/src/data_model/effects.rs | 2 +- src/ledger/src/staking/mod.rs | 8 ++--- src/ledger/src/store/mod.rs | 19 +++++++++- 6 files changed, 43 insertions(+), 24 deletions(-) diff --git a/src/components/abciapp/src/abci/server/callback/mod.rs b/src/components/abciapp/src/abci/server/callback/mod.rs index 12daa86dc..66246295f 100644 --- a/src/components/abciapp/src/abci/server/callback/mod.rs +++ b/src/components/abciapp/src/abci/server/callback/mod.rs @@ -507,6 +507,7 @@ pub fn deliver_tx( } /// putting block in the ledgerState +#[allow(noop_method_call)] pub fn end_block( s: &mut ABCISubmissionServer, req: &RequestEndBlock, diff --git a/src/components/abciapp/src/abci/staking/mod.rs b/src/components/abciapp/src/abci/staking/mod.rs index 942bed172..f0ae57bd8 100644 --- a/src/components/abciapp/src/abci/staking/mod.rs +++ b/src/components/abciapp/src/abci/staking/mod.rs @@ -233,6 +233,7 @@ pub fn get_validators( /// - pay delegation rewards /// - pay proposer rewards(traditional block rewards) /// - do governance operations +#[allow(noop_method_call)] pub fn system_ops( la: &mut LedgerState, header: &Header, diff --git a/src/components/finutils/src/bins/fn.yml b/src/components/finutils/src/bins/fn.yml index cbf96a6c3..02043a839 100644 --- a/src/components/finutils/src/bins/fn.yml +++ b/src/components/finutils/src/bins/fn.yml @@ -158,7 +158,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `staker-priv-key` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - staker-priv-key - claim: about: Claim accumulated FRA rewards @@ -183,7 +183,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - seckey - delegate: about: Delegating operations @@ -213,7 +213,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - seckey - undelegate: about: Undelegating operations @@ -237,7 +237,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - seckey - transfer: about: Transfer tokens from one address to another @@ -285,7 +285,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - transfer-batch: about: Transfer tokens from one address to many others @@ -324,7 +324,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - wallet: about: manipulates a findora wallet @@ -355,14 +355,14 @@ subcommands: - gen-eth-address: help: generate the keypair of an eth address long: gen-eth-address - conflicts-with: + conflicts_with: - show - seckey - asset - use-default-eth-address: help: use a private key of the eth address if `seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - seckey - create - asset: @@ -466,7 +466,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - seckey - account: about: Return user contract account information or the balance if secret key is provided @@ -492,7 +492,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `sec-key` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - sec-key - contract-deposit: about: Transfer an asset from the UTXO chain to the EVM chain @@ -582,7 +582,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - anon-balance: about: List Anon balance and spending status for a public key and a list of commitments @@ -611,7 +611,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - owned-open-abars: about: Get Open Anon UTXOs for a keypair using commitment @@ -634,7 +634,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - owned-utxos: about: List owned UTXOs for a public key @@ -674,7 +674,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - convert-abar-to-bar: about: Convert an ABAR to BAR @@ -717,7 +717,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - anon-transfer: about: Perform an anonymous transfer @@ -759,7 +759,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - anon-transfer-batch: about: Anonymous Transfer of tokens from multiple inputs to multiple outputs @@ -801,7 +801,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - anon-fetch-merkle-proof: about: Query Merkle tree leaf info @@ -834,7 +834,7 @@ subcommands: - use-default-eth-address: help: use a private key of the eth address if `from-seckey` is not provided long: use-default-eth-address - conflicts-with: + conflicts_with: - from-seckey - replace_staker: about: Replace the staker of the validator with target address diff --git a/src/ledger/src/data_model/effects.rs b/src/ledger/src/data_model/effects.rs index e086a2034..494edbef2 100644 --- a/src/ledger/src/data_model/effects.rs +++ b/src/ledger/src/data_model/effects.rs @@ -287,7 +287,7 @@ impl TxnEffect { // (1), within this transaction //let v = vec![]; - let iss_nums = self.new_issuance_nums.entry(code).or_insert_with(Vec::new); + let iss_nums = self.new_issuance_nums.entry(code).or_default(); if let Some(last_num) = iss_nums.last() { if seq_num <= *last_num { diff --git a/src/ledger/src/staking/mod.rs b/src/ledger/src/staking/mod.rs index 7a42430b2..de471b8d2 100644 --- a/src/ledger/src/staking/mod.rs +++ b/src/ledger/src/staking/mod.rs @@ -809,7 +809,7 @@ impl Staking { self.delegation_info .end_height_map .entry(end_height) - .or_insert_with(BTreeSet::new) + .or_default() .insert(owner); // There should be no failure here !! @@ -903,7 +903,7 @@ impl Staking { self.delegation_info .end_height_map .entry(h + CFG.checkpoint.unbond_block_cnt) - .or_insert_with(BTreeSet::new) + .or_default() .insert(*addr); } @@ -995,7 +995,7 @@ impl Staking { self.delegation_info .end_height_map .entry(h + CFG.checkpoint.unbond_block_cnt) - .or_insert_with(BTreeSet::new) + .or_default() .insert(pu.new_delegator_id); // update delegator entries for pu target_validator @@ -1078,7 +1078,7 @@ impl Staking { self.delegation_info .end_height_map .entry(end_height) - .or_insert_with(BTreeSet::new) + .or_default() .insert(addr.to_owned()); Ok(()) } else { diff --git a/src/ledger/src/store/mod.rs b/src/ledger/src/store/mod.rs index 498776a22..28a2f42c8 100644 --- a/src/ledger/src/store/mod.rs +++ b/src/ledger/src/store/mod.rs @@ -1547,6 +1547,22 @@ impl LedgerStatus { // Asset issuance should match the currently registered key } + let get_effect_asset = + |derived_asset_code: &AssetTypeCode| -> Option { + for (code, asset) in &txn_effect.new_asset_codes { + let dc = AssetTypeCode::from_prefix_and_raw_asset_type_code( + AssetTypePrefix::UserDefined, + &code, + &CFG.checkpoint, + self.td_commit_height, + ); + if dc == *derived_asset_code { + return Some(asset.clone()); + } + } + None + }; + // New issuance numbers // (1) Must refer to a created asset type // - NOTE: if the asset type is created in this transaction, this @@ -1560,7 +1576,7 @@ impl LedgerStatus { let asset_type = self .asset_types .get(&code) - .or_else(|| txn_effect.new_asset_codes.get(&code).cloned()) + .or_else(|| get_effect_asset(&code)) .c(d!())?; let proper_key = asset_type.properties.issuer; if *iss_key != proper_key { @@ -1715,6 +1731,7 @@ impl LedgerStatus { // // This drains every field of `block` except `txns` and `temp_sids`. #[allow(unused_mut)] + #[allow(clippy::unwrap_or_default)] fn apply_block_effects(&mut self, block: &mut BlockEffect) -> (TmpSidMap, u64, u64) { let base_sid = self.next_txo.0; let handle_asset_type_code = |code: AssetTypeCode| {