chore: do not update datum channel if not changed

cardano-miners · Aug 31, 2023 · 4c79e80 · 4c79e80
1 parent 97f5066
commit 4c79e80
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/cmd/mine.rs b/src/cmd/mine.rs
@@ -82,9 +82,16 @@ pub async fn exec() -> miette::Result<()> {
         .await
         .into_diagnostic()?;
 
+    let mut last_value = None;
+
     loop {
         match get_latest_datum(&ledger_client).await {
-            Ok(d) => sender.send(Some(d)).into_diagnostic()?,
+            Ok(d) => {
+                if Some(&d) != last_value.as_ref() {
+                    sender.send(Some(d.clone())).into_diagnostic()?;
+                    last_value = Some(d);
+                }
+            }
             Err(_) => {
                 tokio::time::sleep(Duration::from_secs(10)).await;
             }