VladislavD
/
monitor
1
0
Fork 0
Code Issues 4 Pull Requests Packages Projects Releases 1 Wiki Activity

brd listener for cli - cli ini only after config pull from brd ??

migrate
prplV 2025-05-22 09:31:18 +03:00
parent 5c94e366eb
commit df3934452b
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
noxis-rs/src/main.rs
View File

@ -29,6 +29,8 @@ async fn main() -> anyhow::Result<()>{
info!("Noxis is configurating..."); info!("Noxis is configurating...");
// //
let (tx_brd, mut rx_brd) = broadcast::channel::<Processes>(1); let (tx_brd, mut rx_brd) = broadcast::channel::<Processes>(1);
// for cli to get config
let mut rx_cli_brd = tx_brd.subscribe();
// cli <-> config // cli <-> config
let (tx_oneshot, rx_oneshot) = oneshot::channel::<Processes>(); let (tx_oneshot, rx_oneshot) = oneshot::channel::<Processes>();
let mut handler: Vec<tokio::task::JoinHandle<()>> = vec![]; let mut handler: Vec<tokio::task::JoinHandle<()>> = vec![];
@ -47,7 +49,17 @@ async fn main() -> anyhow::Result<()>{
// initilaizing task for cli manipulation // initilaizing task for cli manipulation
let preboot_cli = preboot.clone(); let preboot_cli = preboot.clone();
let cli_module = tokio::spawn(async move { let cli_module = tokio::spawn(async move {
if let Err(er) = init_cli_pipeline(preboot_cli).await { let config = {
let mut tick = tokio::time::interval(Duration::from_millis(500));
loop {
tick.tick().await;
break match rx_cli_brd.try_recv() {
Ok(conf) => conf,
Err(_) => continue,
}
}
};
if let Err(er) = init_cli_pipeline(preboot_cli, Arc::new(config)).await {
error!("CLI pipeline failed due to {}", er) error!("CLI pipeline failed due to {}", er)
} }
}); });