fourmolize

Author: kderme

cardano-db-sync/src/Cardano/DbSync/Era/Shelley/Generic/StakeDist.hs

@@ -195,7 +195,7 @@ genericCountEpochStake ::
   LedgerState (ShelleyBlock p era) mk ->
   Maybe (Word64, EpochNo)
 genericCountEpochStake lstate =
-    Just (delegationsLen, epoch)
+  Just (delegationsLen, epoch)
   where
     epoch :: EpochNo
     epoch = EpochNo $ 1 + unEpochNo (Shelley.nesEL (Consensus.shelleyLedgerState lstate))
@@ -236,7 +236,7 @@ genericFullStakeSlice ::
   LedgerState (ShelleyBlock p era) mk ->
   StakeSliceRes
 genericFullStakeSlice lstate =
-    Slice stakeSlice True
+  Slice stakeSlice True
   where
     epoch :: EpochNo
     epoch = EpochNo $ 1 + unEpochNo (Shelley.nesEL (Consensus.shelleyLedgerState lstate))

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

@@ -25,11 +25,12 @@ import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
 import Cardano.DbSync.Era.Universal.Adjust (adjustEpochRewards)
 import Cardano.DbSync.Era.Universal.Epoch (insertPoolDepositRefunds, insertProposalRefunds, insertRewardRests, insertRewards)
 import Cardano.DbSync.Era.Universal.Insert.GovAction
-import Cardano.DbSync.Era.Universal.Validate (validateEpochStake, validateEpochRewards)
+import Cardano.DbSync.Era.Universal.Validate (validateEpochRewards, validateEpochStake)
 import Cardano.DbSync.Ledger.Event
 import Cardano.DbSync.Types
 
 import Cardano.DbSync.Error (SyncNodeError)
+import Cardano.DbSync.Ledger.Types
 import Cardano.DbSync.Metrics (setDbEpochSyncDuration, setDbEpochSyncNumber)
 import Control.Concurrent.Class.MonadSTM.Strict (readTVarIO, writeTVar)
 import Control.Monad.Extra (whenJust)
@@ -38,7 +39,6 @@ import qualified Data.Set as Set
 import qualified Data.Text as Text
 import Data.Time (UTCTime, diffUTCTime, getCurrentTime)
 import Text.Printf (printf)
-import Cardano.DbSync.Ledger.Types
 
 --------------------------------------------------------------------------------------------
 -- Insert LedgerEvents

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

@@ -21,26 +21,27 @@ import qualified Data.Set as Set
 import GHC.Err (error)
 
 import qualified Cardano.Db as DB
+import Cardano.DbSync.Api
+import Cardano.DbSync.Api.Types
 import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
+import Cardano.DbSync.Era.Universal.Epoch
 import Cardano.DbSync.Error (SyncNodeError)
 import Cardano.DbSync.Ledger.Event
-import Cardano.DbSync.Types
 import Cardano.DbSync.Ledger.Types
-import qualified Data.Strict.Maybe as Strict
-import Cardano.DbSync.Api.Types
-import Cardano.DbSync.Api
-import Cardano.DbSync.Era.Universal.Epoch
+import Cardano.DbSync.Types
 import Cardano.DbSync.Util.Constraint
+import qualified Data.Strict.Maybe as Strict
 
 validateEpochStake ::
   SyncEnv ->
   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
+  Strict.Just lstate | Just (expectedCount, epoch) <- Generic.countEpochStake (clsState lstate) -> do
+    actualCount <- lift $ DB.queryNormalEpochStakeCount (unEpochNo epoch)
+    if actualCount /= expectedCount
+      then do
         liftIO
           . logWarning tracer
           $ mconcat
@@ -56,18 +57,18 @@ validateEpochStake syncEnv applyRes firstCall = case apOldLedger applyRes of
         insertStakeSlice syncEnv slice
         when firstCall $ validateEpochStake syncEnv applyRes False
       else
-        liftIO $ logInfo tracer
-          $ mconcat
-            [ "Validate Epoch Stake: total entries in epoch "
-            , textShow (unEpochNo epoch)
-            , " are "
-            , textShow actualCount
-            ]
-    _ -> pure ()
+        liftIO $
+          logInfo tracer $
+            mconcat
+              [ "Validate Epoch Stake: total entries in epoch "
+              , textShow (unEpochNo epoch)
+              , " are "
+              , textShow actualCount
+              ]
+  _ -> pure ()
   where
     tracer = getTrace syncEnv
 
-
 validateEpochRewards ::
   Trace IO Text ->
   Network ->