diff --git a/go/enclave/components/rollup_consumer.go b/go/enclave/components/rollup_consumer.go index fad4ad764f..5f4ed38c5f 100644 --- a/go/enclave/components/rollup_consumer.go +++ b/go/enclave/components/rollup_consumer.go @@ -145,11 +145,6 @@ func (rc *rollupConsumerImpl) extractAndVerifyRollups(br *common.BlockAndReceipt continue // Blob hashes don't match, skip this rollup } - // Check if we have all required blobs - if len(blobs) < len(rollupHashes.BlobHashes) { - return nil, fmt.Errorf("insufficient blobs for rollup reconstruction: have %d, need %d", len(blobs), len(rollupHashes.BlobHashes)) - } - r, err := ethadapter.ReconstructRollup(blobs) if err != nil { // This is a critical error because we've already verified the blob hashes diff --git a/go/host/l1/publisher.go b/go/host/l1/publisher.go index 168dda4e57..5675deacaa 100644 --- a/go/host/l1/publisher.go +++ b/go/host/l1/publisher.go @@ -245,21 +245,13 @@ func (p *Publisher) ExtractRelevantTenTransactions(block *types.Block, receipts decodedTx := p.mgmtContractLib.DecodeTx(txs[i]) var blobs []*kzg4844.Blob + var err error switch typedTx := decodedTx.(type) { case *ethadapter.L1SetImportantContractsTx: contractAddressTxs = append(contractAddressTxs, typedTx) case *ethadapter.L1RollupHashes: - // Check if this block is part of a reorg - //canonicalBlock, err := p.ethClient.EthClient().BlockByNumber(context.Background(), block.Number()) - //if err == nil && canonicalBlock.Hash() != block.Hash() { - // println("Skipping rollup from reorged block", - // "blockNumber", block.NumberU64(), - // "blockHash", block.Hash().Hex(), - // "canonicalHash", canonicalBlock.Hash().Hex()) - // continue - //} - blobs, err := p.blobResolver.FetchBlobs(p.sendingContext, block.Header(), typedTx.BlobHashes) + blobs, err = p.blobResolver.FetchBlobs(p.sendingContext, block.Header(), typedTx.BlobHashes) // temporarily add this host stopping check to prevent sim test failures until a more robust solution is implemented if err != nil { if errors.Is(err, ethereum.NotFound) {