@@ -277,7 +277,8 @@ proc processSignedBeaconBlock*(
277
277
proc validateBlobSidecarFromEL(
278
278
self: ref Eth2Processor,
279
279
block_root: Eth2Digest):
280
- Future[Result[void , ValidationError]] {.async: (raises: [CancelledError]) .} =
280
+ Future[Result[void , ValidationError]]
281
+ {.async: (raises: [CancelledError]) .} =
281
282
282
283
if (let o = self.quarantine[].popBlobless(block_root); o.isSome):
283
284
let blobless = o.get()
@@ -287,13 +288,15 @@ proc validateBlobSidecarFromEL(
287
288
await self.elManager.sendGetBlobs(forkyBlck)
288
289
if blobsFromElOpt.get.len > 0 and blobsFromElOpt.isSome():
289
290
let blobsEl = blobsFromElOpt.get()
291
+
290
292
# check lengths of array[BlobAndProofV1] with blobs
291
293
# kzg commitments of the signed block
292
294
if blobsEl.len == forkyBlck.message.body.blob_kzg_commitments.len:
293
295
let blob_sidecars_el =
294
296
create_blob_sidecars(
295
297
forkyBlck,
296
- deneb.KzgProofs.init(blobsEl.mapIt(kzg.KzgProof(bytes: it.proof.data))),
298
+ deneb.KzgProofs.init(blobsEl.mapIt(kzg.KzgProof(
299
+ bytes: it.proof.data))),
297
300
deneb.Blobs.init(blobsEl.mapIt(it.blob.data)))
298
301
299
302
for blb_el in blob_sidecars_el:
@@ -304,6 +307,8 @@ proc validateBlobSidecarFromEL(
304
307
MsgSource.gossip, blobless,
305
308
Opt.some(self.blobQuarantine[].popBlobs(block_root, forkyBlck)))
306
309
310
+ debug " Pulled blobs from EL, bypassing blob gossip validation" ,
311
+ blobs_from_el = blobsEl.len
307
312
return ok()
308
313
309
314
else :
0 commit comments