Garmelon/tablejohn
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Make repo optional

Browse source
This commit is contained in:
Joscha 2023-08-09 14:13:17 +02:00
parent a261bfdd26
commit 04212dff1c
4 changed files with 28 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/server/recurring.rs
View file

@ -6,13 +6,16 @@
mod queue;
mod repo;
use std::sync::Arc;
use gix::ThreadSafeRepository;
use tracing::{debug_span, error, Instrument};
use super::Server;
async fn recurring_task(state: &Server) {
async fn recurring_task(state: &Server, repo: Arc<ThreadSafeRepository>) {
async {
if let Err(e) = repo::update(&state.db, state.repo.clone()).await {
if let Err(e) = repo::update(&state.db, repo).await {
error!("Error updating repo:\n{e:?}");
};
}
@ -28,9 +31,9 @@ async fn recurring_task(state: &Server) {
.await;
}
pub async fn run(server: Server) {
pub async fn run(server: Server, repo: Arc<ThreadSafeRepository>) {
loop {
recurring_task(&server).await;
recurring_task(&server, repo.clone()).await;
tokio::time::sleep(server.config.repo_update_delay).await;
}
}