From a4ee858607a816c323f1ed278c5d5d8095f156a4 Mon Sep 17 00:00:00 2001 From: Oskar Thoren Date: Thu, 10 Jun 2021 20:34:39 +0800 Subject: [PATCH] post waku relay message error handling --- nwaku.go | 2 +- nwaku/jsonrpc.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/nwaku.go b/nwaku.go index 4dde874..44ffcce 100644 --- a/nwaku.go +++ b/nwaku.go @@ -38,7 +38,7 @@ func main() { // Publish var message = nwaku.WakuRelayMessage{Payload: "0x1a2b3c4d5e6f", ContentTopic: contentTopic} - var res = nwaku.PostWakuRelayMessage(client, message) + var res, _ = nwaku.PostWakuRelayMessage(client, message) fmt.Println("Publish", res) <-nodeStopped diff --git a/nwaku/jsonrpc.go b/nwaku/jsonrpc.go index a42abeb..27c8dd4 100644 --- a/nwaku/jsonrpc.go +++ b/nwaku/jsonrpc.go @@ -28,15 +28,15 @@ func GetWakuStoreMessages(client *rpc.Client, contentTopic string) (StoreRespons } -func PostWakuRelayMessage(client *rpc.Client, message WakuRelayMessage) bool { +func PostWakuRelayMessage(client *rpc.Client, message WakuRelayMessage) (bool, error) { var topic = "/waku/2/default-waku/proto" var res bool if err := client.Call(&res, "post_waku_v2_relay_v1_message", topic, message); err != nil { - panic(err) + return res, err } - return res + return res, nil } // TODO Subscribe, then poll for getting messages