Add EpochState table

Fixes #1706

Author: kderme

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

@@ -280,8 +280,9 @@ generateNewEpochEvents env details = do
     newEpochEvent lastEpochNo =
       case cenEpochNo lastEpochNo of
         Strict.Nothing -> Just $ LedgerStartAtEpoch currentEpochNo
-        Strict.Just oldEpoch | currentEpochNo == EpochNo (1 + unEpochNo oldEpoch)
-            -> Just $ LedgerNewEpoch currentEpochNo (getSyncStatus details)
+        Strict.Just oldEpoch
+          | currentEpochNo == EpochNo (1 + unEpochNo oldEpoch) ->
+              Just $ LedgerNewEpoch currentEpochNo (getSyncStatus details)
         _ -> Nothing
 
     newCurrentEpochNo :: CurrentEpochNo

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

@@ -22,7 +22,7 @@ import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
 import Cardano.DbSync.Era.Universal.Block (insertBlockUniversal)
 import Cardano.DbSync.Era.Universal.Epoch (hasEpochStartEvent, hasNewEpochEvent)
 import Cardano.DbSync.Era.Universal.Insert.Certificate (mkAdaPots)
-import Cardano.DbSync.Era.Universal.Insert.LedgerEvent (insertBlockLedgerEvents)
+import Cardano.DbSync.Era.Universal.Insert.LedgerEvent (insertNewEpochLedgerEvents)
 import Cardano.DbSync.Error
 import Cardano.DbSync.Fix.EpochStake
 import Cardano.DbSync.Ledger.State (applyBlockAndSnapshot, defaultApplyResult)
@@ -129,7 +129,7 @@ insertBlock syncEnv cblk applyRes firstAfterRollback tookSnapshot = do
   let !details = apSlotDetails applyResult
   let !withinTwoMin = isWithinTwoMin details
   let !withinHalfHour = isWithinHalfHour details
-  insertBlockLedgerEvents syncEnv (sdEpochNo details) (apEvents applyResult)
+  insertNewEpochLedgerEvents syncEnv (sdEpochNo details) (apEvents applyResult)
   let isNewEpochEvent = hasNewEpochEvent (apEvents applyResult)
   let isStartEventOrRollback = hasEpochStartEvent (apEvents applyResult) || firstAfterRollback
   let isMember poolId = Set.member poolId (apPoolsRegistered applyResult)

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

@@ -9,7 +9,6 @@ module Cardano.DbSync.Era.Shelley.Generic.EpochUpdate (
 import Cardano.DbSync.Era.Shelley.Generic.ProtoParams
 import Cardano.DbSync.Types
 import Cardano.DbSync.Util
-import Cardano.Ledger.BaseTypes (StrictMaybe)
 import qualified Cardano.Ledger.BaseTypes as Ledger
 import Cardano.Ledger.Conway.Governance
 import qualified Cardano.Ledger.Shelley.API.Wallet as Shelley
@@ -31,7 +30,7 @@ data NewEpoch = NewEpoch
   , neAdaPots :: !(Maybe Shelley.AdaPots)
   , neEpochUpdate :: !EpochUpdate
   , neDRepState :: !(Maybe (DRepPulsingState StandardConway))
-  , neEnacted :: !(Maybe (GovRelation StrictMaybe StandardConway))
+  , neEnacted :: !(Maybe (ConwayGovState StandardConway))
   }
 
 data EpochUpdate = EpochUpdate

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

@@ -29,7 +29,7 @@ import Cardano.DbSync.Cache (queryOrInsertStakeAddress, queryPoolKeyOrInsert)
 import Cardano.DbSync.Cache.Types (Cache, CacheNew (..))
 import qualified Cardano.DbSync.Era.Shelley.Generic as Generic
 import Cardano.DbSync.Era.Universal.Insert.Certificate (insertPots)
-import Cardano.DbSync.Era.Universal.Insert.GovAction (insertCostModel, insertDrepDistr, updateEnacted, updateExpired, updateRatified)
+import Cardano.DbSync.Era.Universal.Insert.GovAction (insertCostModel, insertDrepDistr, insertUpdateEnacted, updateExpired, updateRatified)
 import Cardano.DbSync.Era.Universal.Insert.Other (toDouble)
 import Cardano.DbSync.Error
 import Cardano.DbSync.Ledger.Event
@@ -77,9 +77,9 @@ insertOnNewEpoch tracer iopts blkId slotNo epochNo newEpoch = do
     lift $ insertDrepDistr epochNo drepSnapshot
     updateRatified epochNo (toList $ rsEnacted ratifyState)
     updateExpired epochNo (toList $ rsExpired ratifyState)
-  whenStrictJust (Generic.neEnacted newEpoch) $ \enactedSt ->
-    when (ioGov iopts) $
-      updateEnacted epochNo enactedSt
+  whenStrictJust (Generic.neEnacted newEpoch) $ \enactedSt -> do
+    when (ioGov iopts) $ do
+      insertUpdateEnacted tracer blkId epochNo enactedSt
   where
     epochUpdate :: Generic.EpochUpdate
     epochUpdate = Generic.neEpochUpdate newEpoch

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

@@ -88,15 +88,15 @@ insertCertificate syncEnv isMember mDeposits blkId txId epochNo slotNo redeemers
     Right (ConwayTxCertGov c) ->
       when (ioGov iopts) $ case c of
         ConwayRegDRep cred coin anchor ->
-          lift $ insertDrepRegistration txId idx cred (Just coin) (strictMaybeToMaybe anchor)
+          lift $ insertDrepRegistration blkId txId idx cred (Just coin) (strictMaybeToMaybe anchor)
         ConwayUnRegDRep cred coin ->
           lift $ insertDrepDeRegistration txId idx cred coin
         ConwayAuthCommitteeHotKey khCold khHot ->
           lift $ insertCommitteeRegistration txId idx khCold khHot
         ConwayResignCommitteeColdKey khCold anchor ->
-          lift $ insertCommitteeDeRegistration txId idx khCold (strictMaybeToMaybe anchor)
+          lift $ insertCommitteeDeRegistration blkId txId idx khCold (strictMaybeToMaybe anchor)
         ConwayUpdateDRep cred anchor ->
-          lift $ insertDrepRegistration txId idx cred Nothing (strictMaybeToMaybe anchor)
+          lift $ insertDrepRegistration blkId txId idx cred Nothing (strictMaybeToMaybe anchor)
   where
     tracer = getTrace syncEnv
     cache = envCache syncEnv
@@ -236,15 +236,16 @@ insertMirCert _tracer cache network txId idx mcert = do
 --------------------------------------------------------------------------------------------
 insertDrepRegistration ::
   (MonadBaseControl IO m, MonadIO m) =>
+  DB.BlockId ->
   DB.TxId ->
   Word16 ->
   Ledger.Credential 'DRepRole StandardCrypto ->
   Maybe Coin ->
   Maybe (Anchor StandardCrypto) ->
   ReaderT SqlBackend m ()
-insertDrepRegistration txId idx cred mcoin mAnchor = do
+insertDrepRegistration blkId txId idx cred mcoin mAnchor = do
   drepId <- insertCredDrepHash cred
-  votingAnchorId <- whenMaybe mAnchor $ insertVotingAnchor txId DB.OtherAnchor
+  votingAnchorId <- whenMaybe mAnchor $ insertVotingAnchor blkId DB.OtherAnchor
   void
     . DB.insertDrepRegistration
     $ DB.DrepRegistration
@@ -295,13 +296,14 @@ insertCommitteeRegistration txId idx khCold cred = do
 
 insertCommitteeDeRegistration ::
   (MonadBaseControl IO m, MonadIO m) =>
+  DB.BlockId ->
   DB.TxId ->
   Word16 ->
   Ledger.Credential 'ColdCommitteeRole StandardCrypto ->
   Maybe (Anchor StandardCrypto) ->
   ReaderT SqlBackend m ()
-insertCommitteeDeRegistration txId idx khCold mAnchor = do
-  votingAnchorId <- whenMaybe mAnchor $ insertVotingAnchor txId DB.OtherAnchor
+insertCommitteeDeRegistration blockId txId idx khCold mAnchor = do
+  votingAnchorId <- whenMaybe mAnchor $ insertVotingAnchor blockId DB.OtherAnchor
   khColdId <- insertCommitteeHash khCold
   void
     . DB.insertCommitteeDeRegistration