logos-messaging/logos-messaging-rust-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-rust-bindings.git synced 2026-05-23 02:49:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

Methods should be thread-safe

Browse Source
This commit is contained in:
Daniel Sanchez Quiros 2022-10-05 16:33:16 +02:00
parent 7e5d060032
commit 7868dfde9a
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,7 +53,7 @@ impl<State: WakuNodeState> WakuNodeHandle<State> {
/// Add a node multiaddress and protocol to the waku node’s peerstore /// Add a node multiaddress and protocol to the waku node’s peerstore
/// ///
/// wrapper around [`peers::waku_add_peers`] /// wrapper around [`peers::waku_add_peers`]
pub fn add_peer(&mut self, address: Multiaddr, protocol_id: usize) -> Result<PeerId> { pub fn add_peer(&self, address: Multiaddr, protocol_id: usize) -> Result<PeerId> {
peers::waku_add_peers(address, protocol_id) peers::waku_add_peers(address, protocol_id)
} }
} }
@ -97,7 +97,7 @@ impl WakuNodeHandle<Running> {
/// ///
/// wrapper around [`peers::waku_connect_peer_with_address`] /// wrapper around [`peers::waku_connect_peer_with_address`]
pub fn connect_peer_with_address( pub fn connect_peer_with_address(
&mut self, &self,
address: Multiaddr, address: Multiaddr,
timeout: Option<Duration>, timeout: Option<Duration>,
) -> Result<()> { ) -> Result<()> {
@ -107,18 +107,14 @@ impl WakuNodeHandle<Running> {
/// Dial peer using its peer ID /// Dial peer using its peer ID
/// ///
/// wrapper around [`peers::waku_connect_peer_with_id`] /// wrapper around [`peers::waku_connect_peer_with_id`]
pub fn connect_peer_with_id( pub fn connect_peer_with_id(&self, peer_id: PeerId, timeout: Option<Duration>) -> Result<()> {
&mut self,
peer_id: PeerId,
timeout: Option<Duration>,
) -> Result<()> {
peers::waku_connect_peer_with_id(peer_id, timeout) peers::waku_connect_peer_with_id(peer_id, timeout)
} }
/// Disconnect a peer using its peerID /// Disconnect a peer using its peerID
/// ///
/// wrapper around [`peers::waku_disconnect_peer_with_id`] /// wrapper around [`peers::waku_disconnect_peer_with_id`]
pub fn disconnect_peer_with_id(&mut self, peer_id: PeerId) -> Result<()> { pub fn disconnect_peer_with_id(&self, peer_id: PeerId) -> Result<()> {
peers::waku_disconnect_peer_with_id(peer_id) peers::waku_disconnect_peer_with_id(peer_id)
} }
@ -140,7 +136,7 @@ impl WakuNodeHandle<Running> {
/// ///
/// wrapper around [`relay::waku_relay_publish_message`] /// wrapper around [`relay::waku_relay_publish_message`]
pub fn relay_publish_message( pub fn relay_publish_message(
&mut self, &self,
message: &WakuMessage, message: &WakuMessage,
pubsub_topic: Option<WakuPubSubTopic>, pubsub_topic: Option<WakuPubSubTopic>,
timeout: Duration, timeout: Duration,
@ -152,7 +148,7 @@ impl WakuNodeHandle<Running> {
/// ///
/// wrapper around [`relay::waku_relay_publish_encrypt_asymmetric`] /// wrapper around [`relay::waku_relay_publish_encrypt_asymmetric`]
pub fn relay_publish_encrypt_asymmetric( pub fn relay_publish_encrypt_asymmetric(
&mut self, &self,
message: &WakuMessage, message: &WakuMessage,
pubsub_topic: Option<WakuPubSubTopic>, pubsub_topic: Option<WakuPubSubTopic>,
public_key: &PublicKey, public_key: &PublicKey,
@ -172,7 +168,7 @@ impl WakuNodeHandle<Running> {
/// ///
/// wrapper around [`relay::waku_relay_publish_encrypt_symmetric`] /// wrapper around [`relay::waku_relay_publish_encrypt_symmetric`]
pub fn relay_publish_encrypt_symmetric( pub fn relay_publish_encrypt_symmetric(
&mut self, &self,
message: &WakuMessage, message: &WakuMessage,
pubsub_topic: Option<WakuPubSubTopic>, pubsub_topic: Option<WakuPubSubTopic>,
symmetric_key: &Key<Aes256Gcm>, symmetric_key: &Key<Aes256Gcm>,