//! Waku node implementation mod config; mod events; mod management; mod peers; mod relay; // std pub use aes_gcm::Key; pub use multiaddr::Multiaddr; pub use secp256k1::{PublicKey, SecretKey}; use std::time::Duration; // internal use crate::general::{MessageHash, Result, WakuMessage}; pub use config::RLNConfig; pub use config::WakuNodeConfig; pub use events::{Event, WakuMessageEvent, WakuNodeContext}; pub use relay::waku_create_content_topic; use crate::Encoding; use crate::WakuContentTopic; use std::time::SystemTime; /// Marker trait to disallow undesired waku node states in the handle pub trait WakuNodeState {} /// Waku node initialized state pub struct Initialized; /// Waku node running state pub struct Running; impl WakuNodeState for Initialized {} impl WakuNodeState for Running {} /// Handle to the underliying waku node pub struct WakuNodeHandle { pub ctx: WakuNodeContext, } /// Spawn a new Waku node with the given configuration (default configuration if `None` provided) /// as per the [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_newchar-jsonconfig) pub fn waku_new(config: Option) -> Result { Ok(WakuNodeHandle { ctx: management::waku_new(config)?, }) } pub fn waku_destroy(node: WakuNodeHandle) -> Result<()> { management::waku_destroy(&node.ctx) } // unsafe impl Send for WakuNodeHandle {} impl WakuNodeHandle { /// Start a Waku node mounting all the protocols that were enabled during the Waku node instantiation. /// as per the [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_start) pub fn start(&self) -> Result<()> { management::waku_start(&self.ctx) } /// Stops a Waku node /// as per the [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_stop) pub fn stop(&self) -> Result<()> { management::waku_stop(&self.ctx) } /// Get the multiaddresses the Waku node is listening to /// as per [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_listen_addresses) pub fn listen_addresses(&self) -> Result> { management::waku_listen_addresses(&self.ctx) } /// Get the nwaku version pub fn version(&self) -> Result { management::waku_version(&self.ctx) } /// Dial peer using a multiaddress /// If `timeout` as milliseconds doesn't fit into a `i32` it is clamped to [`i32::MAX`] /// If the function execution takes longer than `timeout` value, the execution will be canceled and an error returned. /// Use 0 for no timeout /// As per the [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_connect_peerchar-address-int-timeoutms) pub fn connect(&self, address: &Multiaddr, timeout: Option) -> Result<()> { peers::waku_connect(&self.ctx, address, timeout) } pub fn relay_publish_txt( &self, pubsub_topic: &String, msg_txt: &String, content_topic_name: &'static str, timeout: Option, ) -> Result { let content_topic = WakuContentTopic::new("waku", "2", content_topic_name, Encoding::Proto); let message = WakuMessage::new( msg_txt, content_topic, 0, SystemTime::now() .duration_since(SystemTime::UNIX_EPOCH) .unwrap() .as_millis() .try_into() .unwrap(), Vec::new(), false, ); relay::waku_relay_publish_message(&self.ctx, &message, pubsub_topic, timeout) } /// Publish a message using Waku Relay. /// As per the [specification](https://rfc.vac.dev/spec/36/#extern-char-waku_relay_publishchar-messagejson-char-pubsubtopic-int-timeoutms) /// The pubsub_topic parameter is optional and if not specified it will be derived from the contentTopic. pub fn relay_publish_message( &self, message: &WakuMessage, pubsub_topic: &String, timeout: Option, ) -> Result { relay::waku_relay_publish_message(&self.ctx, message, pubsub_topic, timeout) } /// Subscribe to WakuRelay to receive messages matching a content filter. pub fn relay_subscribe(&self, pubsub_topic: &String) -> Result<()> { relay::waku_relay_subscribe(&self.ctx, pubsub_topic) } /// Closes the pubsub subscription to stop receiving messages matching a content filter. No more messages will be received from this pubsub topic pub fn relay_unsubscribe(&self, pubsub_topic: &String) -> Result<()> { relay::waku_relay_unsubscribe(&self.ctx, pubsub_topic) } }