waku-org/nwaku
1
0
Fork 0
mirror of https://github.com/waku-org/nwaku.git synced 2025-01-30 00:25:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(message): added meta attribute to waku message

Browse Source
This commit is contained in:
Lorenzo Delgado 2023-03-01 10:11:29 +01:00 committed by GitHub
parent 43b3f1cef4
commit 4865fd4b7b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
waku/v2/protocol/waku_message/codec.nim
View File

@ -21,6 +21,7 @@ proc encode*(message: WakuMessage): ProtoBuffer =
buf.write3(2, message.contentTopic) buf.write3(2, message.contentTopic)
buf.write3(3, message.version) buf.write3(3, message.version)
buf.write3(10, zint64(message.timestamp)) buf.write3(10, zint64(message.timestamp))
buf.write3(11, message.meta)
when defined(rln): when defined(rln):
buf.write3(21, message.proof) buf.write3(21, message.proof)
buf.write3(31, message.ephemeral) buf.write3(31, message.ephemeral)
@ -62,6 +63,16 @@ proc decode*(T: type WakuMessage, buffer: seq[byte]): ProtobufResult[T] =
msg.timestamp = Timestamp(timestamp) msg.timestamp = Timestamp(timestamp)
var meta: seq[byte]
if not ?pb.getField(11, meta):
msg.meta = @[]
else:
if meta.len > MaxMetaAttrLength:
return err(ProtobufError.invalidLengthField("meta"))
msg.meta = meta
# Experimental: this is part of https://rfc.vac.dev/spec/17/ spec # Experimental: this is part of https://rfc.vac.dev/spec/17/ spec
when defined(rln): when defined(rln):
var proof: seq[byte] var proof: seq[byte]

4
waku/v2/protocol/waku_message/message.nim
View File

@ -13,6 +13,8 @@ import
../../utils/time ../../utils/time
const const
MaxMetaAttrLength* = 32 # 32 bytes
MaxWakuMessageSize* = 1024 * 1024 # 1 Mibytes. Corresponds to PubSub default MaxWakuMessageSize* = 1024 * 1024 # 1 Mibytes. Corresponds to PubSub default
@ -30,6 +32,8 @@ type WakuMessage* = object
payload*: seq[byte] payload*: seq[byte]
# String identifier that can be used for content-based filtering. # String identifier that can be used for content-based filtering.
contentTopic*: ContentTopic contentTopic*: ContentTopic
# Application specific metadata.
meta*: seq[byte]
# Number to discriminate different types of payload encryption. # Number to discriminate different types of payload encryption.
# Compatibility with Whisper/WakuV1. # Compatibility with Whisper/WakuV1.
version*: uint32 version*: uint32