diff --git a/pkg/node/message.go b/pkg/node/message.go index 557dec8..d49e8d2 100644 --- a/pkg/node/message.go +++ b/pkg/node/message.go @@ -7,16 +7,14 @@ import ( "github.com/google/uuid" ) -// Protocol version constants +// if payload.Version != ProtocolVersion { return errVersionMismatch } +// if payload.Version < MinProtocolVersion { return errUnsupportedVersion } const ( - // ProtocolVersion is the current protocol version - ProtocolVersion = "1.0" - // MinProtocolVersion is the minimum supported version + ProtocolVersion = "1.0" MinProtocolVersion = "1.0" ) -// SupportedProtocolVersions lists all protocol versions this node supports. -// Used for version negotiation during handshake. +// if !IsProtocolVersionSupported(peer.Version) { return errUnsupportedVersion } var SupportedProtocolVersions = []string{"1.0"} // if node.IsProtocolVersionSupported(peerVersion) { proceed() } @@ -93,7 +91,7 @@ func NewMessage(msgType MessageType, from, to string, payload interface{}) (*Mes }, nil } -// resp, err := msg.Reply(MsgPong, PongPayload{SentAt: ping.SentAt, ReceivedAt: time.Now().UnixMilli()}) +// response, err := msg.Reply(MsgPong, PongPayload{SentAt: ping.SentAt, ReceivedAt: time.Now().UnixMilli()}) // if err != nil { return nil, err } func (message *Message) Reply(msgType MessageType, payload interface{}) (*Message, error) { reply, err := NewMessage(msgType, message.To, message.From, payload)