From 9949996ed7a42096cbd74daeffe755f1a5313606 Mon Sep 17 00:00:00 2001 From: Lorenzo Delgado Date: Wed, 25 Jan 2023 14:35:38 +0100 Subject: [PATCH] refactor(relay): simplify relay publish jsonrpc api --- waku/v2/node/waku_node.nim | 3 +-- waku/v2/protocol/waku_relay.nim | 4 ++-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/waku/v2/node/waku_node.nim b/waku/v2/node/waku_node.nim index 41d6f4177..6b0d2e42a 100644 --- a/waku/v2/node/waku_node.nim +++ b/waku/v2/node/waku_node.nim @@ -364,8 +364,7 @@ proc publish*(node: WakuNode, topic: PubsubTopic, message: WakuMessage) {.async, trace "publish", topic=topic, contentTopic=message.contentTopic - let data = message.encode().buffer - discard await node.wakuRelay.publish(topic, data) + discard await node.wakuRelay.publish(topic, message) proc startRelay*(node: WakuNode) {.async.} = ## Setup and start relay protocol diff --git a/waku/v2/protocol/waku_relay.nim b/waku/v2/protocol/waku_relay.nim index f4f3095ac..2bd0c22bd 100644 --- a/waku/v2/protocol/waku_relay.nim +++ b/waku/v2/protocol/waku_relay.nim @@ -147,10 +147,10 @@ method publish*(w: WakuRelay, pubsubTopic: PubsubTopic, message: WakuMessage|seq var data: seq[byte] when message is WakuMessage: - data = message.encode() + data = message.encode().buffer else: data = message - return await procCall GossipSub(w).publish(pubsubTopic, message) + return await procCall GossipSub(w).publish(pubsubTopic, data)