change mobile sub location criteria (#601)

* revert mobile sub location criteria to 1/day

* change to not cleanout subscriber_loc_verified table

* remove time constraint from subscriber rewards

---------

Co-authored-by: Brian Balser <bbalser@nova-labs.com>

mobile_verifier/src/subscriber_location.rs

@@ -1,4 +1,4 @@
-use chrono::{DateTime, Duration, Utc};
+use chrono::{DateTime, Utc};
 use file_store::{
     file_info_poller::FileInfoStream,
     file_sink::FileSinkClient,
@@ -18,8 +18,6 @@ use sqlx::{PgPool, Postgres, Transaction};
 use std::ops::Range;
 use tokio::sync::mpsc::Receiver;
 
-const SUBSCRIBER_REWARD_PERIOD_LENGTH_IN_DAYS: i64 = 14;
-
 pub type SubscriberValidatedLocations = Vec<Vec<u8>>;
 
 pub struct SubscriberLocationIngestor {
@@ -175,13 +173,11 @@ pub struct SubscriberLocationShare {
 
 pub async fn aggregate_location_shares(
     db: impl sqlx::PgExecutor<'_> + Copy,
-    reward_period: &Range<DateTime<Utc>>,
+    _reward_period: &Range<DateTime<Utc>>,
 ) -> Result<SubscriberValidatedLocations, sqlx::Error> {
     let mut rows = sqlx::query_as::<_, SubscriberLocationShare>(
-        "select distinct(subscriber_id) from subscriber_loc_verified where received_timestamp >= $1 and received_timestamp < $2",
+        "select distinct(subscriber_id) from subscriber_loc_verified",
     )
-    .bind(reward_period.end - Duration::days(SUBSCRIBER_REWARD_PERIOD_LENGTH_IN_DAYS))
-    .bind(reward_period.end)
     .fetch(db);
     let mut location_shares = SubscriberValidatedLocations::new();
     while let Some(share) = rows.try_next().await? {