add block_number

eth.blobs/Makefile

@@ -10,7 +10,7 @@ codegen:
 
 .PHONE: package
 package: build
-	substreams pack -o substreams.spkg substreams.yaml
+	substreams pack substreams.yaml
 
 .PHONY: run
 run: build

eth.blobs/proto/blobs.proto

@@ -9,6 +9,7 @@ message Blobs { repeated Blob blobs = 1; }
 message Blob {
   uint64 slot = 1;
   google.protobuf.Timestamp timestamp = 2;
+  uint64 block_number = 3;
   uint32 index = 11;
   uint32 length = 12;
   bytes data = 13;

eth.blobs/src/lib.rs

@@ -9,10 +9,11 @@ fn map_blobs(blk: BeaconBlock) -> Result<Blobs, substreams::errors::Error> {
         Deneb(body) => body
             .embedded_blobs
             .into_iter()
-            .inspect(|_| substreams::log::info!("blk.timestamp: {}", blk.timestamp.clone().unwrap_or_default()))
+            // .inspect(|_| substreams::log::info!("blk.timestamp: {}", blk.timestamp.clone().unwrap_or_default()))
             .map(|b| Blob {
                 slot: blk.slot,
-                timestamp: blk.timestamp.clone(),
+                timestamp: body.execution_payload.as_ref().cloned().unwrap_or_default().timestamp, // blk.timestamp.clone(),
+                block_number: body.execution_payload.as_ref().cloned().unwrap_or_default().block_number,
                 index: b.index as u32,
                 length: b.blob.len() as u32,
                 data: b.blob,

eth.blobs/src/pb/eth.blobs.v1.rs

@@ -12,6 +12,8 @@ pub struct Blob {
     pub slot: u64,
     #[prost(message, optional, tag="2")]
     pub timestamp: ::core::option::Option<::prost_types::Timestamp>,
+    #[prost(uint64, tag="3")]
+    pub block_number: u64,
     #[prost(uint32, tag="11")]
     pub index: u32,
     #[prost(uint32, tag="12")]