✨ Actually update the cache TTL comparatee

hackclub · Sep 5, 2024 · 22854d5 · 22854d5
1 parent 5dae8db
commit 22854d5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "replit-takeout"
-version = "1.7.4"
+version = "1.7.5"
 edition = "2021"
 authors = ["Ben Dixon <malted@malted.dev>"]
 

diff --git a/src/main.rs b/src/main.rs
@@ -73,8 +73,8 @@ async fn rocket() -> _ {
         .manage(State {
             token_to_id_cache: tokio::sync::RwLock::new(HashMap::new()),
             stats_cache: tokio::sync::RwLock::new((
-                AggregateStats::default(),
-                chrono::offset::Utc::now(),
+                airtable::aggregates().await.expect("airtable aggregates"),
+                Utc::now(),
             )),
         })
         .attach(cors.to_cors().unwrap())
@@ -186,6 +186,7 @@ async fn get_stats(state: &rocket::State<State>) -> Option<Json<AggregateStats>>
 
     if seconds_ago > 5 {
         state.stats_cache.write().await.0 = airtable::aggregates().await.ok()?;
+        state.stats_cache.write().await.1 = Utc::now();
         info!(
             "Refreshing stats cache ({seconds_ago}) :): {:?}",
             state.stats_cache.read().await.0
@@ -197,8 +198,7 @@ async fn get_stats(state: &rocket::State<State>) -> Option<Json<AggregateStats>>
         )
     }
 
-    let stats = state.stats_cache.read().await.0.clone();
-    Some(Json(stats))
+    Some(Json(state.stats_cache.read().await.0))
 }
 
 async fn airtable_loop() -> Result<()> {