Manually commit heartbeats and speedtests (#444)

* Manually commit heartbeats and speedtests * move dcommits to after the save last verified end time
helium · Apr 13, 2023 · c8e3501 · c8e3501
1 parent d6aba47
commit c8e3501
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/mobile_verifier/src/cli/server.rs b/mobile_verifier/src/cli/server.rs
@@ -41,6 +41,7 @@ impl Cmd {
             concat!(env!("CARGO_PKG_NAME"), "_heartbeat"),
         )
         .deposits(Some(file_upload_tx.clone()))
+        .auto_commit(false)
         .roll_time(Duration::minutes(15))
         .create()
         .await?;
@@ -52,6 +53,7 @@ impl Cmd {
             concat!(env!("CARGO_PKG_NAME"), "_speedtest_average"),
         )
         .deposits(Some(file_upload_tx.clone()))
+        .auto_commit(false)
         .roll_time(Duration::minutes(15))
         .create()
         .await?;

diff --git a/mobile_verifier/src/verifier.rs b/mobile_verifier/src/verifier.rs
@@ -112,6 +112,8 @@ impl VerifierDaemon {
         }
 
         save_last_verified_end_time(&mut transaction, &scheduler.verification_period.end).await?;
+        let _ = self.heartbeats.commit().await?.await??;
+        let _ = self.speedtest_avgs.commit().await?.await??;
         transaction.commit().await?;
 
         Ok(())