File tree 1 file changed +20
-9
lines changed
1 file changed +20
-9
lines changed Original file line number Diff line number Diff line change @@ -1691,15 +1691,26 @@ where
1691
1691
continue ;
1692
1692
}
1693
1693
1694
- blobs. push (
1695
- self . storage_client ( )
1696
- . read_blob ( blob_id)
1697
- . await
1698
- . map_err ( |_| LocalNodeError :: CannotReadLocalBlob {
1699
- chain_id : self . chain_id ,
1700
- blob_id,
1701
- } ) ?,
1702
- ) ;
1694
+ let maybe_blob = {
1695
+ let chain_state_view = self . chain_state_view ( ) . await ?;
1696
+ chain_state_view
1697
+ . manager
1698
+ . get ( )
1699
+ . pending_blobs
1700
+ . get ( & blob_id)
1701
+ . cloned ( )
1702
+ } ;
1703
+
1704
+ if let Some ( blob) = maybe_blob {
1705
+ self . client . local_node . cache_recent_blob ( & blob) . await ;
1706
+ blobs. push ( blob) ;
1707
+ continue ;
1708
+ }
1709
+
1710
+ return Err ( LocalNodeError :: CannotReadLocalBlob {
1711
+ chain_id : self . chain_id ,
1712
+ blob_id,
1713
+ } ) ;
1703
1714
}
1704
1715
Ok ( blobs)
1705
1716
}
You can’t perform that action at this time.
0 commit comments