feat:handshake for meerevm p2p

p2p/synch/handshake.go

@@ -75,6 +75,7 @@ func (ps *PeerSync) immediatelyConnected(pe *peers.Peer) {
 }
 
 func (ps *PeerSync) Connection(pe *peers.Peer) {
+	ps.connectMeerEVM(pe)
 	if pe.ConnectionState().IsConnected() {
 		return
 	}
@@ -276,7 +277,7 @@ func (s *Sync) IsInboundPeerAtLimit() bool {
 	return len(s.Peers().DirInbound()) >= s.p2p.Config().MaxInbound
 }
 
-func (s *Sync) ConnectionGater(pid *peer.ID,addr ma.Multiaddr, dir network.Direction) bool {
+func (s *Sync) ConnectionGater(pid *peer.ID, addr ma.Multiaddr, dir network.Direction) bool {
 
 	var pe *peers.Peer
 	if pid != nil {
@@ -285,8 +286,8 @@ func (s *Sync) ConnectionGater(pid *peer.ID,addr ma.Multiaddr, dir network.Direc
 			return true
 		}
 		pe = s.peers.Get(*pid)
-	}else if addr != nil {
-		pe =s.peers.GetByAddress(addr)
+	} else if addr != nil {
+		pe = s.peers.GetByAddress(addr)
 	}
 
 	if pe != nil {

p2p/synch/meerevm.go

@@ -0,0 +1,36 @@
+package synch
+
+import (
+	"github.com/Qitmeer/qng/p2p/common"
+	"github.com/Qitmeer/qng/p2p/peers"
+	"github.com/ethereum/go-ethereum/p2p/enode"
+)
+
+func (ps *PeerSync) connectMeerEVM(pe *peers.Peer) {
+	ms := pe.GetMeerState()
+	if ms == nil {
+		return
+	}
+	meers := common.NewMeerState(ms)
+	meerP2P := ps.sy.p2p.BlockChain().MeerChain().Server()
+	if meerP2P.PeerCount() > 0 {
+		for _, p := range meerP2P.Peers() {
+			if p.ID() == meers.Id {
+				return
+			}
+		}
+	}
+	if len(meers.Enode) > 0 {
+		node, err := enode.Parse(enode.ValidSchemes, meers.Enode)
+		if err != nil {
+			log.Error("invalid enode: %v", err)
+		}
+		meerP2P.AddTrustedPeer(node)
+	} else if len(meers.ENR) > 0 {
+		node, err := enode.Parse(enode.ValidSchemes, meers.ENR)
+		if err != nil {
+			log.Error("invalid enr: %v", err)
+		}
+		meerP2P.AddTrustedPeer(node)
+	}
+}