Fix pushMessage parameter encoding
Signed-off-by: Lee Smet <lee.smet@hotmail.com>
This commit is contained in:
@@ -125,16 +125,15 @@ impl MyceliumClient {
|
||||
Destination::Ip(ip) => json!({ "ip": ip.to_string() }),
|
||||
Destination::Pk(pk) => json!({ "pk": pk }),
|
||||
};
|
||||
let message = json!({
|
||||
let mut message = json!({
|
||||
"dst": dst_v,
|
||||
"topic": topic,
|
||||
"payload": payload_b64,
|
||||
});
|
||||
let mut params = json!({ "message": message });
|
||||
if let Some(rt) = reply_timeout {
|
||||
params["reply_timeout"] = json!(rt);
|
||||
message["reply_timeout"] = json!(rt);
|
||||
}
|
||||
params
|
||||
message
|
||||
}
|
||||
|
||||
/// pushMessage: send a message with dst/topic/payload. Optional reply_timeout for sync replies.
|
||||
|
Reference in New Issue
Block a user