diff --git a/bin/nanocld/src/apiserver/apiserver.rs b/bin/nanocld/src/apiserver/apiserver.rs index 67b4828b4d92d970780a1c4766bf6320083c0fa1..a4e4b2140119c62074e5c8189bf75c1c3a66cf69 100644 --- a/bin/nanocld/src/apiserver/apiserver.rs +++ b/bin/nanocld/src/apiserver/apiserver.rs @@ -1,12 +1,16 @@ use ntex::rt; use std::time; -pub fn start_apiserver() { +use crate::models::SystemState; + +pub fn start_apiserver(state: SystemState) { rt::Arbiter::new().exec_fn(move || { rt::spawn(async move { loop { - let database_url = "sqlite://./database.sqlite"; + + let sqlite_addr= state.inner.config.store_addr.as_ref().unwrap().clone(); + // let database_url = "sqlite://./database.sqlite"; let address = "0.0.0.0:8080"; - if let Err(e) = fleet_apiserver::start_server(database_url, address).await + if let Err(e) = fleet_apiserver::start_server(sqlite_addr.as_str(), address).await { eprintln!("Error starting server: {}", e); } diff --git a/bin/nanocld/src/system/init.rs b/bin/nanocld/src/system/init.rs index cbebadbd696e93e625e220702e1f8d1a43336503..89e8acffce10d029ec8e3fcb0b3d14a57d232e5b 100644 --- a/bin/nanocld/src/system/init.rs +++ b/bin/nanocld/src/system/init.rs @@ -178,7 +178,7 @@ pub async fn init(conf: &DaemonConfig) -> IoResult { // Ok::<_, IoError>(()) // }); eventbus::eventbus::analyze(system_state_cl); - apiserver::apiserver::start_apiserver(); + apiserver::apiserver::start_apiserver(system_ptr); // super::metric::spawn(&system_state); Ok(system_state)