@@ -424,3 +424,31 @@ func TestReconciliationFailedToCommit(t *testing.T) {
424
424
assert .Error (t , err )
425
425
assert .Contains (t , err .Error (), "failed to commit" )
426
426
}
427
+
428
+ func TestFailuresWhileReconcilingMissingPvtData (t * testing.T ) {
429
+ committer := & mocks.Committer {}
430
+ fetcher := & mocks.ReconciliationFetcher {}
431
+ committer .On ("GetMissingPvtDataTracker" ).Return (nil , errors .New ("failed to obtain missing pvt data tracker" ))
432
+
433
+ r := NewReconciler (committer , fetcher , & ReconcilerConfig {sleepInterval : time .Millisecond * 100 , batchSize : 1 , IsEnabled : true })
434
+ err := r .reconcile ()
435
+ assert .Error (t , err )
436
+ assert .Contains (t , "failed to obtain missing pvt data tracker" , err .Error ())
437
+
438
+ committer .Mock = mock.Mock {}
439
+ committer .On ("GetMissingPvtDataTracker" ).Return (nil , nil )
440
+ r = NewReconciler (committer , fetcher , & ReconcilerConfig {sleepInterval : time .Millisecond * 100 , batchSize : 1 , IsEnabled : true })
441
+ err = r .reconcile ()
442
+ assert .Error (t , err )
443
+ assert .Contains (t , "got nil as MissingPvtDataTracker, exiting..." , err .Error ())
444
+
445
+ missingPvtDataTracker := & mocks.MissingPvtDataTracker {}
446
+ missingPvtDataTracker .On ("GetMissingPvtDataInfoForMostRecentBlocks" , mock .Anything ).Return (nil , errors .New ("failed get missing pvt data for recent blocks" ))
447
+
448
+ committer .Mock = mock.Mock {}
449
+ committer .On ("GetMissingPvtDataTracker" ).Return (missingPvtDataTracker , nil )
450
+ r = NewReconciler (committer , fetcher , & ReconcilerConfig {sleepInterval : time .Millisecond * 100 , batchSize : 1 , IsEnabled : true })
451
+ err = r .reconcile ()
452
+ assert .Error (t , err )
453
+ assert .Contains (t , "failed get missing pvt data for recent blocks" , err .Error ())
454
+ }
0 commit comments