diff --git a/src/proto_017_PtNairob/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_017_PtNairob/lib_sc_rollup_node/dal_pages_request.ml index a7de9eb2adbd16fe4ea529aea848b1482cb31755..7424e66d0261dbc67ab8cd341120a4e99d607894 100644 --- a/src/proto_017_PtNairob/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_017_PtNairob/lib_sc_rollup_node/dal_pages_request.ml @@ -89,21 +89,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} let storage_invariant_broken published_level index = failwith diff --git a/src/proto_018_Proxford/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_018_Proxford/lib_sc_rollup_node/dal_pages_request.ml index 027bf6eb70ec9897bab2fe7e6da99c4041818c49..ea0386a2f6881f5d6f377e2a9575cf5bc5c55c3b 100644 --- a/src/proto_018_Proxford/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_018_Proxford/lib_sc_rollup_node/dal_pages_request.ml @@ -124,21 +124,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} let storage_invariant_broken published_level index = failwith diff --git a/src/proto_019_PtParisB/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_019_PtParisB/lib_sc_rollup_node/dal_pages_request.ml index 6875d3cf150db2d927b4d9cd577e8be5e399294e..06e643412223b460ee5c5d1c95a7eb51bcdddcbd 100644 --- a/src/proto_019_PtParisB/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_019_PtParisB/lib_sc_rollup_node/dal_pages_request.ml @@ -124,21 +124,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} let storage_invariant_broken published_level index = failwith diff --git a/src/proto_020_PsParisC/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_020_PsParisC/lib_sc_rollup_node/dal_pages_request.ml index 6875d3cf150db2d927b4d9cd577e8be5e399294e..06e643412223b460ee5c5d1c95a7eb51bcdddcbd 100644 --- a/src/proto_020_PsParisC/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_020_PsParisC/lib_sc_rollup_node/dal_pages_request.ml @@ -124,21 +124,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} let storage_invariant_broken published_level index = failwith diff --git a/src/proto_021_PsQuebec/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_021_PsQuebec/lib_sc_rollup_node/dal_pages_request.ml index 6875d3cf150db2d927b4d9cd577e8be5e399294e..06e643412223b460ee5c5d1c95a7eb51bcdddcbd 100644 --- a/src/proto_021_PsQuebec/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_021_PsQuebec/lib_sc_rollup_node/dal_pages_request.ml @@ -124,21 +124,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} let storage_invariant_broken published_level index = failwith diff --git a/src/proto_022_PsRiotum/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_022_PsRiotum/lib_sc_rollup_node/dal_pages_request.ml index 921b7077b47554a2ef23a6b03b3bf8ed289081b1..8c849681ea6220c871e1369c1775d7ed4d8f17d9 100644 --- a/src/proto_022_PsRiotum/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_022_PsRiotum/lib_sc_rollup_node/dal_pages_request.ml @@ -107,21 +107,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Environment.Error_monad.Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} module Slots_statuses_cache = Aches.Vache.Map (Aches.Vache.FIFO_Precise) (Aches.Vache.Strong) diff --git a/src/proto_023_PtSeouLo/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_023_PtSeouLo/lib_sc_rollup_node/dal_pages_request.ml index 921b7077b47554a2ef23a6b03b3bf8ed289081b1..8c849681ea6220c871e1369c1775d7ed4d8f17d9 100644 --- a/src/proto_023_PtSeouLo/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_023_PtSeouLo/lib_sc_rollup_node/dal_pages_request.ml @@ -107,21 +107,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Environment.Error_monad.Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} module Slots_statuses_cache = Aches.Vache.Map (Aches.Vache.FIFO_Precise) (Aches.Vache.Strong) diff --git a/src/proto_024_PsD5wVTJ/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_024_PsD5wVTJ/lib_sc_rollup_node/dal_pages_request.ml index 921b7077b47554a2ef23a6b03b3bf8ed289081b1..8c849681ea6220c871e1369c1775d7ed4d8f17d9 100644 --- a/src/proto_024_PsD5wVTJ/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_024_PsD5wVTJ/lib_sc_rollup_node/dal_pages_request.ml @@ -107,21 +107,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Environment.Error_monad.Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} module Slots_statuses_cache = Aches.Vache.Map (Aches.Vache.FIFO_Precise) (Aches.Vache.Strong) diff --git a/src/proto_alpha/lib_sc_rollup_node/dal_pages_request.ml b/src/proto_alpha/lib_sc_rollup_node/dal_pages_request.ml index 1166b385e8c1c8e79eb025d1ac95774227e2e9cf..d7d8c03b5ffa9cd1c4c16e31f2fbaa65db9c780e 100644 --- a/src/proto_alpha/lib_sc_rollup_node/dal_pages_request.ml +++ b/src/proto_alpha/lib_sc_rollup_node/dal_pages_request.ml @@ -107,21 +107,13 @@ let get_slot_pages = (Dal_node_client.get_slot_pages dal_cctxt) Lwt.return -let download_confirmed_slot_pages ({Node_context.dal_cctxt; _} as node_ctxt) - ~published_level ~index = - let open Environment.Error_monad.Lwt_result_syntax in - let* published_in_block_hash = - Node_context.hash_of_level node_ctxt (Raw_level.to_int32 published_level) - in - let* header = - Node_context.get_slot_header node_ctxt ~published_in_block_hash index - in +let download_confirmed_slot_pages {Node_context.dal_cctxt; _} ~published_level + ~index = let dal_cctxt = WithExceptions.Option.get ~loc:__LOC__ dal_cctxt in (* DAL must be configured for this point to be reached *) - let slot_id : Slot_id.t = - {slot_level = header.id.published_level; slot_index = header.id.index} - in - get_slot_pages dal_cctxt slot_id + get_slot_pages + dal_cctxt + {slot_level = Raw_level.to_int32 published_level; slot_index = index} module Slots_statuses_cache = Aches.Vache.Map (Aches.Vache.FIFO_Precise) (Aches.Vache.Strong)