fix(listener,metrics): fix counter of sent proofs (#2393)

* fix(listener,metrics): fix counter of sent proofs * fix: typo
fluencelabs · Oct 28, 2024 · 1e7c5cb · 1e7c5cb
1 parent 944b4b6
commit 1e7c5cb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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) {