From 40a65f981a664a186a52fc2981b99a6d8a1191d4 Mon Sep 17 00:00:00 2001 From: yuzu Date: Tue, 29 Jul 2025 09:26:15 +0000 Subject: parallel process monitoring get git-svn-id: svn+ssh://diminuette.aengel.lesbianunix.dev/salaryman/trunk@16 b9215c17-b818-4693-b096-d1e41a411fef --- src/server/main.rs | 137 +++++++++++++---------------------------------------- 1 file changed, 34 insertions(+), 103 deletions(-) (limited to 'src/server/main.rs') diff --git a/src/server/main.rs b/src/server/main.rs index 7557145..b769fbf 100644 --- a/src/server/main.rs +++ b/src/server/main.rs @@ -1,25 +1,12 @@ -mod context; -mod endpoints; - use clap::Parser; -use dropshot::{ApiDescription, ConfigDropshot, ConfigLogging, ConfigLoggingLevel, ServerBuilder}; -use salaryman::service::{Service, ServiceConf}; -use schemars::JsonSchema; +use salaryman::service::{Service, ServiceConf, ServiceState}; use serde::{Deserialize, Serialize}; -use tokio::{fs::read_to_string, sync::RwLock}; - use std::{ - net::{IpAddr, SocketAddr}, + fs::read_to_string, + os::unix::net::{UnixListener, UnixStream}, path::PathBuf, - sync::Arc, -}; - -use crate::context::{SalarymanDContext, SalarymanService}; -use crate::endpoints::{ - endpoint_get_config, endpoint_get_config_save, endpoint_get_service, endpoint_get_services, - endpoint_post_service, endpoint_post_stdin, endpoint_put_config, endpoint_restart_service, - endpoint_start_service, endpoint_stop_service, }; +use rayon::prelude::*; #[derive(Parser, Debug)] #[command(version, about, long_about = None)] @@ -35,47 +22,33 @@ struct Args { #[arg( short, long, - value_name = "ADDR", - help = "IP address to bind API to", - default_value = "127.0.0.1" + value_name = "SOCK", + help = "UNIX socket to bind", + default_value = "/tmp/salaryman.sock" )] - address: IpAddr, - #[arg( - short, - long, - value_name = "PORT", - help = "TCP Port to bind API to", - default_value = "3080" - )] - port: u16, + socket: PathBuf, } -#[derive(Serialize, Deserialize, JsonSchema, Clone, Debug)] -pub struct User { - pub username: String, - pub token: String, +pub enum ServiceReq { + Create(ServiceConf), } -#[derive(Serialize, Deserialize, JsonSchema, Clone, Debug)] +#[derive(Serialize, Deserialize, Clone, Debug)] pub struct Config { - pub address: Option, - pub port: Option, - pub user: Vec, + pub socket: Option, pub service: Vec, } impl Config { pub fn new() -> Self { Self { - address: None, - port: None, - user: Vec::new(), + socket: None, service: Vec::new(), } } } -async fn load_config(file: &PathBuf) -> Result> { - let s: String = match read_to_string(file).await { +fn load_config(file: &PathBuf) -> Result> { + let s: String = match read_to_string(file) { Ok(s) => s, Err(_) => { return Err(Box::new(std::io::Error::new( @@ -93,70 +66,28 @@ async fn load_config(file: &PathBuf) -> Result Result<(), Box> { +fn main() -> Result<(), Box> { let args = Args::parse(); - let conf: Config = load_config(&args.config).await?; - let addr = if let Some(addr) = conf.address { - addr - } else { - args.address - }; - let port = if let Some(port) = conf.port { - port + let conf: Config = load_config(&args.config)?; + let _sockaddr = if let Some(sock) = conf.socket { + sock } else { - args.port + args.socket }; - let bind = SocketAddr::new(addr, port); - let services: RwLock>> = RwLock::new(Vec::new()); - for i in 0..conf.service.len() { - let mut lock = services.write().await; - lock.push(Arc::new(SalarymanService::from_parts( - conf.service[i].clone(), - Arc::new(RwLock::new(Service::from_conf(&conf.service[i]))), - ))); - drop(lock); + let mut services: Vec = Vec::new(); + for service in conf.service { + services.push(service.build()?); } - let lock = services.write().await; - for i in 0..lock.len() { - if lock[i].config.autostart { - let mut l = lock[i].service.write().await; - l.start().await?; - l.scan_stdout().await?; - l.scan_stderr().await?; - drop(l); - } + loop { + services.par_iter_mut() + .for_each(|service| { + match service.state().expect("unable to get service state") { + ServiceState::Failed => service.restart().expect("unable to restart service"), + ServiceState::Stopped => (), + _ => (), + } + }); + services.push(Service::new()); + std::thread::sleep(std::time::Duration::from_millis(100)); } - drop(lock); - let log_conf = ConfigLogging::StderrTerminal { - level: ConfigLoggingLevel::Info, - }; - let log = log_conf.to_logger("smd")?; - let ctx = Arc::new(SalarymanDContext::from_parts( - services, - args.config, - Arc::new(RwLock::new(conf)), - )); - let config = ConfigDropshot { - bind_address: bind, - ..Default::default() - }; - let mut api = ApiDescription::new(); - api.register(endpoint_get_services)?; - api.register(endpoint_get_service)?; - api.register(endpoint_start_service)?; - api.register(endpoint_stop_service)?; - api.register(endpoint_restart_service)?; - api.register(endpoint_post_stdin)?; - api.register(endpoint_post_service)?; - api.register(endpoint_get_config)?; - api.register(endpoint_put_config)?; - api.register(endpoint_get_config_save)?; - api.openapi("Salaryman", semver::Version::new(1, 0, 0)) - .write(&mut std::io::stdout())?; - let server = ServerBuilder::new(api, ctx.clone(), log) - .config(config) - .start()?; - server.await?; - Ok(()) } -- cgit 1.4.1-2-gfad0