fix: deduplicate tx count for stake deltas

Signed-off-by: William Hankins <[email protected]>

Author: whankinsiv

modules/stake_delta_filter/src/utils.rs

@@ -1,7 +1,7 @@
 use acropolis_common::{
     messages::{AddressDeltasMessage, StakeAddressDeltasMessage},
     Address, AddressDelta, BlockInfo, Era, ShelleyAddress, ShelleyAddressDelegationPart,
-    ShelleyAddressPointer, StakeAddress, StakeAddressDelta, StakeCredential,
+    ShelleyAddressPointer, StakeAddress, StakeAddressDelta, StakeCredential, TxIdentifier,
 };
 use anyhow::{anyhow, Result};
 use serde_with::serde_as;
@@ -318,7 +318,7 @@ struct StakeEntry {
     delta: i64,
     addresses: Vec<ShelleyAddress>,
     addresses_seen: HashSet<ShelleyAddress>,
-    tx_count: u32,
+    txs_seen: HashSet<TxIdentifier>,
 }
 
 /// Iterates through all address deltas in `delta`, leaves only stake addresses
@@ -403,7 +403,7 @@ pub fn process_message(
             delta: 0,
             addresses: Vec::new(),
             addresses_seen: HashSet::new(),
-            tx_count: 0,
+            txs_seen: HashSet::new(),
         });
         entry.delta += d.received.lovelace as i64 - d.sent.lovelace;
 
@@ -412,15 +412,15 @@ pub fn process_message(
                 entry.addresses.push(shelley.clone());
             }
         }
-        entry.tx_count += 1;
+        entry.txs_seen.insert(d.tx_identifier);
     }
 
     let deltas = grouped
         .into_iter()
         .map(|(stake_address, entry)| StakeAddressDelta {
             stake_address,
             addresses: entry.addresses,
-            tx_count: entry.tx_count,
+            tx_count: entry.txs_seen.len() as u32,
             delta: entry.delta,
         })
         .collect();

processes/omnibus/omnibus.toml

@@ -65,13 +65,22 @@ store-stake-addresses = false
 store-spdd = false
 
 [module.historical-accounts-state]
+# Enables /accounts/{stake_address}/rewards endpoint
 store-rewards-history = false
+# Enables /accounts/{stake_address}/history endpoint
 store-active-stake-history = false
+# Enables /accounts/{stake_address}/registrations endpoint
 store-registration-history = false
+# Enables /accounts/{stake_address}/delegations endpoint
 store-delegation-history = false
+# Enables /accounts/{stake_address}/mirs endpoint
 store-mir-history = false
+# Enables /accounts/{stake_address}/withdrawals endpoint
 store-withdrawal-history = false
+# Enables /accounts/{stake_address}/addresses endpoint
 store-addresses = false
+# Enables /accounts/{stake_address}/addresses/total endpoint (Requires store-addresses to be enabled)
+store-tx-count = false
 
 [module.drep-state]
 # Enables /governance/dreps/{drep_id} endpoint (Requires store-delegators to be enabled)