logos-messaging/logos-messaging-rust-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-rust-bindings.git synced 2026-01-03 22:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor node -> management

Browse Source
This commit is contained in:
Daniel Sanchez Quiros 2022-10-03 19:03:58 +02:00
parent fb0805ce40
commit f331dae7f8
1 changed files with 1 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
waku/src/node/mod.rs
View File

@ -6,13 +6,11 @@ mod peers;
use multiaddr::Multiaddr; use multiaddr::Multiaddr;
use std::marker::PhantomData; use std::marker::PhantomData;
use std::sync::Mutex; use std::sync::Mutex;
use std::time::Duration;
// crates // crates
// internal // internal
use crate::general::{PeerId, Result}; use crate::general::Result;
pub use config::WakuNodeConfig; pub use config::WakuNodeConfig;
pub use peers::{Protocol, WakuPeerData, WakuPeers};
/// Shared flag to check if a waku node is already running in the current process /// Shared flag to check if a waku node is already running in the current process
static WAKU_NODE_INITIALIZED: Mutex<bool> = Mutex::new(false); static WAKU_NODE_INITIALIZED: Mutex<bool> = Mutex::new(false);
@ -39,10 +37,6 @@ impl<State: WakuNodeState> WakuNodeHandle<State> {
pub fn listen_addresses(&self) -> Result<Vec<Multiaddr>> { pub fn listen_addresses(&self) -> Result<Vec<Multiaddr>> {
management::waku_listen_addressses() management::waku_listen_addressses()
} }
pub fn add_peer(&mut self, address: Multiaddr, protocol_id: usize) -> Result<PeerId> {
peers::waku_add_peers(address, protocol_id)
}
} }
fn stop_node() -> Result<()> { fn stop_node() -> Result<()> {
let mut node_initialized = WAKU_NODE_INITIALIZED let mut node_initialized = WAKU_NODE_INITIALIZED
@ -66,34 +60,6 @@ impl WakuNodeHandle<Running> {
pub fn stop(self) -> Result<()> { pub fn stop(self) -> Result<()> {
stop_node() stop_node()
} }
pub fn connect_peer_with_address(
&mut self,
address: Multiaddr,
timeout: Option<Duration>,
) -> Result<()> {
peers::waku_connect_peer_with_address(address, timeout)
}
pub fn connect_peer_with_id(
&mut self,
peer_id: PeerId,
timeout: Option<Duration>,
) -> Result<()> {
peers::waku_connect_peer_with_id(peer_id, timeout)
}
pub fn disconnect_peer_with_id(&mut self, peer_id: PeerId) -> Result<()> {
peers::waku_disconnect_peer_with_id(peer_id)
}
pub fn peer_count(&self) -> Result<usize> {
peers::waku_peer_count()
}
pub fn peers(&self) -> Result<WakuPeers> {
peers::waku_peers()
}
} }
pub fn waku_new(config: Option<WakuNodeConfig>) -> Result<WakuNodeHandle<Initialized>> { pub fn waku_new(config: Option<WakuNodeConfig>) -> Result<WakuNodeHandle<Initialized>> {