More rebase fix

helium · Oct 10, 2024 · 5a4b999 · 5a4b999
1 parent 4565c1d
commit 5a4b999
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 8 deletions.
diff --git a/ingest/src/server_mobile.rs b/ingest/src/server_mobile.rs
@@ -14,13 +14,10 @@ use helium_proto::services::poc_mobile::{
     CoverageObjectIngestReportV1, CoverageObjectReqV1, CoverageObjectRespV1,
     DataTransferSessionIngestReportV1, DataTransferSessionReqV1, DataTransferSessionRespV1,
     InvalidatedRadioThresholdIngestReportV1, InvalidatedRadioThresholdReportReqV1,
-    InvalidatedRadioThresholdReportRespV1, InvalidatedRadioThresholdReportRespV1,
-    PromotionRewardIngestReportV1, PromotionRewardReqV1, PromotionRewardRespV1,
-    RadioLocationEstimatesIngestReportV1, RadioLocationEstimatesReqV1,
-    RadioLocationEstimatesRespV1, RadioThresholdIngestReportV1, RadioThresholdIngestReportV1,
-    RadioThresholdReportReqV1, RadioThresholdReportReqV1, RadioThresholdReportRespV1,
+    InvalidatedRadioThresholdReportRespV1, PromotionRewardIngestReportV1, PromotionRewardReqV1,
+    PromotionRewardRespV1, RadioLocationEstimatesIngestReportV1, RadioLocationEstimatesReqV1,
+    RadioLocationEstimatesRespV1, RadioThresholdIngestReportV1, RadioThresholdReportReqV1,
     RadioThresholdReportRespV1, ServiceProviderBoostedRewardsBannedRadioIngestReportV1,
-    ServiceProviderBoostedRewardsBannedRadioIngestReportV1,
     ServiceProviderBoostedRewardsBannedRadioReqV1, ServiceProviderBoostedRewardsBannedRadioRespV1,
     SpeedtestIngestReportV1, SpeedtestReqV1, SpeedtestRespV1, SubscriberLocationIngestReportV1,
     SubscriberLocationReqV1, SubscriberLocationRespV1,

diff --git a/ingest/tests/common/mod.rs b/ingest/tests/common/mod.rs
@@ -47,8 +47,7 @@ pub async fn setup_mobile() -> anyhow::Result<(TestClient, Trigger)> {
     let (sp_boosted_tx, _rx) = tokio::sync::mpsc::channel(10);
     let (subscriber_mapping_tx, subscriber_mapping_rx) = tokio::sync::mpsc::channel(10);
     let (promotion_rewards_tx, _rx) = tokio::sync::mpsc::channel(10);
-    let (radio_location_estimates_tx, _radio_location_estimates_rx) =
-        tokio::sync::mpsc::channel(10);
+    let (radio_location_estimates_tx, radio_location_estimates_rx) = tokio::sync::mpsc::channel(10);
 
     tokio::spawn(async move {
         let grpc_server = GrpcServer::new(