@@ -17,11 +17,14 @@ use crate::models::heartbeat::Heartbeat;
1717use crate :: models:: leaderboard:: { Leaderboard , NewLeaderboard } ;
1818use crate :: utils:: time:: get_week_start;
1919
20+ const DAILY_RETENTION_DAYS : i64 = 30 ;
21+ const WEEKLY_RETENTION_WEEKS : i64 = 12 ;
22+
2023async fn regenerate_daily_leaderboard ( _tick : Tick , pool : Data < DbPool > ) {
2124 let started = std:: time:: Instant :: now ( ) ;
2225 let today = Utc :: now ( ) . date_naive ( ) ;
2326
24- tracing:: info !( period = "daily" , date = %today, "Starting leaderboard regeneration" ) ;
27+ tracing:: debug !( period = "daily" , date = %today, "Starting leaderboard regeneration" ) ;
2528
2629 let result = regenerate_leaderboard_period ( & pool, "daily" , today) ;
2730
@@ -33,7 +36,7 @@ async fn regenerate_daily_leaderboard(_tick: Tick, pool: Data<DbPool>) {
3336 metrics:: histogram!( "leaderboard_job_duration_seconds" , "period" => "daily" )
3437 . record ( elapsed. as_secs_f64 ( ) ) ;
3538
36- tracing:: info !(
39+ tracing:: debug !(
3740 period = "daily" ,
3841 elapsed_ms = elapsed. as_millis( ) as u64 ,
3942 status = status,
@@ -46,7 +49,7 @@ async fn regenerate_weekly_leaderboard(_tick: Tick, pool: Data<DbPool>) {
4649 let today = Utc :: now ( ) . date_naive ( ) ;
4750 let week_start = get_week_start ( today) ;
4851
49- tracing:: info !( period = "weekly" , date = %week_start, "Starting leaderboard regeneration" ) ;
52+ tracing:: debug !( period = "weekly" , date = %week_start, "Starting leaderboard regeneration" ) ;
5053
5154 let result = regenerate_leaderboard_period ( & pool, "weekly" , week_start) ;
5255
@@ -58,7 +61,7 @@ async fn regenerate_weekly_leaderboard(_tick: Tick, pool: Data<DbPool>) {
5861 metrics:: histogram!( "leaderboard_job_duration_seconds" , "period" => "weekly" )
5962 . record ( elapsed. as_secs_f64 ( ) ) ;
6063
61- tracing:: info !(
64+ tracing:: debug !(
6265 period = "weekly" ,
6366 elapsed_ms = elapsed. as_millis( ) as u64 ,
6467 status = status,
@@ -70,7 +73,7 @@ async fn regenerate_all_time_leaderboard(_tick: Tick, pool: Data<DbPool>) {
7073 let started = std:: time:: Instant :: now ( ) ;
7174 let all_time_date = NaiveDate :: from_ymd_opt ( 1970 , 1 , 1 ) . unwrap ( ) ;
7275
73- tracing:: info !( period = "all_time" , "Starting leaderboard regeneration" ) ;
76+ tracing:: debug !( period = "all_time" , "Starting leaderboard regeneration" ) ;
7477
7578 let result = regenerate_leaderboard_period ( & pool, "all_time" , all_time_date) ;
7679
@@ -82,7 +85,7 @@ async fn regenerate_all_time_leaderboard(_tick: Tick, pool: Data<DbPool>) {
8285 metrics:: histogram!( "leaderboard_job_duration_seconds" , "period" => "all_time" )
8386 . record ( elapsed. as_secs_f64 ( ) ) ;
8487
85- tracing:: info !(
88+ tracing:: debug !(
8689 period = "all_time" ,
8790 elapsed_ms = elapsed. as_millis( ) as u64 ,
8891 status = status,
@@ -160,14 +163,14 @@ fn cleanup_old_entries(pool: &DbPool) -> Result<(), diesel::result::Error> {
160163 } ) ?;
161164
162165 let today = Utc :: now ( ) . date_naive ( ) ;
163- let cutoff_daily = today - chrono:: Duration :: days ( 30 ) ;
164- let cutoff_weekly = today - chrono:: Duration :: weeks ( 12 ) ;
166+ let cutoff_daily = today - chrono:: Duration :: days ( DAILY_RETENTION_DAYS ) ;
167+ let cutoff_weekly = today - chrono:: Duration :: weeks ( WEEKLY_RETENTION_WEEKS ) ;
165168
166169 conn. transaction ( |conn| {
167170 let daily_deleted = Leaderboard :: delete_old_daily ( conn, cutoff_daily) ?;
168171 let weekly_deleted = Leaderboard :: delete_old_weekly ( conn, cutoff_weekly) ?;
169172
170- tracing:: info !(
173+ tracing:: debug !(
171174 daily_deleted,
172175 weekly_deleted,
173176 "Cleaned up old leaderboard entries"
0 commit comments