Skip to content

Commit 23fbbbe

Browse files
committed
fourmolize
Signed-off-by: Kostas Dermentzis <kostas.dermentzis@iohk.io>
1 parent 2b0d4f3 commit 23fbbbe

File tree

3 files changed

+22
-21
lines changed

3 files changed

+22
-21
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ genericCountEpochStake ::
195195
LedgerState (ShelleyBlock p era) mk ->
196196
Maybe (Word64, EpochNo)
197197
genericCountEpochStake lstate =
198-
Just (delegationsLen, epoch)
198+
Just (delegationsLen, epoch)
199199
where
200200
epoch :: EpochNo
201201
epoch = EpochNo $ 1 + unEpochNo (Shelley.nesEL (Consensus.shelleyLedgerState lstate))
@@ -236,7 +236,7 @@ genericFullStakeSlice ::
236236
LedgerState (ShelleyBlock p era) mk ->
237237
StakeSliceRes
238238
genericFullStakeSlice lstate =
239-
Slice stakeSlice True
239+
Slice stakeSlice True
240240
where
241241
epoch :: EpochNo
242242
epoch = EpochNo $ 1 + unEpochNo (Shelley.nesEL (Consensus.shelleyLedgerState lstate))

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,11 +25,12 @@ import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
2525
import Cardano.DbSync.Era.Universal.Adjust (adjustEpochRewards)
2626
import Cardano.DbSync.Era.Universal.Epoch (insertPoolDepositRefunds, insertProposalRefunds, insertRewardRests, insertRewards)
2727
import Cardano.DbSync.Era.Universal.Insert.GovAction
28-
import Cardano.DbSync.Era.Universal.Validate (validateEpochStake, validateEpochRewards)
28+
import Cardano.DbSync.Era.Universal.Validate (validateEpochRewards, validateEpochStake)
2929
import Cardano.DbSync.Ledger.Event
3030
import Cardano.DbSync.Types
3131

3232
import Cardano.DbSync.Error (SyncNodeError)
33+
import Cardano.DbSync.Ledger.Types
3334
import Cardano.DbSync.Metrics (setDbEpochSyncDuration, setDbEpochSyncNumber)
3435
import Control.Concurrent.Class.MonadSTM.Strict (readTVarIO, writeTVar)
3536
import Control.Monad.Extra (whenJust)
@@ -38,7 +39,6 @@ import qualified Data.Set as Set
3839
import qualified Data.Text as Text
3940
import Data.Time (UTCTime, diffUTCTime, getCurrentTime)
4041
import Text.Printf (printf)
41-
import Cardano.DbSync.Ledger.Types
4242

4343
--------------------------------------------------------------------------------------------
4444
-- Insert LedgerEvents

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

Lines changed: 18 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -21,26 +21,27 @@ import qualified Data.Set as Set
2121
import GHC.Err (error)
2222

2323
import qualified Cardano.Db as DB
24+
import Cardano.DbSync.Api
25+
import Cardano.DbSync.Api.Types
2426
import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
27+
import Cardano.DbSync.Era.Universal.Epoch
2528
import Cardano.DbSync.Error (SyncNodeError)
2629
import Cardano.DbSync.Ledger.Event
27-
import Cardano.DbSync.Types
2830
import Cardano.DbSync.Ledger.Types
29-
import qualified Data.Strict.Maybe as Strict
30-
import Cardano.DbSync.Api.Types
31-
import Cardano.DbSync.Api
32-
import Cardano.DbSync.Era.Universal.Epoch
31+
import Cardano.DbSync.Types
3332
import Cardano.DbSync.Util.Constraint
33+
import qualified Data.Strict.Maybe as Strict
3434

3535
validateEpochStake ::
3636
SyncEnv ->
3737
ApplyResult ->
3838
Bool ->
3939
ExceptT SyncNodeError DB.DbM ()
4040
validateEpochStake syncEnv applyRes firstCall = case apOldLedger applyRes of
41-
Strict.Just lstate | Just (expectedCount, epoch) <- Generic.countEpochStake (clsState lstate) -> do
42-
actualCount <- lift $ DB.queryNormalEpochStakeCount (unEpochNo epoch)
43-
if actualCount /= expectedCount then do
41+
Strict.Just lstate | Just (expectedCount, epoch) <- Generic.countEpochStake (clsState lstate) -> do
42+
actualCount <- lift $ DB.queryNormalEpochStakeCount (unEpochNo epoch)
43+
if actualCount /= expectedCount
44+
then do
4445
liftIO
4546
. logWarning tracer
4647
$ mconcat
@@ -56,18 +57,18 @@ validateEpochStake syncEnv applyRes firstCall = case apOldLedger applyRes of
5657
insertStakeSlice syncEnv slice
5758
when firstCall $ validateEpochStake syncEnv applyRes False
5859
else
59-
liftIO $ logInfo tracer
60-
$ mconcat
61-
[ "Validate Epoch Stake: total entries in epoch "
62-
, textShow (unEpochNo epoch)
63-
, " are "
64-
, textShow actualCount
65-
]
66-
_ -> pure ()
60+
liftIO $
61+
logInfo tracer $
62+
mconcat
63+
[ "Validate Epoch Stake: total entries in epoch "
64+
, textShow (unEpochNo epoch)
65+
, " are "
66+
, textShow actualCount
67+
]
68+
_ -> pure ()
6769
where
6870
tracer = getTrace syncEnv
6971

70-
7172
validateEpochRewards ::
7273
Trace IO Text ->
7374
Network ->

0 commit comments

Comments
 (0)