log block body validation errors

Author: Jaap van der Plas

src/main/scala/io/iohk/ethereum/blockchain/sync/fast/SyncBlocksValidator.scala

@@ -14,22 +14,23 @@ trait SyncBlocksValidator {
   def blockchain: Blockchain
   def validators: Validators
 
-  def validateBlocks(requestedHashes: Seq[ByteString], blockBodies: Seq[BlockBody]): BlockBodyValidationResult = {
-    var result: BlockBodyValidationResult = Valid
+  def validateBlocks(requestedHashes: Seq[ByteString], blockBodies: Seq[BlockBody]): BlockBodyValidationResult =
     (requestedHashes zip blockBodies)
       .map { case (hash, body) => (blockchain.getBlockHeaderByHash(hash), body) }
-      .forall {
-        case (Some(header), body) =>
-          val validationResult: Either[StdBlockValidator.BlockError, BlockValid] =
-            validators.blockValidator.validateHeaderAndBody(header, body)
-          result = validationResult.fold(_ => Invalid, _ => Valid)
-          validationResult.isRight
-        case _ =>
-          result = DbError
-          false
+      .foldLeft(Valid) {
+        case (Valid, (Some(header), body)) =>
+          validators.blockValidator
+            .validateHeaderAndBody(header, body)
+            .fold(
+              { error =>
+                log.error(s"Block body validation failed with error $error")
+                Invalid
+              },
+              _ => Valid
+            )
+        case (Valid, _) => DbError
+        case (invalid, _) => invalid
       }
-    result
-  }
 
   def validateHeaderOnly(blockHeader: BlockHeader): Either[BlockHeaderError, BlockHeaderValid] =
     validators.blockHeaderValidator.validateHeaderOnly(blockHeader)