mirror of https://github.com/waku-org/nwaku.git
122 lines
3.5 KiB
Nim
122 lines
3.5 KiB
Nim
{.push raises: [].}
|
|
|
|
import
|
|
chronicles,
|
|
json_serialization,
|
|
json_serialization/std/options,
|
|
json_serialization/lexer
|
|
|
|
import ../../waku/waku_api/rest/serdes
|
|
|
|
type ProtocolTesterMessage* = object
|
|
sender*: string
|
|
index*: uint32
|
|
count*: uint32
|
|
startedAt*: int64
|
|
sinceStart*: int64
|
|
sincePrev*: int64
|
|
size*: uint64
|
|
|
|
proc writeValue*(
|
|
writer: var JsonWriter[RestJson], value: ProtocolTesterMessage
|
|
) {.raises: [IOError].} =
|
|
writer.beginRecord()
|
|
writer.writeField("sender", value.sender)
|
|
writer.writeField("index", value.index)
|
|
writer.writeField("count", value.count)
|
|
writer.writeField("startedAt", value.startedAt)
|
|
writer.writeField("sinceStart", value.sinceStart)
|
|
writer.writeField("sincePrev", value.sincePrev)
|
|
writer.writeField("size", value.size)
|
|
writer.endRecord()
|
|
|
|
proc readValue*(
|
|
reader: var JsonReader[RestJson], value: var ProtocolTesterMessage
|
|
) {.gcsafe, raises: [SerializationError, IOError].} =
|
|
var
|
|
sender: Option[string]
|
|
index: Option[uint32]
|
|
count: Option[uint32]
|
|
startedAt: Option[int64]
|
|
sinceStart: Option[int64]
|
|
sincePrev: Option[int64]
|
|
size: Option[uint64]
|
|
|
|
for fieldName in readObjectFields(reader):
|
|
case fieldName
|
|
of "sender":
|
|
if sender.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `sender` fields found", "ProtocolTesterMessage"
|
|
)
|
|
sender = some(reader.readValue(string))
|
|
of "index":
|
|
if index.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `index` fields found", "ProtocolTesterMessage"
|
|
)
|
|
index = some(reader.readValue(uint32))
|
|
of "count":
|
|
if count.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `count` fields found", "ProtocolTesterMessage"
|
|
)
|
|
count = some(reader.readValue(uint32))
|
|
of "startedAt":
|
|
if startedAt.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `startedAt` fields found", "ProtocolTesterMessage"
|
|
)
|
|
startedAt = some(reader.readValue(int64))
|
|
of "sinceStart":
|
|
if sinceStart.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `sinceStart` fields found", "ProtocolTesterMessage"
|
|
)
|
|
sinceStart = some(reader.readValue(int64))
|
|
of "sincePrev":
|
|
if sincePrev.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `sincePrev` fields found", "ProtocolTesterMessage"
|
|
)
|
|
sincePrev = some(reader.readValue(int64))
|
|
of "size":
|
|
if size.isSome():
|
|
reader.raiseUnexpectedField(
|
|
"Multiple `size` fields found", "ProtocolTesterMessage"
|
|
)
|
|
size = some(reader.readValue(uint64))
|
|
else:
|
|
unrecognizedFieldWarning(value)
|
|
|
|
if sender.isNone():
|
|
reader.raiseUnexpectedValue("Field `sender` is missing")
|
|
|
|
if index.isNone():
|
|
reader.raiseUnexpectedValue("Field `index` is missing")
|
|
|
|
if count.isNone():
|
|
reader.raiseUnexpectedValue("Field `count` is missing")
|
|
|
|
if startedAt.isNone():
|
|
reader.raiseUnexpectedValue("Field `startedAt` is missing")
|
|
|
|
if sinceStart.isNone():
|
|
reader.raiseUnexpectedValue("Field `sinceStart` is missing")
|
|
|
|
if sincePrev.isNone():
|
|
reader.raiseUnexpectedValue("Field `sincePrev` is missing")
|
|
|
|
if size.isNone():
|
|
reader.raiseUnexpectedValue("Field `size` is missing")
|
|
|
|
value = ProtocolTesterMessage(
|
|
sender: sender.get(),
|
|
index: index.get(),
|
|
count: count.get(),
|
|
startedAt: startedAt.get(),
|
|
sinceStart: sinceStart.get(),
|
|
sincePrev: sincePrev.get(),
|
|
size: size.get(),
|
|
)
|