-
Notifications
You must be signed in to change notification settings - Fork 721
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
6303ebc
commit 34e21cf
Showing
5 changed files
with
125 additions
and
19 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
93 changes: 93 additions & 0 deletions
93
...ano-testnet/test/cardano-testnet-test/Cardano/Testnet/Test/LedgerEvents/TreasuryGrowth.hs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,93 @@ | ||
| {-# LANGUAGE LambdaCase #-} | ||
| {-# LANGUAGE NamedFieldPuns #-} | ||
| {-# LANGUAGE OverloadedStrings #-} | ||
|
|
||
| module Cardano.Testnet.Test.LedgerEvents.TreasuryGrowth where | ||
|
|
||
| import Cardano.Api hiding (cardanoEra) | ||
| import qualified Cardano.Api as Api | ||
| import Cardano.Api.Ledger (Coin (..)) | ||
|
|
||
| import qualified Cardano.Ledger.Shelley.LedgerState as L | ||
| import Cardano.Testnet as TN | ||
|
|
||
| import Prelude | ||
|
|
||
| import Control.Monad.Trans.State.Strict | ||
| import Data.List (sortOn) | ||
| import Data.Map.Strict (Map) | ||
| import qualified Data.Map.Strict as M | ||
| import Lens.Micro ((^.)) | ||
| import qualified System.Directory as IO | ||
| import System.FilePath ((</>)) | ||
|
|
||
| import qualified Testnet.Property.Utils as H | ||
| import Testnet.Runtime | ||
|
|
||
| import qualified Hedgehog as H | ||
| import qualified Hedgehog.Extras.Stock.IO.Network.Sprocket as H | ||
| import qualified Hedgehog.Extras.Test as H | ||
|
|
||
|
|
||
| prop_check_if_treasury_is_growing :: H.Property | ||
| prop_check_if_treasury_is_growing = H.integrationRetryWorkspace 0 "growing-treasury" $ \tempAbsBasePath' -> do | ||
| -- Start testnet | ||
| conf@Conf{tempAbsPath=TmpAbsolutePath tempAbsPath'} <- TN.mkConf tempAbsBasePath' | ||
|
|
||
| let era = BabbageEra | ||
| options = cardanoDefaultTestnetOptions | ||
| { cardanoEpochLength = 100 | ||
| , cardanoNodeEra = AnyCardanoEra era -- TODO: We should only support the latest era and the upcoming era | ||
| , cardanoActiveSlotsCoeff = 0.3 | ||
| } | ||
|
|
||
| runtime@TestnetRuntime{configurationFile} <- cardanoTestnetDefault options conf | ||
|
|
||
| -- uncomment for epoch state live access | ||
| -- startLedgerNewEpochStateLogging runtime tempAbsBasePath' | ||
|
|
||
| -- Get socketPath | ||
| socketPathAbs <- do | ||
| socketPath' <- H.noteShowM $ H.sprocketArgumentName <$> H.headM (poolSprockets runtime) | ||
| H.noteIO (IO.canonicalizePath $ tempAbsPath' </> socketPath') | ||
|
|
||
| (_condition, treasuryValues) <- H.leftFailM . runExceptT $ | ||
| Api.foldEpochState (File configurationFile) (Api.File socketPathAbs) Api.QuickValidation 10 M.empty handler | ||
| H.note_ $ "treasury for last 5 epochs: " <> show treasuryValues | ||
|
|
||
| let treasuriesSortedByEpoch = | ||
| map snd | ||
| . sortOn fst | ||
| . M.assocs | ||
| $ treasuryValues | ||
|
|
||
| if checkNonDecreasing treasuriesSortedByEpoch && checkHasIncreased treasuriesSortedByEpoch | ||
| then H.success | ||
| else do | ||
| H.note_ "treasury is not growing" | ||
| H.failure | ||
| where | ||
| handler :: AnyNewEpochState -> StateT (Map EpochNo Integer) IO LedgerStateCondition | ||
| handler (AnyNewEpochState _ newEpochState) = do | ||
| let (Coin coin) = newEpochState ^. L.nesEsL . L.esAccountStateL . L.asTreasuryL | ||
| epochNo = newEpochState ^. L.nesELL | ||
| -- handler is executed multiple times per epoch, so we keep only the latest treasury value | ||
| modify $ M.insert epochNo coin | ||
| if epochNo >= EpochNo 5 | ||
| then pure ConditionMet | ||
| else pure ConditionNotMet | ||
|
|
||
| -- | Check if the last element > first element | ||
| checkHasIncreased :: (Ord a) => [a] -> Bool | ||
| checkHasIncreased = \case | ||
| [] -> False | ||
| x1:xs -> case reverse xs of | ||
| [] -> False | ||
| xn:_ -> xn > x1 | ||
|
|
||
| checkNonDecreasing :: (Ord a) => [a] -> Bool | ||
| checkNonDecreasing = \case | ||
| [] -> False | ||
| [_] -> True | ||
| (x:y:xs) -> x <= y && checkNonDecreasing (y:xs) | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters