diff options
| author | namilsk <namilsk@namilsk.tech> | 2026-01-20 18:31:42 +0300 |
|---|---|---|
| committer | namilsk <namilsk@namilsk.tech> | 2026-01-20 18:33:30 +0300 |
| commit | 2be31dc8ca78ecd91ef726c0fa4ca5129629076e (patch) | |
| tree | 93320390eb21013df36c89171046abda5386afe1 /src/router/router.rs | |
| parent | 6f2c288f81abcaffb5381fd868b5ef82f00c4816 (diff) | |
Shitcode, again
Diffstat (limited to 'src/router/router.rs')
| -rw-r--r-- | src/router/router.rs | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/router/router.rs b/src/router/router.rs index 65de900..3f1e629 100644 --- a/src/router/router.rs +++ b/src/router/router.rs @@ -4,9 +4,15 @@ use emissary_util::reseeder::Reseeder; use emissary_util::runtime::tokio::Runtime as TokioRuntime; use emissary_util::storage::{Storage, StorageBundle}; use serde::{Deserialize, Serialize}; + use std::future::Future; use std::path::PathBuf; use std::sync::Arc; +use tokio::sync::Mutex; + +lazy_static::lazy_static! { + pub static ref ROUTER: Arc<Mutex<Option<Router<TokioRuntime>>>> = Arc::new(Mutex::new(None)); +} pub trait RouterUtils { fn config(&mut self) -> impl Future<Output = Result<(), Box<dyn std::error::Error>>> + Send; @@ -86,7 +92,7 @@ impl RouterUtils for Emissary { .store_router_info(info.name.to_string(), info.router_info.clone()) .await { - log::warn!("Failed to store reseeded router info: {}", e); + println!("Failed to store reseeded router info: {}", e); } bundle.routers.push(info.router_info); } @@ -96,7 +102,7 @@ impl RouterUtils for Emissary { self.storage_bundle = Some(bundle); return Err(format!("Reseed failed and no routers available: {}", e).into()); } else { - log::warn!("Reseed failed, but using existing routers: {}", e); + println!("Reseed failed, but using existing routers: {}", e); } } } @@ -142,7 +148,6 @@ impl RouterUtils for Emissary { .await .map_err(|e| format!("Router creation failed: {}", e))?; - // Сохраняем router_info, если он новый storage.store_local_router_info(router_info).await?; Ok(router) |