diff --git a/crates/chain-listener/src/listener.rs b/crates/chain-listener/src/listener.rs index ba9bb650d5..08b36db94f 100644 --- a/crates/chain-listener/src/listener.rs +++ b/crates/chain-listener/src/listener.rs @@ -1300,8 +1300,8 @@ impl ChainListener { } Ok(tx_id) => { tracing::info!(target: "chain-listener", "Successfully submitted {} proofs, txHash: {tx_id}", unit_ids.len()); + self.observe(|m| m.observe_proofs_submitted(unit_ids.len() as u64)); self.pending_proof_txs.push((tx_id, unit_ids)); - self.observe(|m| m.observe_proof_submitted()); Ok(()) } diff --git a/crates/peer-metrics/src/chain_listener.rs b/crates/peer-metrics/src/chain_listener.rs index de5240aa7f..c2e5b3d2a0 100644 --- a/crates/peer-metrics/src/chain_listener.rs +++ b/crates/peer-metrics/src/chain_listener.rs @@ -262,8 +262,8 @@ impl ChainListenerMetrics { self.ccp_proofs_submit_failed.inc(); } - pub fn observe_proof_submitted(&self) { - self.ccp_proofs_submitted.inc(); + pub fn observe_proofs_submitted(&self, proofs: u64) { + self.ccp_proofs_submitted.inc_by(proofs); } pub fn observe_proof_tx_success(&self) {