fixed writing to cache

iotaledger · Jul 8, 2024 · 8248b36 · 8248b36
1 parent 50391e9
commit 8248b36
Showing 1 changed file with 4 additions and 10 deletions.
diff --git a/src/bin/inx-chronicle/api/explorer/routes.rs b/src/bin/inx-chronicle/api/explorer/routes.rs
@@ -351,7 +351,7 @@ async fn richest_addresses_ledger_analytics(
     RichestAddressesQuery { top, ledger_index }: RichestAddressesQuery,
 ) -> ApiResult<RichestAddressesResponse> {
     let ledger_index = resolve_ledger_index(&database, ledger_index).await?;
-    let cache = RICHEST_ADDRESSES_CACHE.write().await;
+    let mut cache = RICHEST_ADDRESSES_CACHE.write().await;
     let seconds_until_midnight = calculate_seconds_until_midnight();
 
     if let Some(cached_data) = &*cache {
@@ -392,10 +392,7 @@ async fn richest_addresses_ledger_analytics(
     };
 
     // Store the response in the cache
-    *RICHEST_ADDRESSES_CACHE.write().await = Some(RichestCacheData {
-        last_updated: Instant::now(),
-        data: response.clone(),
-    });
+    *cache = Some(RichestCacheData { last_updated: Instant::now(), data: response.clone() });
 
     let refresh_elapsed = refresh_start.elapsed().unwrap();
     info!("refreshing richest-addresses cache done. Took {:?}", refresh_elapsed);
@@ -409,7 +406,7 @@ async fn token_distribution_ledger_analytics(
     LedgerIndex { ledger_index }: LedgerIndex,
 ) -> ApiResult<TokenDistributionResponse> {
     let ledger_index = resolve_ledger_index(&database, ledger_index).await?;
-    let cache = TOKEN_DISTRIBUTION_CACHE.write().await;
+    let mut cache = TOKEN_DISTRIBUTION_CACHE.write().await;
 
     let seconds_until_midnight = calculate_seconds_until_midnight();
     if let Some(cached_data) = &*cache {
@@ -432,10 +429,7 @@ async fn token_distribution_ledger_analytics(
     };
 
     // Store the response in the cache
-    *TOKEN_DISTRIBUTION_CACHE.write().await = Some(TokenCacheData {
-        last_updated: Instant::now(),
-        data: response.clone(),
-    });
+    *cache = Some(TokenCacheData { last_updated: Instant::now(), data: response.clone() });
 
     let refresh_elapsed = refresh_start.elapsed().unwrap();
     info!("refreshing token-distribution cache done. Took {:?}", refresh_elapsed);