Fix inserting epoch_stake_progress

Fixes #1620

Author: kderme

cardano-db-sync/CHANGELOG.md

@@ -1,6 +1,7 @@
 # Revision history for cardano-db-sync
 
 ## 13.2.0.0
+* Added a new table `epoch_stake_progress` which indicates when `epoch_stake` is completed
 * Uses the cache for the computation of `epoch` table when following
 * `epoch_stake` is now computed earlier, before the epoch is reached
 * Exception handling and concurrency improved.

cardano-db/src/Cardano/Db/Insert.hs

@@ -113,6 +113,7 @@ import Database.Persist.Class (
   replaceUnique,
  )
 import Database.Persist.EntityDef.Internal (entityDB, entityUniques)
+import Database.Persist.Postgresql (upsertWhere)
 import Database.Persist.Sql (
   OnlyOneUniqueKey,
   PersistRecordBackend,
@@ -352,7 +353,7 @@ insertEpochStakeProgress =
 
 updateSetComplete :: MonadIO m => Word64 -> ReaderT SqlBackend m ()
 updateSetComplete epoch = do
-  updateWhere [EpochStakeProgressEpochNo Database.Persist.==. epoch] [EpochStakeProgressCompleted Database.Persist.=. True]
+  upsertWhere (EpochStakeProgress epoch True) [EpochStakeProgressCompleted Database.Persist.=. True] [EpochStakeProgressEpochNo Database.Persist.==. epoch]
 
 updateGovActionEnacted :: MonadIO m => GovActionProposalId -> Word64 -> ReaderT SqlBackend m ()
 updateGovActionEnacted gaid eNo =

cardano-db/src/Cardano/Db/Schema.hs

@@ -955,6 +955,11 @@ schemaDocs =
       EpochStakeAmount # "The amount (in Lovelace) being staked."
       EpochStakeEpochNo # "The epoch number."
 
+    EpochStakeProgress --^ do
+      "A table which shows when the epoch_stake for an epoch is complete"
+      EpochStakeProgressEpochNo # "The related epoch"
+      EpochStakeProgressCompleted # "True if completed. If not completed the entry won't exist or more rarely be False."
+
     Treasury --^ do
       "A table for payments from the treasury to a StakeAddress. Note: Before protocol version 5.0\
       \ (Alonzo) if more than one payment was made to a stake address in a single epoch, only the\