Delete heartbeats that have different hotspots for the given cbsd_id (#…

…560)
helium · Jun 28, 2023 · 15cacfe · 15cacfe
1 parent 000140d
commit 15cacfe
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/mobile_verifier/src/heartbeats.rs b/mobile_verifier/src/heartbeats.rs
@@ -227,6 +227,13 @@ impl Heartbeat {
         if self.validity != proto::HeartbeatValidity::Valid {
             return Ok(false);
         }
+
+        sqlx::query("DELETE FROM heartbeats WHERE cbsd_id = $1 AND hotspot_key != $2")
+            .bind(&self.cbsd_id)
+            .bind(&self.hotspot_key)
+            .execute(&mut *exec)
+            .await?;
+
         let truncated_timestamp = self.truncated_timestamp()?;
         Ok(
             sqlx::query_as::<_, HeartbeatSaveResult>(