lukas/aurcache
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add envvar for version check interval

Browse Source
This commit is contained in:
lukas-heiligenbrunner 2024-03-13 18:45:44 +01:00 committed by Lukas-Heiligenbrunner
parent 2af2e83164
commit 4d564c1d11
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/scheduler/aur_version_update.rs
View File

@ -1,3 +1,4 @@
use std::env;
use crate::db::packages; use crate::db::packages;
use crate::db::prelude::{Packages, Versions}; use crate::db::prelude::{Packages, Versions};
use anyhow::anyhow; use anyhow::anyhow;
@ -5,11 +6,16 @@ use aur_rs::{Package, Request};
use sea_orm::ActiveValue::Set; use sea_orm::ActiveValue::Set;
use sea_orm::{ActiveModelTrait, DatabaseConnection, EntityTrait}; use sea_orm::{ActiveModelTrait, DatabaseConnection, EntityTrait};
use std::time::Duration; use std::time::Duration;
use tokio::time::sleep; use tokio::time::{sleep};
pub fn start_aur_version_checking(db: DatabaseConnection) { pub fn start_aur_version_checking(db: DatabaseConnection) {
let default_version_check_interval = 10;
let check_interval = env::var("VERSION_CHECK_INTERVAL")
.map(|x| x.parse::<u64>().unwrap_or(default_version_check_interval))
.unwrap_or(default_version_check_interval);
tokio::spawn(async move { tokio::spawn(async move {
sleep(Duration::from_secs(10)).await; sleep(Duration::from_secs(check_interval)).await;
loop { loop {
println!("performing aur version checks"); println!("performing aur version checks");
match aur_check_versions(db.clone()).await { match aur_check_versions(db.clone()).await {