logos-messaging/logos-delivery
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-delivery.git synced 2026-05-05 14:29:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add WakuMessage version as per spec (#250)

Browse Source
This commit is contained in:
Dean Eigenmann 2020-10-30 16:46:07 +01:00 committed by GitHub
parent 94a28d9fb7
commit 6dc111ee2a
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
waku/node/v2/waku_types.nim
View File

@ -24,6 +24,7 @@ type
WakuMessage* = object WakuMessage* = object
payload*: seq[byte] payload*: seq[byte]
contentTopic*: ContentTopic contentTopic*: ContentTopic
version*: string
MessageNotificationHandler* = proc(topic: string, msg: WakuMessage): Future[ MessageNotificationHandler* = proc(topic: string, msg: WakuMessage): Future[
void] {.gcsafe, closure.} void] {.gcsafe, closure.}
@ -151,6 +152,7 @@ proc init*(T: type WakuMessage, buffer: seq[byte]): ProtoResult[T] =
discard ? pb.getField(1, msg.payload) discard ? pb.getField(1, msg.payload)
discard ? pb.getField(2, msg.contentTopic) discard ? pb.getField(2, msg.contentTopic)
discard ? pb.getField(3, msg.version)
ok(msg) ok(msg)
@ -159,6 +161,7 @@ proc encode*(message: WakuMessage): ProtoBuffer =
result.write(1, message.payload) result.write(1, message.payload)
result.write(2, message.contentTopic) result.write(2, message.contentTopic)
result.write(3, message.version)
proc notify*(filters: Filters, msg: WakuMessage, requestId: string = "") = proc notify*(filters: Filters, msg: WakuMessage, requestId: string = "") =
for key in filters.keys: for key in filters.keys:

1
waku/protocol/v2/waku_store.nim
View File

@ -16,7 +16,6 @@ logScope:
const const
WakuStoreCodec* = "/vac/waku/store/2.0.0-beta1" WakuStoreCodec* = "/vac/waku/store/2.0.0-beta1"
proc encode*(index: Index): ProtoBuffer = proc encode*(index: Index): ProtoBuffer =
## encodes an Index object into a ProtoBuffer ## encodes an Index object into a ProtoBuffer
## returns the resultant ProtoBuffer ## returns the resultant ProtoBuffer