From c6662bd914f22a0f43defa530be0fcc57d866b7f Mon Sep 17 00:00:00 2001
From: Agnish Ghosh <iamagnix@gmail.com>
Date: Thu, 4 Jul 2024 11:46:40 +0530
Subject: [PATCH] reenable blobs in block proposal

---
 beacon_chain/sync/sync_protocol.nim        |  2 +-
 beacon_chain/validators/message_router.nim | 34 +++++++++++-----------
 2 files changed, 18 insertions(+), 18 deletions(-)

diff --git a/beacon_chain/sync/sync_protocol.nim b/beacon_chain/sync/sync_protocol.nim
index dcbe7b343..02702d336 100644
--- a/beacon_chain/sync/sync_protocol.nim
+++ b/beacon_chain/sync/sync_protocol.nim
@@ -24,7 +24,7 @@ const
     ## Allow syncing ~64 blocks/sec (minus request costs)
   blobResponseCost = allowedOpsPerSecondCost(1000)
     ## Multiple can exist per block, they are much smaller than blocks
-  dataColumnResponseCost = allowedOpsPerSecondCost(250)
+  dataColumnResponseCost = allowedOpsPerSecondCost(4000)
     ## 1 blob has an equivalent memory of 8 data columns
 
 type
diff --git a/beacon_chain/validators/message_router.nim b/beacon_chain/validators/message_router.nim
index e529cd748..67dd3786c 100644
--- a/beacon_chain/validators/message_router.nim
+++ b/beacon_chain/validators/message_router.nim
@@ -145,23 +145,23 @@ proc routeSignedBeaconBlock*(
       blockRoot = shortLog(blck.root), blck = shortLog(blck.message),
       signature = shortLog(blck.signature), error = res.error()
 
-  # var blobRefs = Opt.none(BlobSidecars)
-  # if blobsOpt.isSome():
-  #   let blobs = blobsOpt.get()
-  #   var workers = newSeq[Future[SendResult]](blobs.len)
-  #   for i in 0..<blobs.lenu64:
-  #     let subnet_id = compute_subnet_for_blob_sidecar(i)
-  #     workers[i] = router[].network.broadcastBlobSidecar(subnet_id, blobs[i])
-  #   let allres = await allFinished(workers)
-  #   for i in 0..<allres.len:
-  #     let res = allres[i]
-  #     doAssert res.finished()
-  #     if res.failed():
-  #       notice "Blob not sent",
-  #         blob = shortLog(blobs[i]), error = res.error[]
-  #     else:
-  #       notice "Blob sent", blob = shortLog(blobs[i])
-  #   blobRefs = Opt.some(blobs.mapIt(newClone(it)))
+  var blobRefs = Opt.none(BlobSidecars)
+  if blobsOpt.isSome():
+    let blobs = blobsOpt.get()
+    var workers = newSeq[Future[SendResult]](blobs.len)
+    for i in 0..<blobs.lenu64:
+      let subnet_id = compute_subnet_for_blob_sidecar(i)
+      workers[i] = router[].network.broadcastBlobSidecar(subnet_id, blobs[i])
+    let allres = await allFinished(workers)
+    for i in 0..<allres.len:
+      let res = allres[i]
+      doAssert res.finished()
+      if res.failed():
+        notice "Blob not sent",
+          blob = shortLog(blobs[i]), error = res.error[]
+      else:
+        notice "Blob sent", blob = shortLog(blobs[i])
+    blobRefs = Opt.some(blobs.mapIt(newClone(it)))
   
   var dataColumnRefs = Opt.none(DataColumnSidecars)
   when typeof(blck).kind >= ConsensusFork.Deneb: