[network/peer] Disconnect from peers who only send legacy version field (#2830)

Co-authored-by: Stephen Buttolph <stephen@avalabs.org>

Author: dhrubabasu

message/messages_benchmark_test.go

@@ -51,7 +51,6 @@ func BenchmarkMarshalHandshake(b *testing.B) {
 				MyTime:         uint64(time.Now().Unix()),
 				IpAddr:         []byte(net.IPv4(1, 2, 3, 4).To16()),
 				IpPort:         0,
-				MyVersion:      "v1.2.3",
 				IpSigningTime:  uint64(time.Now().Unix()),
 				IpNodeIdSig:    []byte{'y', 'e', 'e', 't'},
 				TrackedSubnets: [][]byte{id[:]},
@@ -108,7 +107,6 @@ func BenchmarkUnmarshalHandshake(b *testing.B) {
 				MyTime:         uint64(time.Now().Unix()),
 				IpAddr:         []byte(net.IPv4(1, 2, 3, 4).To16()),
 				IpPort:         0,
-				MyVersion:      "v1.2.3",
 				IpSigningTime:  uint64(time.Now().Unix()),
 				IpNodeIdSig:    []byte{'y', 'e', 'e', 't'},
 				TrackedSubnets: [][]byte{id[:]},

message/messages_test.go

@@ -129,7 +129,6 @@ func TestMessage(t *testing.T) {
 						MyTime:         uint64(nowUnix),
 						IpAddr:         []byte(net.IPv6zero),
 						IpPort:         9651,
-						MyVersion:      "v1.2.3",
 						IpSigningTime:  uint64(nowUnix),
 						IpNodeIdSig:    []byte{'y', 'e', 'e', 't'},
 						TrackedSubnets: [][]byte{testID[:]},

message/mock_outbound_message_builder.go

@@ -22,7 +22,6 @@ type OutboundMsgBuilder interface {
 		networkID uint32,
 		myTime uint64,
 		ip ips.IPPort,
-		myVersion string,
 		client string,
 		major uint32,
 		minor uint32,
@@ -245,7 +244,6 @@ func (b *outMsgBuilder) Handshake(
 	networkID uint32,
 	myTime uint64,
 	ip ips.IPPort,
-	myVersion string,
 	client string,
 	major uint32,
 	minor uint32,
@@ -269,7 +267,6 @@ func (b *outMsgBuilder) Handshake(
 					MyTime:         myTime,
 					IpAddr:         ip.IP.To16(),
 					IpPort:         uint32(ip.Port),
-					MyVersion:      myVersion,
 					IpSigningTime:  ipSigningTime,
 					IpNodeIdSig:    ipNodeIDSig,
 					TrackedSubnets: subnetIDBytes,

message/outbound_msg_builder.go

@@ -523,20 +523,12 @@ func (p *peer) writeMessages() {
 	}
 
 	myVersion := p.VersionCompatibility.Version()
-	legacyApplication := &version.Application{
-		Name:  version.LegacyAppName,
-		Major: myVersion.Major,
-		Minor: myVersion.Minor,
-		Patch: myVersion.Patch,
-	}
-
 	knownPeersFilter, knownPeersSalt := p.Network.KnownPeers()
 
 	msg, err := p.MessageCreator.Handshake(
 		p.NetworkID,
 		p.Clock.Unix(),
 		mySignedIP.IPPort,
-		legacyApplication.String(),
 		myVersion.Name,
 		uint32(myVersion.Major),
 		uint32(myVersion.Minor),
@@ -946,25 +938,11 @@ func (p *peer) handleHandshake(msg *p2p.Handshake) {
 		return
 	}
 
-	if msg.Client != nil {
-		p.version = &version.Application{
-			Name:  msg.Client.Name,
-			Major: int(msg.Client.Major),
-			Minor: int(msg.Client.Minor),
-			Patch: int(msg.Client.Patch),
-		}
-	} else {
-		// Handle legacy version field
-		peerVersion, err := version.ParseLegacyApplication(msg.MyVersion)
-		if err != nil {
-			p.Log.Debug("failed to parse peer version",
-				zap.Stringer("nodeID", p.id),
-				zap.Error(err),
-			)
-			p.StartClose()
-			return
-		}
-		p.version = peerVersion
+	p.version = &version.Application{
+		Name:  msg.Client.GetName(),
+		Major: int(msg.Client.GetMajor()),
+		Minor: int(msg.Client.GetMinor()),
+		Patch: int(msg.Client.GetPatch()),
 	}
 
 	if p.VersionCompatibility.Version().Before(p.version) {

network/peer/peer.go

@@ -8,7 +8,6 @@ option go_package = "github.com/ava-labs/avalanchego/proto/pb/p2p";
 // Represents peer-to-peer messages.
 // Only one type can be non-null.
 message Message {
-  reserved 33; // Until after durango activation.
   reserved 36; // Next unused field number.
   // NOTES
   // Use "oneof" for each message type and set rest to null if not used.
@@ -100,6 +99,7 @@ message Pong {
 //
 // Peers should drop connections to peers with incompatible versions.
 message Handshake {
+  reserved 5; // Until E upgrade is activated.
   // Network the peer is running on (e.g local, testnet, mainnet)
   uint32 network_id = 1;
   // Unix timestamp when this Handshake message was created
@@ -108,8 +108,6 @@ message Handshake {
   bytes ip_addr = 3;
   // IP port of the peer
   uint32 ip_port = 4;
-  // Avalanche client version
-  string my_version = 5;
   // Timestamp of the IP
   uint64 ip_signing_time = 6;
   // Signature of the peer IP port pair at a provided timestamp with the TLS
@@ -251,7 +249,6 @@ message GetAcceptedFrontier {
 //
 // AcceptedFrontier is sent in response to GetAcceptedFrontier.
 message AcceptedFrontier {
-  reserved 4; // Until Cortina upgrade is activated
   // Chain being responded from
   bytes chain_id = 1;
   // Request id of the original GetAcceptedFrontier request
@@ -281,7 +278,6 @@ message GetAccepted {
 // a subset of container ids from the GetAccepted request that the sending peer
 // has accepted.
 message Accepted {
-  reserved 4; // Until Cortina upgrade is activated
   // Chain being responded from
   bytes chain_id = 1;
   // Request id of the original GetAccepted request
@@ -312,7 +308,6 @@ message GetAncestors {
 // Ancestors contains a contiguous ancestry of containers for the requested
 // container in order of increasing block height.
 message Ancestors {
-  reserved 4; // Until Cortina upgrade is activated
   // Chain being responded from
   bytes chain_id = 1;
   // Request id of the original GetAncestors request