robin/log-normalizer
1
0
Fork 0
mirror of https://codeberg.org/icewind/log-normalizer.git synced 2026-06-03 13:54:11 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

main loop

Browse source
This commit is contained in:
Robin Appelman 2020-06-20 12:46:45 +02:00
commit 0d206cfce3
1 changed files with 10 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/main.rs
View file

@ -7,16 +7,24 @@ use crate::database::store_log;
use crate::normalized::NormalizedLog; use crate::normalized::NormalizedLog;
use main_error::MainError; use main_error::MainError;
use sqlx::{postgres::PgQueryAs, PgPool}; use sqlx::{postgres::PgQueryAs, PgPool};
use tokio::time::{delay_for, Duration};
#[tokio::main] #[tokio::main]
async fn main() -> Result<(), MainError> { async fn main() -> Result<(), MainError> {
let database_url = dotenv::var("DATABASE_URL")?; let database_url = dotenv::var("DATABASE_URL")?;
let raw_database_url = dotenv::var("RAW_DATABASE_URL")?; let raw_database_url = dotenv::var("RAW_DATABASE_URL")?;
let pool = PgPool::builder().max_size(2).build(&database_url).await?; loop {
normalize(&database_url, &raw_database_url).await?;
delay_for(Duration::from_secs(15 * 60)).await;
}
}
async fn normalize(database_url: &str, raw_database_url: &str) -> Result<(), MainError> {
let pool = PgPool::builder().max_size(2).build(database_url).await?;
let raw_pool = PgPool::builder() let raw_pool = PgPool::builder()
.max_size(2) .max_size(2)
.build(&raw_database_url) .build(raw_database_url)
.await?; .await?;
let max = get_max_log(&raw_pool).await?; let max = get_max_log(&raw_pool).await?;