fourmolize

Author: kderme

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

@@ -80,20 +80,20 @@ updateEpochStart syncEnv cache slotDetails isNewEpochEvent isBoundaryBlock = do
   let curEpochNo = unEpochNo $ sdEpochNo slotDetails
 
   if
-    -- The tip has been reached so now replace/update the epoch every block.
-    | getSyncStatus slotDetails == SyncFollowing ->
-        handleEpochWhenFollowing syncEnv cache mLastMapEpochFromCache mEpochBlockDiff curEpochNo
-    -- When syncing we check if current block is the first block in an epoch.
-    -- If so then it's time to put the previous epoch into the DB.
-    | isNewEpochEvent ->
-        updateEpochWhenSyncing syncEnv cache mEpochBlockDiff mLastMapEpochFromCache curEpochNo isBoundaryBlock
-    -- we're syncing and the epochNo are the same so we just update the cache until above check passes.
-    | otherwise ->
-        handleEpochCachingWhenSyncing
-          syncEnv
-          cache
-          mLastMapEpochFromCache
-          mEpochBlockDiff
+      -- The tip has been reached so now replace/update the epoch every block.
+      | getSyncStatus slotDetails == SyncFollowing ->
+          handleEpochWhenFollowing syncEnv cache mLastMapEpochFromCache mEpochBlockDiff curEpochNo
+      -- When syncing we check if current block is the first block in an epoch.
+      -- If so then it's time to put the previous epoch into the DB.
+      | isNewEpochEvent ->
+          updateEpochWhenSyncing syncEnv cache mEpochBlockDiff mLastMapEpochFromCache curEpochNo isBoundaryBlock
+      -- we're syncing and the epochNo are the same so we just update the cache until above check passes.
+      | otherwise ->
+          handleEpochCachingWhenSyncing
+            syncEnv
+            cache
+            mLastMapEpochFromCache
+            mEpochBlockDiff
 
 -----------------------------------------------------------------------------------------------------
 -- When Following

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 ->

cardano-db-sync/src/Cardano/DbSync/OffChain/Http.hs

@@ -174,15 +174,15 @@ httpGetBytes manager request bytesToRead maxBytes url =
                 ( "application/json"
                     `BS.isInfixOf` ct
                     || "application/ld+json"
-                      `BS.isInfixOf` ct
+                    `BS.isInfixOf` ct
                     || "text/plain"
-                      `BS.isInfixOf` ct
+                    `BS.isInfixOf` ct
                     || "binary/octet-stream"
-                      `BS.isInfixOf` ct
+                    `BS.isInfixOf` ct
                     || "application/octet-stream"
-                      `BS.isInfixOf` ct
+                    `BS.isInfixOf` ct
                     || "application/binary"
-                      `BS.isInfixOf` ct
+                    `BS.isInfixOf` ct
                 )
                 . left
                 $ OCFErrBadContentType url (Text.decodeLatin1 ct)

cardano-db-tool/src/Cardano/DbTool/Validate/AdaPots.hs

@@ -21,10 +21,10 @@ validateSumAdaPots = do
   let uniqueCount = List.length $ List.nubOrd (map accSumAdaPots xs)
 
   if
-    | uniqueCount == 0 -> error $ redText "No AdaPots entries found"
-    | length xs == 1 -> putStrLn $ greenText "ok (but only one AdaPots entry found)"
-    | uniqueCount == 1 -> putStrLn $ greenText "ok"
-    | otherwise -> error $ redText (show uniqueCount ++ " unique AdaPots sums (should be 1)")
+      | uniqueCount == 0 -> error $ redText "No AdaPots entries found"
+      | length xs == 1 -> putStrLn $ greenText "ok (but only one AdaPots entry found)"
+      | uniqueCount == 1 -> putStrLn $ greenText "ok"
+      | otherwise -> error $ redText (show uniqueCount ++ " unique AdaPots sums (should be 1)")
 
 -- -----------------------------------------------------------------------------