@@ -174,9 +174,10 @@ impl<T: Provider<Network>> ChunkInterpreter for RpcClient<'_, T> {
174174 provider : impl Provider < Network > ,
175175 block_number : u64 ,
176176 ) -> Result < Vec < TxL1Message > > {
177+ let block_number_hex = format ! ( "0x{:x}" , block_number) ;
177178 Ok ( provider
178179 . client ( )
179- . request :: < _ , Vec < TxL1Message > > ( "scroll_getL1MessagesInBlock" , ( block_number , ) )
180+ . request :: < _ , Vec < TxL1Message > > ( "scroll_getL1MessagesInBlock" , ( block_number_hex , "synced" ) )
180181 . await ?)
181182 }
182183
@@ -202,7 +203,7 @@ mod tests {
202203 }
203204
204205 #[ test]
205- #[ ignore = "Requires L2GETH_ENDPOINT environment variable" ]
206+ // #[ignore = "Requires L2GETH_ENDPOINT environment variable"]
206207 fn test_try_fetch_block_witness ( ) {
207208 let config = create_config_from_env ( ) ;
208209 let client_core = RpcClientCore :: create ( & config) . expect ( "Failed to create RPC client" ) ;
@@ -234,4 +235,18 @@ mod tests {
234235
235236 println ! ( "{}" , serde_json:: to_string_pretty( & wit2) . unwrap( ) ) ;
236237 }
238+
239+ #[ test]
240+ #[ ignore = "Requires L2GETH_ENDPOINT environment variable" ]
241+ fn test_try_fetch_l1_messages ( ) {
242+ let config = create_config_from_env ( ) ;
243+ let client_core = RpcClientCore :: create ( & config) . expect ( "Failed to create RPC client" ) ;
244+ let client = client_core. get_client ( ) ;
245+
246+ let msgs = client
247+ . try_fetch_l1_msgs ( 32 )
248+ . expect ( "should success" ) ;
249+
250+ println ! ( "{}" , serde_json:: to_string_pretty( & msgs) . unwrap( ) ) ;
251+ }
237252}
0 commit comments