fix rollback deletes

Author: Cmdv

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

@@ -96,6 +96,6 @@ prepareRewardsForDeletion trce nw cache epochNo rewards = do
     then pure ([], [], [], [])
     else pure $ unzip4 validParams
 
--- Add this helper function
-areParamsEmpty :: ([a], [b], [c], [d]) -> Bool
-areParamsEmpty (as, bs, cs, ds) = null as || null bs || null cs || null ds
+areParamsEmpty :: ([DB.StakeAddressId], [DB.RewardSource], [Word64], [DB.PoolHashId]) -> Bool
+areParamsEmpty (addrs, types, epochs, pools) =
+  null addrs && null types && null epochs && null pools

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

@@ -261,7 +261,7 @@ insertRewards syncEnv nw earnedEpoch spendableEpoch cache rewardsChunk = do
   DB.ManualDbConstraints {..} <- liftIO $ readTVarIO $ envDbConstraints syncEnv
   let chunckDbRewards = splittRecordsEvery maxBulkSize dbRewards
   -- minimising the bulk inserts into hundred thousand chunks to improve performance
-  forM_ chunckDbRewards $ \rws -> DB.insertBulkRewards dbConstraintEpochStake rws
+  forM_ chunckDbRewards $ \rws -> DB.insertBulkRewards dbConstraintRewards rws
   where
     mkRewards ::
       MonadIO m =>