From 9496dce91708f6196074097320387c221f48ad10 Mon Sep 17 00:00:00 2001
From: Daniel Karzel <daniel@comit.network>
Date: Mon, 22 Feb 2021 14:51:22 +1100
Subject: [PATCH] Skip heartbeat messages

---
 swap/src/asb/kraken.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/swap/src/asb/kraken.rs b/swap/src/asb/kraken.rs
index f1f38732..62aa4d4d 100644
--- a/swap/src/asb/kraken.rs
+++ b/swap/src/asb/kraken.rs
@@ -87,6 +87,11 @@ impl RateService {
                     }
                 };
 
+                // If we encounter a heartbeat we skip it and iterate again
+                if msg.eq(r#"{"event":"heartbeat"}"#) {
+                    continue;
+                }
+
                 let ticker = match serde_json::from_str::<TickerUpdate>(&msg) {
                     Ok(ticker) => ticker,
                     Err(e) => {
@@ -151,7 +156,6 @@ impl TryFrom<TickerUpdate> for Rate {
                 TickerField::Metadata(_) => None,
             })
             .ok_or(Error::DataFieldMissing)?;
-        // TODO: Ensure whether heartbeats returned by the api are being filtered.
         let ask = data.ask.first().ok_or(Error::MissingAskRateElementType)?;
         let ask = match ask {
             RateElement::Text(ask) => {