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