@@ -45,7 +45,6 @@ defmodule AlignedLayerServiceManager do
4545 end
4646
4747 def get_latest_block_number ( ) do
48- Logger . info ( "Fetching latest block number" )
4948 { :ok , num } = Ethers . current_block_number ( )
5049 Logger . info ( "Latest block number: #{ num } " )
5150 num
@@ -104,8 +103,6 @@ defmodule AlignedLayerServiceManager do
104103 end
105104
106105 def is_batch_responded ( merkle_root , fromBlock ) do
107- Logger . info ( "Checking if batch is responded for merkle_root: #{ merkle_root } , fromBlock: #{ fromBlock } " )
108-
109106 event =
110107 Utils . string_to_bytes32 ( merkle_root )
111108 |> AlignedLayerServiceManager.EventFilters . batch_verified ( )
@@ -116,18 +113,15 @@ defmodule AlignedLayerServiceManager do
116113 Logger . error ( "Error checking batch response for #{ merkle_root } : #{ inspect ( reason ) } " )
117114 { :error , reason }
118115 { _ , [ ] } ->
119- Logger . info ( "Batch #{ merkle_root } not responded yet" )
120116 false
121- { :ok , events } ->
122- Logger . info ( "Batch #{ merkle_root } responded, found #{ length ( events ) } verification events" )
117+ { :ok , _events } ->
123118 true
124119 end
125120 end
126121
127122 # for new batches
128123 def extract_batch_response ( { _status , % NewBatchInfo { } = batch_creation } ) do
129124 created_batch = batch_creation . new_batch
130- Logger . info ( "Extracting batch response for new batch: #{ created_batch . batchMerkleRoot } " )
131125 was_batch_responded = is_batch_responded ( created_batch . batchMerkleRoot , batch_creation . block_number )
132126
133127 batch_response =
@@ -162,7 +156,6 @@ defmodule AlignedLayerServiceManager do
162156
163157 # for existing but unverified batches
164158 def extract_batch_response ( % Batches { } = unverified_batch ) do
165- Logger . info ( "Extracting batch response for existing unverified batch: #{ unverified_batch . merkle_root } " )
166159 was_batch_responded = is_batch_responded ( unverified_batch . merkle_root , unverified_batch . submission_block_number )
167160
168161 case was_batch_responded do
@@ -196,7 +189,6 @@ defmodule AlignedLayerServiceManager do
196189 end
197190
198191 def fetch_batch_response ( merkle_root , fromBlock ) do
199- Logger . info ( "Fetching batch response for merkle_root: #{ merkle_root } , fromBlock: #{ fromBlock } " )
200192 case get_batch_verified_events ( % { merkle_root: merkle_root , fromBlock: fromBlock } ) do
201193 { :ok , batch_verified_info } ->
202194 Logger . info ( "Successfully fetched batch response for #{ merkle_root } " )
@@ -211,7 +203,6 @@ defmodule AlignedLayerServiceManager do
211203 end
212204
213205 def get_batch_verified_events ( % { merkle_root: merkle_root , fromBlock: fromBlock } ) do
214- Logger . info ( "Getting batch verified events for merkle_root: #{ merkle_root } , fromBlock: #{ fromBlock } " )
215206 event =
216207 AlignedLayerServiceManager.EventFilters . batch_verified ( Utils . string_to_bytes32 ( merkle_root ) )
217208 |> Ethers . get_logs ( fromBlock: fromBlock )
@@ -230,30 +221,23 @@ defmodule AlignedLayerServiceManager do
230221 end
231222
232223 defp extract_batch_verified_event_info ( event ) do
233- batch_merkle_root = event |> Map . get ( :topics_raw ) |> Enum . at ( 1 )
234- sender_address = event |> Map . get ( :data ) |> Enum . at ( 0 )
235224 block_number = event |> Map . get ( :block_number )
236- tx_hash = event |> Map . get ( :transaction_hash )
237- Logger . info ( "Extracting batch verified event info for block #{ block_number } , tx: #{ tx_hash } , merkle_root: #{ batch_merkle_root } " )
238225
239226 { :ok ,
240227 % BatchVerifiedInfo {
241228 address: event |> Map . get ( :address ) ,
242- block_number: event |> Map . get ( : block_number) ,
243- block_timestamp: get_block_timestamp ( event |> Map . get ( : block_number) ) ,
229+ block_number: block_number ,
230+ block_timestamp: get_block_timestamp ( block_number ) ,
244231 transaction_hash: event |> Map . get ( :transaction_hash ) ,
245- batch_merkle_root: batch_merkle_root ,
246- sender_address: sender_address
232+ batch_merkle_root: event |> Map . get ( :topics_raw ) |> Enum . at ( 1 ) ,
233+ sender_address: event |> Map . get ( :data ) |> Enum . at ( 0 )
247234 } }
248235 end
249236
250237 def get_block_timestamp ( block_number ) do
251- Logger . info ( "Fetching block timestamp for block #{ block_number } " )
252238 case Ethers.Utils . get_block_timestamp ( block_number ) do
253239 { :ok , timestamp } ->
254- datetime = DateTime . from_unix! ( timestamp )
255- Logger . info ( "Block #{ block_number } timestamp: #{ datetime } " )
256- datetime
240+ DateTime . from_unix! ( timestamp )
257241 { :error , error } ->
258242 Logger . error ( "Error fetching block timestamp for block #{ block_number } : #{ error } " )
259243 raise ( "Error fetching block timestamp: #{ error } " )
0 commit comments