logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-07 16:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

bug: fix hash size greater than 32 (#1621)

Browse Source
This commit is contained in:
Alvaro Revuelta 2023-03-24 13:06:27 +01:00 committed by GitHub
parent 8f54d80611
commit bdf5cd1c54
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
waku/v2/node/waku_node.nim
View File

@ -21,7 +21,6 @@ import
libp2p/protocols/connectivity/autonat/service, libp2p/protocols/connectivity/autonat/service,
libp2p/nameresolving/nameresolver, libp2p/nameresolving/nameresolver,
libp2p/builders, libp2p/builders,
libp2p/multihash,
libp2p/transports/tcptransport, libp2p/transports/tcptransport,
libp2p/transports/wstransport libp2p/transports/wstransport
import import
@ -391,11 +390,11 @@ proc registerRelayDefaultHandler(node: WakuNode, topic: PubsubTopic) =
if node.wakuRelay.isSubscribed(topic): if node.wakuRelay.isSubscribed(topic):
return return
proc traceHandler(topic: PubsubTopic, data: seq[byte]) {.async, gcsafe.} = proc traceHandler(topic: PubsubTopic, msg: WakuMessage) {.async, gcsafe.} =
trace "waku.relay received", trace "waku.relay received",
peerId=node.peerId, peerId=node.peerId,
pubsubTopic=topic, pubsubTopic=topic,
hash=MultiHash.digest("sha2-256", data).expect("valid hash").data.buffer.to0xHex(), # TODO: this could be replaced by a message UID hash=topic.digest(msg).to0xHex(),
receivedTime=getNowInNanosecondTime() receivedTime=getNowInNanosecondTime()
waku_node_messages.inc(labelValues = ["relay"]) waku_node_messages.inc(labelValues = ["relay"])
@ -418,7 +417,7 @@ proc registerRelayDefaultHandler(node: WakuNode, topic: PubsubTopic) =
if msg.isErr(): if msg.isErr():
return return
await traceHandler(topic, data) await traceHandler(topic, msg.value)
await filterHandler(topic, msg.value) await filterHandler(topic, msg.value)
await archiveHandler(topic, msg.value) await archiveHandler(topic, msg.value)
@ -484,7 +483,7 @@ proc publish*(node: WakuNode, topic: PubsubTopic, message: WakuMessage) {.async,
trace "waku.relay published", trace "waku.relay published",
peerId=node.peerId, peerId=node.peerId,
pubsubTopic=topic, pubsubTopic=topic,
hash=MultiHash.digest("sha2-256", message.encode().buffer).expect("valid hash").data.buffer.to0xHex(), # TODO: this could be replaced by a message UID hash=topic.digest(message).to0xHex(),
publishTime=getNowInNanosecondTime() publishTime=getNowInNanosecondTime()
proc startRelay*(node: WakuNode) {.async.} = proc startRelay*(node: WakuNode) {.async.} =