Revalidate epoch_stake after fixing

Author: kderme

cardano-db-sync/src/Cardano/DbSync/Era/Universal/Insert/LedgerEvent.hs

@@ -74,7 +74,7 @@ insertNewEpochLedgerEvents syncEnv applyRes currentEpochNo@(EpochNo curEpoch) =
     handler ev =
       case ev of
         LedgerNewEpoch en ss -> do
-          validateEpochStake syncEnv applyRes
+          validateEpochStake syncEnv applyRes True
           databaseCacheSize <- lift DB.queryStatementCacheSize
           liftIO . logInfo tracer $ "Database Statement Cache size is " <> textShow databaseCacheSize
           currentTime <- liftIO getCurrentTime

cardano-db-sync/src/Cardano/DbSync/Era/Universal/Validate.hs

@@ -34,8 +34,10 @@ import Cardano.DbSync.Util.Constraint
 
 validateEpochStake ::
   SyncEnv ->
-  ApplyResult -> ExceptT SyncNodeError DB.DbM ()
-validateEpochStake syncEnv applyRes = case apOldLedger applyRes of
+  ApplyResult ->
+  Bool ->
+  ExceptT SyncNodeError DB.DbM ()
+validateEpochStake syncEnv applyRes firstCall = case apOldLedger applyRes of
     Strict.Just lstate | Just (expectedCount, epoch) <- Generic.countEpochStake (clsState lstate) -> do
       actualCount <- lift $ DB.queryNormalEpochStakeCount (unEpochNo epoch)
       if actualCount /= expectedCount then do
@@ -52,6 +54,7 @@ validateEpochStake syncEnv applyRes = case apOldLedger applyRes of
         let slice = Generic.fullEpochStake (clsState lstate)
         addStakeConstraintsIfNotExist syncEnv tracer
         insertStakeSlice syncEnv slice
+        when firstCall $ validateEpochStake syncEnv applyRes False
       else
         liftIO $ logInfo tracer
           $ mconcat