diff --git a/ingest/src/server_mobile.rs b/ingest/src/server_mobile.rs index ed4af6d59..49673b7c3 100644 --- a/ingest/src/server_mobile.rs +++ b/ingest/src/server_mobile.rs @@ -498,7 +498,7 @@ pub async fn grpc_server(settings: &Settings) -> Result<()> { fn maybe_honor_timestamp(timestamp: u64) -> u64 { if cfg!(feature = "time") && std::env::var("HONOR_TIMESTAMP").is_ok() { let str = std::env::var("HONOR_TIMESTAMP").unwrap(); - tracing::debug!("using HONOR_TIMESTAMP={}", str); + tracing::debug!("using HONOR_TIMESTAMP={str} and timestamp={timestamp}"); match str.as_str() { "0" => timestamp, timestamp_str => match timestamp_str.parse::() { diff --git a/test_mobile/tests/integration_test.rs b/test_mobile/tests/integration_test.rs index d6c00625e..1ab96d752 100644 --- a/test_mobile/tests/integration_test.rs +++ b/test_mobile/tests/integration_test.rs @@ -1,6 +1,5 @@ use anyhow::Result; use common::{docker::Docker, hotspot::Hotspot, hours_ago}; -use std::time::Duration; use uuid::Uuid; mod common; @@ -32,11 +31,11 @@ async fn main() -> Result<()> { hotspot1.submit_speedtest(1001, 1001, 25).await?; hotspot1.submit_speedtest(1002, 1002, 25).await?; - hotspot1 - .submit_wifi_heartbeat(hours_ago(12), co_uuid) - .await?; - - let _ = tokio::time::sleep(Duration::from_secs(10)).await; + for x in (1..=12).rev() { + hotspot1 + .submit_wifi_heartbeat(hours_ago(x), co_uuid) + .await?; + } Ok(()) }