fix(sync): close stream on read error (#1519)

sync/bundle/bundle.go

@@ -62,9 +62,10 @@ func (b *Bundle) Encode() ([]byte, error) {
 
 	if util.IsFlagSet(b.Flags, BundleFlagCompressed) {
 		c, err := util.CompressBuffer(data)
-		if err == nil {
-			data = c
+		if err != nil {
+			return nil, err
 		}
+		data = c
 	}
 
 	msg := &_Bundle{

sync/sync.go

@@ -317,19 +317,18 @@ func (sync *synchronizer) processGossipMessage(msg *network.GossipMessage) {
 func (sync *synchronizer) processStreamMessage(msg *network.StreamMessage) {
 	sync.logger.Debug("processing stream message", "pid", msg.From)
 
+	defer func() {
+		_ = msg.Reader.Close()
+	}()
+
 	bdl, err := sync.firewall.OpenStreamBundle(msg.Reader, msg.From)
 	if err != nil {
 		sync.logger.Debug("error on parsing a Stream bundle",
 			"from", msg.From, "bundle", bdl, "error", err)
 
 		return
 	}
-	if err := msg.Reader.Close(); err != nil {
-		// TODO: write test for me
-		sync.logger.Debug("error on closing stream", "error", err, "source", msg.From)
 
-		return
-	}
 	sync.processIncomingBundle(bdl, msg.From)
 }