From 64691306620f554fcd04eae9a9782d6b9e5dec5e Mon Sep 17 00:00:00 2001 From: prplV Date: Tue, 10 Dec 2024 18:23:02 +0300 Subject: [PATCH] added lib to export structs + func to init listener in noxis-rs --- noxis-cli/src/lib.rs | 3 +++ noxis-rs/src/main.rs | 9 ++++++++- 2 files changed, 11 insertions(+), 1 deletion(-) create mode 100644 noxis-cli/src/lib.rs diff --git a/noxis-cli/src/lib.rs b/noxis-cli/src/lib.rs new file mode 100644 index 0000000..163fc0a --- /dev/null +++ b/noxis-cli/src/lib.rs @@ -0,0 +1,3 @@ +mod cli; + +pub use cli::*; \ No newline at end of file diff --git a/noxis-rs/src/main.rs b/noxis-rs/src/main.rs index 1c0288d..97d9d8b 100644 --- a/noxis-rs/src/main.rs +++ b/noxis-rs/src/main.rs @@ -3,14 +3,16 @@ mod utils; use clap::Parser; use log::{error, info}; -use options::{config::*, preboot}; +use options::config::*; use options::logger::setup_logger; use options::signals::set_valid_destructor; use options::structs::Processes; +use options::cli_pipeline::init_cli_pipeline; use std::sync::Arc; use std::time::Duration; use tokio::sync::mpsc; use utils::*; + #[allow(unused_imports)] use options::preboot::PrebootParams; @@ -87,6 +89,11 @@ async fn main() { let _ = subscribe_config_stream(Arc::new(processes)).await; })); + // cli pipeline + handler.push(tokio::spawn(async move { + let _ = init_cli_pipeline().await; + })); + for i in handler { let _ = i.await; }