Publish and save blobs

beacon-chain/rpc/endpoints.go

@@ -465,6 +465,7 @@ func (s *Service) beaconEndpoints(
 		OperationNotifier:             s.cfg.OperationNotifier,
 		Broadcaster:                   s.cfg.Broadcaster,
 		BlockReceiver:                 s.cfg.BlockReceiver,
+		BlobReceiver:                  s.cfg.BlobReceiver,
 		StateGenService:               s.cfg.StateGen,
 		Stater:                        stater,
 		Blocker:                       blocker,

beacon-chain/rpc/eth/beacon/handlers.go

@@ -1584,3 +1584,41 @@ func (s *Server) broadcastSeenBlockSidecars(
 	}
 	return nil
 }
+
+func (s *Server) PublishBlobs(w http.ResponseWriter, r *http.Request) {
+	ctx, span := trace.StartSpan(r.Context(), "beacon.PublishBlobs")
+	defer span.End()
+	if shared.IsSyncing(r.Context(), w, s.SyncChecker, s.HeadFetcher, s.TimeFetcher, s.OptimisticModeFetcher) {
+		return
+	}
+
+	body, err := io.ReadAll(r.Body)
+	if err != nil {
+		httputil.HandleError(w, "Could not read request body", http.StatusInternalServerError)
+		return
+	}
+
+	blobSidecars := &eth.BlobSidecars{}
+	if err := blobSidecars.UnmarshalSSZ(body); err != nil {
+		httputil.HandleError(w, "Could not unmarshal blob sidecars", http.StatusBadRequest)
+		return
+	}
+
+	for _, blobSidecar := range blobSidecars.Sidecars {
+		readOnlySc, err := blocks.NewROBlobWithRoot(blobSidecar, [32]byte{}) // TODO: replace [32]byte{} with beacon root
+		if err != nil {
+			http.Error(w, "Could not create read-only blob", http.StatusInternalServerError)
+			return
+		}
+
+		verifiedBlob := blocks.NewVerifiedROBlob(readOnlySc)
+		if err := s.BlobReceiver.ReceiveBlob(ctx, verifiedBlob); err != nil {
+			http.Error(w, "Could not receive blob", http.StatusInternalServerError)
+			return
+		}
+
+		if err := s.Broadcaster.BroadcastBlob(ctx, blobSidecar.Index, blobSidecar); err != nil {
+			log.WithError(err).Error("Failed to broadcast blob")
+		}
+	}
+}

beacon-chain/rpc/eth/beacon/server.go

@@ -48,4 +48,5 @@ type Server struct {
 	BLSChangesPool                blstoexec.PoolManager
 	ForkchoiceFetcher             blockchain.ForkchoiceFetcher
 	CoreService                   *core.Service
+	BlobReceiver                  blockchain.BlobReceiver
 }