diff --git a/api/src/context.rs b/api/src/context.rs index e7f6b4d2dd3e69..c7286d896ea1bd 100644 --- a/api/src/context.rs +++ b/api/src/context.rs @@ -935,7 +935,7 @@ impl Context { limit: u16, ledger_version: u64, ledger_info: &LedgerInfo, - ) -> Result, E> { + ) -> Result, E> { let txns_res = if !db_sharding_enabled(&self.node_config) { self.db.get_account_all_transaction_summaries( address, @@ -965,6 +965,15 @@ impl Context { .map_err(|err| { E::internal_with_code(err, AptosErrorCode::InternalError, ledger_info) }) + .map(|txns| txns.iter().map(|t| TransactionSummary { + sender: t.sender.into(), + version: t.version.into(), + transaction_hash: t.transaction_hash.into(), + replay_protector: match t.replay_protector { + aptos_types::transaction::ReplayProtector::Nonce(nonce) => ReplayProtector::Nonce(nonce.into()), + aptos_types::transaction::ReplayProtector::SequenceNumber(seq_num) => ReplayProtector::SequenceNumber(seq_num.into()) + }, + }).collect()) } pub fn get_transaction_by_hash( diff --git a/api/src/transactions.rs b/api/src/transactions.rs index ce017e9f463bf3..7b156431c8ee5a 100644 --- a/api/src/transactions.rs +++ b/api/src/transactions.rs @@ -1115,8 +1115,9 @@ impl TransactionsApi { } match accept_type { AcceptType::Json => BasicResponse::try_from_json(( - self.context - .render_transaction_summaries(&latest_ledger_info, data)?, + data, + // self.context + // .render_transaction_summaries(&latest_ledger_info, data)?, &latest_ledger_info, BasicResponseStatus::Ok, )), diff --git a/crates/transaction-emitter-lib/src/emitter/submission_worker.rs b/crates/transaction-emitter-lib/src/emitter/submission_worker.rs index adbfc31154c3bc..464c3464645c27 100644 --- a/crates/transaction-emitter-lib/src/emitter/submission_worker.rs +++ b/crates/transaction-emitter-lib/src/emitter/submission_worker.rs @@ -266,7 +266,7 @@ impl SubmissionWorker { }).collect(); match query_txn_summaries(self.client(), start_version_by_address.clone()).await { Ok((account_to_txn_summaries, ledger_timestamp)) => { - + // Remove committed transactions from self.account_data for (account, txn_summaries) in account_to_txn_summaries { for txn_summary in txn_summaries {