fix(header/p2p): add trivial retrying for trustedPeer requested

libs/header/p2p/exchange.go

@@ -40,11 +40,15 @@ type Exchange[H header.Header] struct {
 
 func NewExchange[H header.Header](
 	host host.Host,
-	peers peer.IDSlice,
+	trustedPeers peer.IDSlice,
 	protocolSuffix string,
 	connGater *conngater.BasicConnectionGater,
 	opts ...Option[ClientParameters],
 ) (*Exchange[H], error) {
+	if len(trustedPeers) == 0 {
+		return nil, fmt.Errorf("no trusted peers")
+	}
+
 	params := DefaultClientParameters()
 	for _, opt := range opts {
 		opt(&params)
@@ -58,7 +62,7 @@ func NewExchange[H header.Header](
 	return &Exchange[H]{
 		host:         host,
 		protocolID:   protocolID(protocolSuffix),
-		trustedPeers: peers,
+		trustedPeers: trustedPeers,
 		peerTracker: newPeerTracker(
 			host,
 			connGater,
@@ -77,7 +81,12 @@ func (ex *Exchange[H]) Start(context.Context) error {
 		// Try to pre-connect to trusted peers.
 		// We don't really care if we succeed at this point
 		// and just need any peers in the peerTracker asap
-		go ex.host.Connect(ex.ctx, peer.AddrInfo{ID: p}) //nolint:errcheck
+		go func(p peer.ID) {
+			err := ex.host.Connect(ex.ctx, peer.AddrInfo{ID: p}) //nolint:errcheck
+			if err != nil {
+				log.Debugw("err connecting to a bootstrap peer", "err", err, "peer", p)
+			}
+		}(p)
 	}
 	go ex.peerTracker.gc()
 	go ex.peerTracker.track()
@@ -220,13 +229,21 @@ func (ex *Exchange[H]) performRequest(
 		return make([]H, 0), nil
 	}
 
-	if len(ex.trustedPeers) == 0 {
-		return nil, fmt.Errorf("no trusted peers")
+	for {
+		//nolint:gosec // G404: Use of weak random number generator
+		idx := rand.Intn(len(ex.trustedPeers))
+		ctx, cancel := context.WithTimeout(ctx, ex.Params.TrustedPeersRequestTimeout)
+
+		h, err := ex.request(ctx, ex.trustedPeers[idx], req)
+		cancel()
+		switch err {
+		default:
+			log.Debug(err)
+			continue
+		case context.Canceled, context.DeadlineExceeded, nil:
+			return h, err
+		}
 	}
-
-	//nolint:gosec // G404: Use of weak random number generator
-	index := rand.Intn(len(ex.trustedPeers))
-	return ex.request(ctx, ex.trustedPeers[index], req)
 }
 
 // request sends the HeaderRequest to a remote peer.

libs/header/p2p/options.go

@@ -104,21 +104,24 @@ func WithRequestTimeout[T parameters](duration time.Duration) Option[T] {
 }
 
 // ClientParameters is the set of parameters that must be configured for the exchange.
+// TODO: #1667
 type ClientParameters struct {
 	// the target minimum amount of responses with the same chain head
 	MinResponses int
 	// MaxRequestSize defines the max amount of headers that can be handled at once.
-	MaxRequestSize uint64
+	MaxRequestSize uint64 // TODO: Rename to MaxRangeRequestSize
 	// MaxHeadersPerRequest defines the max amount of headers that can be requested per 1 request.
-	MaxHeadersPerRequest uint64
+	MaxHeadersPerRequest uint64 // TODO: Rename to MaxHeadersPerRangeRequest
 	// MaxAwaitingTime specifies the duration that gives to the disconnected peer to be back online,
 	// otherwise it will be removed on the next GC cycle.
 	MaxAwaitingTime time.Duration
 	// DefaultScore specifies the score for newly connected peers.
 	DefaultScore float32
 	// RequestTimeout defines a timeout after which the session will try to re-request headers
 	// from another peer.
-	RequestTimeout time.Duration
+	RequestTimeout time.Duration // TODO: Rename to RangeRequestTimeout
+	// TrustedPeersRequestTimeout a timeout for any request to a trusted peer.
+	TrustedPeersRequestTimeout time.Duration
 	// MaxTrackerSize specifies the max amount of peers that can be added to the peerTracker.
 	MaxPeerTrackerSize int
 }
@@ -132,6 +135,7 @@ func DefaultClientParameters() ClientParameters {
 		MaxAwaitingTime:      time.Hour,
 		DefaultScore:         1,
 		RequestTimeout:       time.Second * 3,
+		TrustedPeersRequestTimeout: time.Millisecond * 300,
 		MaxPeerTrackerSize:   100,
 	}
 }