@@ -288,20 +288,15 @@ mod tests {
288
288
#[ tokio:: test]
289
289
async fn fail_if_no_file_in_folder ( ) {
290
290
let immutable_db = db_builder ( "fail_if_no_file_in_folder" ) . build ( ) ;
291
- let digester =
292
- CardanoImmutableDigester :: new ( "devnet" . to_string ( ) , None , TestLogger :: stdout ( ) ) ;
293
- let beacon = CardanoDbBeacon :: new ( 1 , 1 ) ;
294
291
295
- let result = digester
296
- . compute_digest ( & immutable_db. dir , & beacon)
297
- . await
298
- . expect_err ( "compute_digest should have failed" ) ;
292
+ let result = list_immutable_files_to_process ( & immutable_db. dir , 1 )
293
+ . expect_err ( "list_immutable_files_to_process should have failed" ) ;
299
294
300
295
assert_eq ! (
301
296
format!(
302
297
"{:?}" ,
303
298
ImmutableDigesterError :: NotEnoughImmutable {
304
- expected_number: beacon . immutable_file_number ,
299
+ expected_number: 1 ,
305
300
found_number: None ,
306
301
db_dir: immutable_db. dir,
307
302
}
@@ -315,35 +310,24 @@ mod tests {
315
310
let immutable_db = db_builder ( "fail_if_no_immutable_exist" )
316
311
. with_non_immutables ( & [ "not_immutable" ] )
317
312
. build ( ) ;
318
- let digester =
319
- CardanoImmutableDigester :: new ( "devnet" . to_string ( ) , None , TestLogger :: stdout ( ) ) ;
320
- let beacon = CardanoDbBeacon :: new ( 1 , 1 ) ;
321
313
322
- assert ! ( digester
323
- . compute_digest( & immutable_db. dir, & beacon)
324
- . await
325
- . is_err( ) ) ;
314
+ assert ! ( list_immutable_files_to_process( & immutable_db. dir, 1 ) . is_err( ) ) ;
326
315
}
327
316
328
317
#[ tokio:: test]
329
318
async fn fail_if_theres_only_the_uncompleted_immutable_trio ( ) {
330
319
let immutable_db = db_builder ( "fail_if_theres_only_the_uncompleted_immutable_trio" )
331
320
. append_immutable_trio ( )
332
321
. build ( ) ;
333
- let digester =
334
- CardanoImmutableDigester :: new ( "devnet" . to_string ( ) , None , TestLogger :: stdout ( ) ) ;
335
- let beacon = CardanoDbBeacon :: new ( 1 , 1 ) ;
336
322
337
- let result = digester
338
- . compute_digest ( & immutable_db. dir , & beacon)
339
- . await
340
- . expect_err ( "compute_digest should've failed" ) ;
323
+ let result = list_immutable_files_to_process ( & immutable_db. dir , 1 )
324
+ . expect_err ( "list_immutable_files_to_process should've failed" ) ;
341
325
342
326
assert_eq ! (
343
327
format!(
344
328
"{:?}" ,
345
329
ImmutableDigesterError :: NotEnoughImmutable {
346
- expected_number: beacon . immutable_file_number ,
330
+ expected_number: 1 ,
347
331
found_number: None ,
348
332
db_dir: immutable_db. dir,
349
333
}
@@ -358,20 +342,15 @@ mod tests {
358
342
. with_immutables ( & [ 1 , 2 , 3 , 4 , 5 ] )
359
343
. append_immutable_trio ( )
360
344
. build ( ) ;
361
- let digester =
362
- CardanoImmutableDigester :: new ( "devnet" . to_string ( ) , None , TestLogger :: stdout ( ) ) ;
363
- let beacon = CardanoDbBeacon :: new ( 1 , 10 ) ;
364
345
365
- let result = digester
366
- . compute_digest ( & immutable_db. dir , & beacon)
367
- . await
368
- . expect_err ( "compute_digest should've failed" ) ;
346
+ let result = list_immutable_files_to_process ( & immutable_db. dir , 10 )
347
+ . expect_err ( "list_immutable_files_to_process should've failed" ) ;
369
348
370
349
assert_eq ! (
371
350
format!(
372
351
"{:?}" ,
373
352
ImmutableDigesterError :: NotEnoughImmutable {
374
- expected_number: beacon . immutable_file_number ,
353
+ expected_number: 10 ,
375
354
found_number: Some ( 5 ) ,
376
355
db_dir: immutable_db. dir,
377
356
}
0 commit comments