mirror of
https://github.com/status-im/nim-eth.git
synced 2025-02-17 08:27:05 +00:00
Add session message packet WIP
This commit is contained in:
parent
a3c008b80f
commit
b1a99d5ea3
@ -82,6 +82,7 @@ type
|
||||
OrdinaryMessage = 0x00
|
||||
Whoareyou = 0x01
|
||||
HandshakeMessage = 0x02
|
||||
SessionMessage = 0x03
|
||||
|
||||
Packet* = object
|
||||
case flag*: Flag
|
||||
@ -96,6 +97,9 @@ type
|
||||
# TODO record or node immediately?
|
||||
node*: Option[Node]
|
||||
srcIdHs*: NodeId
|
||||
of SessionMessage:
|
||||
# TODO: Implement
|
||||
discard
|
||||
|
||||
HandshakeKey* = object
|
||||
nodeId*: NodeId
|
||||
@ -570,3 +574,7 @@ proc decodePacket*(c: var Codec, fromAddr: Address, input: openArray[byte]):
|
||||
return decodeHandshakePacket(c, fromAddr, staticHeader.nonce,
|
||||
input.toOpenArray(0, ivSize - 1), header,
|
||||
input.toOpenArray(ivSize + header.len, input.high))
|
||||
|
||||
of SessionMessage:
|
||||
# TODO: Implement
|
||||
return ok(Packet(flag: Flag.SessionMessage))
|
@ -454,6 +454,9 @@ proc receive*(d: Protocol, a: Address, packet: openArray[byte]) =
|
||||
if node.address.isSome() and a == node.address.get():
|
||||
if d.addNode(node):
|
||||
trace "Added new node to routing table after handshake", node
|
||||
of SessionMessage:
|
||||
# TODO: implement
|
||||
discard
|
||||
else:
|
||||
trace "Packet decoding error", error = decoded.error, address = a
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user