reduce logs

ragibkl · Sep 12, 2024 · 11b53ee · 11b53ee
1 parent e2c33e7
commit 11b53ee
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/logs/query_logs.rs b/src/logs/query_logs.rs
@@ -14,7 +14,7 @@ pub struct QueryLogs {
 
 impl QueryLogs {
     pub fn remove_expired_logs(&self) {
-        let query_time_cutoff = Utc::now() - Duration::minutes(10);
+        let query_time_cutoff = Utc::now() - Duration::minutes(2);
 
         let mut logs_store_guard = self.logs_store.lock().unwrap();
         for query_logs in logs_store_guard.values_mut() {

diff --git a/src/logs/usage_stats.rs b/src/logs/usage_stats.rs
@@ -16,11 +16,18 @@ impl UsageStats {
     pub fn merge_logs(&self, logs_hash_map: &HashMap<String, Vec<QueryLog>>) {
         let mut last_query_times = self.last_query_times.lock().unwrap().clone();
 
+        let time_cutoff = Utc::now() - Duration::days(1);
+        last_query_times.retain(|_ip, qt| *qt > time_cutoff);
+
         for (ip, queries) in logs_hash_map.iter() {
             let Some(last_qt) = queries.last().map(|q| q.query_time) else {
                 continue;
             };
 
+            if last_qt > time_cutoff {
+                continue;
+            }
+
             match last_query_times.get_mut(ip) {
                 Some(qt) => *qt = last_qt,
                 None => {