@@ -174,9 +174,10 @@ impl<T: Provider<Network>> ChunkInterpreter for RpcClient<'_, T> {
174
174
provider : impl Provider < Network > ,
175
175
block_number : u64 ,
176
176
) -> Result < Vec < TxL1Message > > {
177
+ let block_number_hex = format ! ( "0x{:x}" , block_number) ;
177
178
Ok ( provider
178
179
. client ( )
179
- . request :: < _ , Vec < TxL1Message > > ( "scroll_getL1MessagesInBlock" , ( block_number , ) )
180
+ . request :: < _ , Vec < TxL1Message > > ( "scroll_getL1MessagesInBlock" , ( block_number_hex , "synced" ) )
180
181
. await ?)
181
182
}
182
183
@@ -202,7 +203,7 @@ mod tests {
202
203
}
203
204
204
205
#[ test]
205
- #[ ignore = "Requires L2GETH_ENDPOINT environment variable" ]
206
+ // #[ignore = "Requires L2GETH_ENDPOINT environment variable"]
206
207
fn test_try_fetch_block_witness ( ) {
207
208
let config = create_config_from_env ( ) ;
208
209
let client_core = RpcClientCore :: create ( & config) . expect ( "Failed to create RPC client" ) ;
@@ -234,4 +235,18 @@ mod tests {
234
235
235
236
println ! ( "{}" , serde_json:: to_string_pretty( & wit2) . unwrap( ) ) ;
236
237
}
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
+ }
237
252
}
0 commit comments