deployer3000
/
integration-module
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases 12 Wiki Activity

main refactor

feature/1126
prplV 2025-03-06 17:53:13 +03:00
parent 4c828c968e
commit 39f901e6a6
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
crates/api-grub/src/main.rs
View File

@ -6,10 +6,8 @@ mod export;
mod monitoring; mod monitoring;
use anyhow::Result; use anyhow::Result;
// use integr_structs::api::ApiConfigV2;
use integr_structs::api::v3::Config; use integr_structs::api::v3::Config;
use logger::setup_logger; use logger::setup_logger;
// use log::{info, warn};
use config::{pull_local_config, init_config_grub_mechanism}; use config::{pull_local_config, init_config_grub_mechanism};
use net::init_api_grub_mechanism; use net::init_api_grub_mechanism;
use tokio::sync::mpsc; use tokio::sync::mpsc;
@ -23,10 +21,6 @@ async fn main() -> Result<()>{
let config = get_config().await; let config = get_config().await;
// config update channel // config update channel
let (tx, mut rx) = mpsc::channel::<Config>(1); let (tx, mut rx) = mpsc::channel::<Config>(1);
// futures
// todo : rewrite with spawn
// let config_fut = init_config_grub_mechanism(&tx);
// let grub_fut = init_api_grub_mechanism(config, &mut rx);
let event_config = tokio::spawn(async move { let event_config = tokio::spawn(async move {
match init_config_grub_mechanism(&tx).await { match init_config_grub_mechanism(&tx).await {
@ -63,7 +57,6 @@ async fn main() -> Result<()>{
for event in events_handler { for event in events_handler {
let _ = event.await; let _ = event.await;
} }
// let _ = tokio::join!(config_fut, grub_fut);
Ok(()) Ok(())
} }