diff --git a/src/elements/asset.rs b/src/elements/asset.rs index 7ce96382..1a3bd24d 100644 --- a/src/elements/asset.rs +++ b/src/elements/asset.rs @@ -11,7 +11,7 @@ use crate::chain::{BNetwork, BlockHash, Network, Txid}; use crate::elements::peg::{get_pegin_data, get_pegout_data, PeginInfo, PegoutInfo}; use crate::elements::registry::{AssetMeta, AssetRegistry}; use crate::errors::*; -use crate::new_index::schema::{Operation, TxHistoryInfo, TxHistoryKey, TxHistoryRow}; +use crate::new_index::schema::{TxHistoryInfo, TxHistoryKey, TxHistoryRow}; use crate::new_index::{db::DBFlush, ChainQuery, DBRow, Mempool, Query}; use crate::util::{bincode_util, full_hash, Bytes, FullHash, TransactionStatus, TxInput}; @@ -178,17 +178,11 @@ pub fn index_confirmed_tx_assets( network: Network, parent_network: BNetwork, rows: &mut Vec, - op: &Operation, ) { let (history, issuances) = index_tx_assets(tx, network, parent_network); rows.extend(history.into_iter().map(|(asset_id, info)| { - let history_row = asset_history_row(&asset_id, confirmed_height, tx_position, info); - if let Operation::DeleteBlocksWithHistory(tx) = op { - tx.send(history_row.key.hash) - .expect("unbounded channel won't fail"); - } - history_row.into_row() + asset_history_row(&asset_id, confirmed_height, tx_position, info).into_row() })); // the initial issuance is kept twice: once in the history index under I, diff --git a/src/new_index/schema.rs b/src/new_index/schema.rs index d6c5625c..09dfbfd8 100644 --- a/src/new_index/schema.rs +++ b/src/new_index/schema.rs @@ -1568,7 +1568,6 @@ fn index_transaction( iconfig.network, iconfig.parent_network, rows, - op, ); }