implement RPC system_addReservedPeer

dot/network/service.go

@@ -591,3 +591,8 @@ func (s *Service) Peers() []common.PeerInfo {
 func (s *Service) NodeRoles() byte {
 	return s.cfg.Roles
 }
+
+// AddToPeerstore adds this address to the peerstore's AddrBook
+func (s *Service) AddToPeerstore(peer peer.AddrInfo) {
+	s.host.addToPeerstore(peer)
+}

dot/rpc/modules/api.go

@@ -9,6 +9,7 @@ import (
 	"github.com/ChainSafe/gossamer/lib/crypto"
 	"github.com/ChainSafe/gossamer/lib/runtime"
 	"github.com/ChainSafe/gossamer/lib/transaction"
+	"github.com/libp2p/go-libp2p-core/peer"
 )
 
 // StorageAPI is the interface for the storage state
@@ -44,6 +45,7 @@ type NetworkAPI interface {
 	Stop() error
 	Start() error
 	IsStopped() bool
+	AddToPeerstore(peer peer.AddrInfo)
 }
 
 // BlockProducerAPI is the interface for BlockProducer methods

dot/rpc/modules/system.go

@@ -17,9 +17,13 @@
 package modules
 
 import (
+	"errors"
 	"net/http"
+	"strings"
 
 	"github.com/ChainSafe/gossamer/lib/common"
+	"github.com/libp2p/go-libp2p-core/peer"
+	ma "github.com/multiformats/go-multiaddr"
 )
 
 // SystemModule is an RPC module providing access to core API points
@@ -31,6 +35,11 @@ type SystemModule struct {
 // EmptyRequest represents an RPC request with no fields
 type EmptyRequest struct{}
 
+// StringRequest holds string request
+type StringRequest struct {
+	String string
+}
+
 // StringResponse holds the string response
 type StringResponse string
 
@@ -135,3 +144,24 @@ func (sm *SystemModule) NodeRoles(r *http.Request, req *EmptyRequest, res *[]int
 	*res = resultArray
 	return nil
 }
+
+// AddReservedPeer Adds a reserved peer. The string parameter should encode a p2p multiaddr.
+func (sm *SystemModule) AddReservedPeer(r *http.Request, req *StringRequest, res *[]interface{}) error {
+	addressParts := strings.Split(req.String, "/p2p/")
+	if len(addressParts) != 2 {
+		return errors.New("error parsing address string")
+	}
+	maddr, err := ma.NewMultiaddr(addressParts[0])
+	if err != nil {
+		return err
+	}
+	addrs := []ma.Multiaddr{}
+	addrs = append(addrs, maddr)
+	addr := &peer.AddrInfo{
+		ID:    peer.ID(addressParts[1]),
+		Addrs: addrs,
+	}
+
+	sm.networkAPI.AddToPeerstore(*addr)
+	return err
+}