diff --git a/ee/tabby-webserver/src/service/cron.rs b/ee/tabby-webserver/src/service/cron.rs index 0ba79f7..c65230a 100644 --- a/ee/tabby-webserver/src/service/cron.rs +++ b/ee/tabby-webserver/src/service/cron.rs @@ -18,10 +18,9 @@ async fn new_job_scheduler(jobs: Vec) -> Result { async fn new_refresh_token_job(db_conn: DbConn) -> Result { // job is run every 2 hours let job = Job::new_async("0 0 1/2 * * * *", move |_, _| { - let utc_ts = chrono::Utc::now().timestamp(); let db_conn = db_conn.clone(); Box::pin(async move { - let res = db_conn.delete_expired_token(utc_ts).await; + let res = db_conn.delete_expired_token().await; if let Err(e) = res { error!("failed to delete expired token: {}", e); } diff --git a/ee/tabby-webserver/src/service/db/refresh_tokens.rs b/ee/tabby-webserver/src/service/db/refresh_tokens.rs index 63dd452..62338fe 100644 --- a/ee/tabby-webserver/src/service/db/refresh_tokens.rs +++ b/ee/tabby-webserver/src/service/db/refresh_tokens.rs @@ -75,13 +75,13 @@ impl DbConn { Ok(()) } - pub async fn delete_expired_token(&self, utc_ts: i64) -> Result { + pub async fn delete_expired_token(&self) -> Result { let res = self .conn .call(move |c| { c.execute( r#"DELETE FROM refresh_tokens WHERE expires_at < ?"#, - params![utc_ts], + params![Utc::now()], ) }) .await?;