Skip fetching event payloads when streaming events

gossip/handler.go

@@ -3,6 +3,8 @@ package gossip
 import (
 	"errors"
 	"fmt"
+	"io"
+	"log/slog"
 	"math"
 	"math/rand/v2"
 	"strings"
@@ -553,7 +555,11 @@ func (h *handler) handle(p *peer) error {
 	// Handle incoming messages until the connection is torn down
 	for {
 		if err := h.handleMsg(p); err != nil {
-			p.Log().Debug("Message handling failed", "err", err, "peer", p.ID(), "name", p.Name())
+			level := slog.LevelWarn
+			if errors.Is(err, io.EOF) {
+				level = slog.LevelDebug
+			}
+			p.Log().Log(level, "Message handling failed", "err", err, "peer", p.ID(), "name", p.Name())
 			return err
 		}
 	}

gossip/protocols/dag/dagstream/dagstreamleecher/leecher.go

@@ -148,10 +148,11 @@ func (d *Leecher) startSession(candidates []string) {
 		}
 	}
 
+	// We only fetch IDs since fetching IDs and events leads to message decoding
+	// issues causing the peer connection the request was send to to be closed.
+	// By requesting IDs only, this issue is avoided. The payloads of events are
+	// then requested independently using the non-streaming P2P protocol.
 	typ := dagstream.RequestIDs
-	if d.callback.PeerEpoch(peer) > d.epoch && d.emptyState && d.session.try == 0 {
-		typ = dagstream.RequestEvents
-	}
 
 	session := dagstream.Session{
 		ID:    getSessionID(d.epoch, d.session.try),