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-16 21:03:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use optional timeout on publish messages

Browse Source
This commit is contained in:
Daniel Sanchez Quiros 2022-10-10 11:07:40 -05:00
parent ed3fa3e0e8
commit 8219d290c0
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -159,7 +159,7 @@ impl WakuNodeHandle<Running> {
&self,
message: &WakuMessage,
pubsub_topic: Option<WakuPubSubTopic>,
timeout: Duration,
timeout: Option<Duration>,
) -> Result<MessageId> {
relay::waku_relay_publish_message(message, pubsub_topic, timeout)
}

12
waku/src/node/relay.rs
View File

@ -74,7 +74,7 @@ pub fn waku_dafault_pubsub_topic() -> WakuPubSubTopic {
pub fn waku_relay_publish_message(
message: &WakuMessage,
pubsub_topic: Option<WakuPubSubTopic>,
timeout: Duration,
timeout: Option<Duration>,
) -> Result<MessageId> {
let pubsub_topic = pubsub_topic
.unwrap_or_else(waku_dafault_pubsub_topic)
@ -91,9 +91,13 @@ pub fn waku_relay_publish_message(
.expect("CString should build properly from pubsub topic")
.into_raw(),
timeout
.as_millis()
.try_into()
.expect("Duration as milliseconds should fit in a i32"),
.map(|duration| {
duration
.as_millis()
.try_into()
.expect("Duration as milliseconds should fit in a i32")
})
.unwrap_or(0),
))
}
.to_str()