xerbalind/planetwars.dev
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages 1 Wiki Activity

create all required directories on startup

Browse source
This commit is contained in:
Ilion Beyst 2022-07-17 17:07:53 +02:00
parent c16b068f8b
commit 09c543eee3
1 changed files with 16 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
planetwars-server/src/lib.rs
View file

@ -8,7 +8,8 @@ pub mod routes;
pub mod schema; pub mod schema;
pub mod util; pub mod util;
use std::net::SocketAddr; use std::path::PathBuf;
use std::{net::SocketAddr, fs};
use std::ops::Deref; use std::ops::Deref;
use std::sync::Arc; use std::sync::Arc;
@ -93,6 +94,19 @@ pub async fn prepare_db(config: &GlobalConfig) -> DbPool {
pool pool
} }
// create all directories required for further operation
fn init_directories(config: &GlobalConfig) -> std::io::Result<()> {
fs::create_dir_all(&config.bots_directory)?;
fs::create_dir_all(&config.maps_directory)?;
fs::create_dir_all(&config.match_logs_directory)?;
let registry_path = PathBuf::from(&config.registry_directory);
fs::create_dir_all(registry_path.join("sha256"))?;
fs::create_dir_all(registry_path.join("manifests"))?;
fs::create_dir_all(registry_path.join("uploads"))?;
Ok(())
}
pub fn api() -> Router { pub fn api() -> Router {
Router::new() Router::new()
.route("/register", post(routes::users::register)) .route("/register", post(routes::users::register))
@ -145,6 +159,7 @@ async fn run_registry(config: Arc<GlobalConfig>, db_pool: DbPool) {
pub async fn run_app() { pub async fn run_app() {
let global_config = Arc::new(get_config().unwrap()); let global_config = Arc::new(get_config().unwrap());
let db_pool = prepare_db(&global_config).await; let db_pool = prepare_db(&global_config).await;
init_directories(&global_config).unwrap();
tokio::spawn(run_ranker(global_config.clone(), db_pool.clone())); tokio::spawn(run_ranker(global_config.clone(), db_pool.clone()));
tokio::spawn(run_registry(global_config.clone(), db_pool.clone())); tokio::spawn(run_registry(global_config.clone(), db_pool.clone()));