@@ -36,15 +36,6 @@ defmodule AlignedLayerServiceManager do
3636 |> Map . get ( "addresses" )
3737 |> Map . get ( "alignedLayerServiceManager" )
3838
39- @ first_block ( case @ environment do
40- "devnet" -> 0
41- "holesky" -> 1_728_056
42- "mainnet" -> 19_000_000
43- "sepolia" -> 9_062_616
44- "hoodi" -> 1_093_860
45- _ -> raise ( "Invalid environment" )
46- end )
47-
4839 use Ethers.Contract ,
4940 abi_file: "lib/abi/AlignedLayerServiceManager.json" ,
5041 default_address: @ aligned_layer_service_manager_address
@@ -85,7 +76,7 @@ defmodule AlignedLayerServiceManager do
8576 block_number = event |> Map . get ( :block_number )
8677 tx_hash = event |> Map . get ( :transaction_hash )
8778 Logger . info ( "Extracting new batch event info for block #{ block_number } , tx: #{ tx_hash } " )
88-
79+
8980 new_batch = parse_new_batch_event ( event )
9081 Logger . info ( "New batch event parsed: #{ inspect ( new_batch ) } " )
9182
@@ -114,20 +105,20 @@ defmodule AlignedLayerServiceManager do
114105
115106 def is_batch_responded ( merkle_root , fromBlock ) do
116107 Logger . info ( "Checking if batch is responded for merkle_root: #{ merkle_root } , fromBlock: #{ fromBlock } " )
117-
108+
118109 event =
119110 Utils . string_to_bytes32 ( merkle_root )
120111 |> AlignedLayerServiceManager.EventFilters . batch_verified ( )
121112 |> Ethers . get_logs ( fromBlock: fromBlock )
122113
123114 case event do
124- { :error , reason } ->
115+ { :error , reason } ->
125116 Logger . error ( "Error checking batch response for #{ merkle_root } : #{ inspect ( reason ) } " )
126117 { :error , reason }
127- { _ , [ ] } ->
118+ { _ , [ ] } ->
128119 Logger . info ( "Batch #{ merkle_root } not responded yet" )
129120 false
130- { :ok , events } ->
121+ { :ok , events } ->
131122 Logger . info ( "Batch #{ merkle_root } responded, found #{ length ( events ) } verification events" )
132123 true
133124 end
@@ -141,11 +132,11 @@ defmodule AlignedLayerServiceManager do
141132
142133 batch_response =
143134 case was_batch_responded do
144- true ->
135+ true ->
145136 Logger . info ( "Batch #{ created_batch . batchMerkleRoot } was responded, fetching response details" )
146137 fetch_batch_response ( created_batch . batchMerkleRoot , batch_creation . block_number )
147138 # was not verified, fill with nils
148- false ->
139+ false ->
149140 Logger . info ( "Batch #{ created_batch . batchMerkleRoot } was not responded yet" )
150141 % { block_number: nil , transaction_hash: nil , block_timestamp: nil }
151142 end
@@ -204,16 +195,16 @@ defmodule AlignedLayerServiceManager do
204195 end
205196 end
206197
207- def fetch_batch_response ( merkle_root , fromBlock \\ @ first_block ) do
198+ def fetch_batch_response ( merkle_root , fromBlock ) do
208199 Logger . info ( "Fetching batch response for merkle_root: #{ merkle_root } , fromBlock: #{ fromBlock } " )
209200 case get_batch_verified_events ( % { merkle_root: merkle_root , fromBlock: fromBlock } ) do
210- { :ok , batch_verified_info } ->
201+ { :ok , batch_verified_info } ->
211202 Logger . info ( "Successfully fetched batch response for #{ merkle_root } " )
212203 batch_verified_info
213- { :empty , _ } ->
204+ { :empty , _ } ->
214205 Logger . info ( "No batch verified events found for #{ merkle_root } " )
215206 nil
216- { :error , error } ->
207+ { :error , error } ->
217208 Logger . error ( "Error fetching batch response for #{ merkle_root } : #{ error } " )
218209 raise ( "Error fetching batch response: #{ error } " )
219210 end
@@ -226,13 +217,13 @@ defmodule AlignedLayerServiceManager do
226217 |> Ethers . get_logs ( fromBlock: fromBlock )
227218
228219 case event do
229- { :error , reason } ->
220+ { :error , reason } ->
230221 Logger . error ( "Error getting batch verified events for #{ merkle_root } : #{ inspect ( reason ) } " )
231222 { :error , reason }
232- { _ , [ ] } ->
223+ { _ , [ ] } ->
233224 Logger . info ( "No batch verified events found for #{ merkle_root } " )
234225 { :empty , "No task found" }
235- { :ok , events } ->
226+ { :ok , events } ->
236227 Logger . info ( "Found #{ length ( events ) } batch verified events for #{ merkle_root } " )
237228 extract_batch_verified_event_info ( events |> List . first ( ) )
238229 end
@@ -259,11 +250,11 @@ defmodule AlignedLayerServiceManager do
259250 def get_block_timestamp ( block_number ) do
260251 Logger . info ( "Fetching block timestamp for block #{ block_number } " )
261252 case Ethers.Utils . get_block_timestamp ( block_number ) do
262- { :ok , timestamp } ->
253+ { :ok , timestamp } ->
263254 datetime = DateTime . from_unix! ( timestamp )
264255 Logger . info ( "Block #{ block_number } timestamp: #{ datetime } " )
265256 datetime
266- { :error , error } ->
257+ { :error , error } ->
267258 Logger . error ( "Error fetching block timestamp for block #{ block_number } : #{ error } " )
268259 raise ( "Error fetching block timestamp: #{ error } " )
269260 end
0 commit comments