diff --git a/src/database/models/project_item.rs b/src/database/models/project_item.rs index 189448ba..d03eef0e 100644 --- a/src/database/models/project_item.rs +++ b/src/database/models/project_item.rs @@ -10,7 +10,7 @@ use serde::{Deserialize, Serialize}; const PROJECTS_NAMESPACE: &str = "projects"; const PROJECTS_SLUGS_NAMESPACE: &str = "projects_slugs"; const PROJECTS_DEPENDENCIES_NAMESPACE: &str = "projects_dependencies"; -const DEFAULT_EXPIRY: i64 = 1800; // 30 minutes +const DEFAULT_EXPIRY: i64 = 3600; // 60 minutes #[derive(Clone, Debug, Serialize, Deserialize)] pub struct DonationUrl { diff --git a/src/main.rs b/src/main.rs index 4b9e119b..4897777f 100644 --- a/src/main.rs +++ b/src/main.rs @@ -134,7 +134,7 @@ async fn main() -> std::io::Result<()> { // Changes statuses of scheduled projects/versions let pool_ref = pool.clone(); // TODO: Clear cache when these are run - scheduler.run(std::time::Duration::from_secs(60), move || { + scheduler.run(std::time::Duration::from_secs(60 * 5), move || { let pool_ref = pool_ref.clone(); info!("Releasing scheduled versions/projects!"); @@ -247,7 +247,7 @@ async fn main() -> std::io::Result<()> { let pool_ref = pool.clone(); let download_queue_ref = download_queue.clone(); - scheduler.run(std::time::Duration::from_secs(30), move || { + scheduler.run(std::time::Duration::from_secs(60 * 5), move || { let pool_ref = pool_ref.clone(); let download_queue_ref = download_queue_ref.clone(); @@ -266,7 +266,7 @@ async fn main() -> std::io::Result<()> { let pool_ref = pool.clone(); let redis_ref = redis_pool.clone(); let session_queue_ref = session_queue.clone(); - scheduler.run(std::time::Duration::from_secs(60), move || { + scheduler.run(std::time::Duration::from_secs(60 * 30), move || { let pool_ref = pool_ref.clone(); let redis_ref = redis_ref.clone(); let session_queue_ref = session_queue_ref.clone(); @@ -324,25 +324,25 @@ async fn main() -> std::io::Result<()> { }); } - { - let pool_ref = pool.clone(); - let redis_ref = redis_pool.clone(); - let client_ref = clickhouse.clone(); - scheduler.run(std::time::Duration::from_secs(60 * 60 * 6), move || { - let pool_ref = pool_ref.clone(); - let redis_ref = redis_ref.clone(); - let client_ref = client_ref.clone(); - - async move { - info!("Done running payouts"); - let result = process_payout(&pool_ref, &redis_ref, &client_ref).await; - if let Err(e) = result { - warn!("Payouts run failed: {:?}", e); - } - info!("Done running payouts"); - } - }); - } + // { + // let pool_ref = pool.clone(); + // let redis_ref = redis_pool.clone(); + // let client_ref = clickhouse.clone(); + // scheduler.run(std::time::Duration::from_secs(60 * 60 * 6), move || { + // let pool_ref = pool_ref.clone(); + // let redis_ref = redis_ref.clone(); + // let client_ref = client_ref.clone(); + // + // async move { + // info!("Done running payouts"); + // let result = process_payout(&pool_ref, &redis_ref, &client_ref).await; + // if let Err(e) = result { + // warn!("Payouts run failed: {:?}", e); + // } + // info!("Done running payouts"); + // } + // }); + // } let ip_salt = Pepper { pepper: models::ids::Base62Id(models::ids::random_base62(11)).to_string(),