Insert rest offchain data tables

Author: kderme

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

@@ -33,6 +33,7 @@ import Control.Concurrent.Class.MonadSTM.Strict (
   isEmptyTBQueue,
   writeTBQueue,
  )
+import Control.Monad.Extra (whenJust)
 import Control.Monad.Trans.Control (MonadBaseControl)
 import Data.Time.Clock.POSIX (POSIXTime)
 import qualified Data.Time.Clock.POSIX as Time
@@ -139,9 +140,12 @@ insertOffChainVoteResults trce resultQueue = do
   where
     insert :: (MonadBaseControl IO m, MonadIO m) => OffChainVoteResult -> ReaderT SqlBackend m ()
     insert = \case
-      OffChainVoteResultMetadata md _ _ _ -> do
-        _ocvdId <- DB.insertOffChainVoteData md
-        pure ()
+      OffChainVoteResultMetadata md accessors -> do
+        mocvdId <- DB.insertOffChainVoteData md
+        whenJust mocvdId $ \ocvdId -> do
+          DB.insertOffChainVoteAuthors $ offChainVoteAuthors accessors ocvdId
+          DB.insertOffChainVoteReference $ offChainVoteReferences accessors ocvdId
+          DB.insertOffChainVoteExternalUpdate $ offChainVoteExternalUpdates accessors ocvdId
       OffChainVoteResultError fe -> void $ DB.insertOffChainVoteFetchError fe
 
     isFetchError :: OffChainVoteResult -> Bool
@@ -285,7 +289,7 @@ fetchOffChainVoteData _tracer manager time oVoteWorkQ =
             referencesF ocvdId = map (mkReference ocvdId) $ mListToList $ Vote.references minimalBody
             externalUpdatesF ocvdId = map (mkexternalUpdates ocvdId) $ mListToList $ Vote.externalUpdates minimalBody
            in
-            OffChainVoteResultMetadata vdt authorsF referencesF externalUpdatesF
+            OffChainVoteResultMetadata vdt (OffChainVoteAccessors authorsF referencesF externalUpdatesF)
         Left err ->
           OffChainVoteResultError $
             DB.OffChainVoteFetchError

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

@@ -14,6 +14,7 @@ module Cardano.DbSync.Types (
   EpochSlot (..),
   OffChainPoolResult (..),
   OffChainVoteResult (..),
+  OffChainVoteAccessors (..),
   OffChainUrlType (..),
   OffChainFetchError (..),
   SlotDetails (..),
@@ -144,13 +145,15 @@ data OffChainPoolResult
   | OffChainPoolResultError !OffChainPoolFetchError
 
 data OffChainVoteResult
-  = OffChainVoteResultMetadata
-      !OffChainVoteData
-      (DB.OffChainVoteDataId -> [OffChainVoteAuthor])
-      (DB.OffChainVoteDataId -> [OffChainVoteReference])
-      (DB.OffChainVoteDataId -> [OffChainVoteExternalUpdate])
+  = OffChainVoteResultMetadata !OffChainVoteData !OffChainVoteAccessors
   | OffChainVoteResultError !OffChainVoteFetchError
 
+data OffChainVoteAccessors = OffChainVoteAccessors
+  { offChainVoteAuthors :: DB.OffChainVoteDataId -> [OffChainVoteAuthor]
+  , offChainVoteReferences :: DB.OffChainVoteDataId -> [OffChainVoteReference]
+  , offChainVoteExternalUpdates :: DB.OffChainVoteDataId -> [OffChainVoteExternalUpdate]
+  }
+
 data OffChainPoolWorkQueue = OffChainPoolWorkQueue
   { oPoolWqHashId :: !PoolHashId
   , oPoolWqReferenceId :: !PoolMetadataRefId

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

@@ -56,6 +56,9 @@ module Cardano.Db.Insert (
   insertCheckOffChainPoolData,
   insertCheckOffChainPoolFetchError,
   insertOffChainVoteData,
+  insertOffChainVoteAuthors,
+  insertOffChainVoteReference,
+  insertOffChainVoteExternalUpdate,
   insertOffChainVoteFetchError,
   insertReservedPoolTicker,
   insertDelistedPool,
@@ -326,10 +329,21 @@ insertCheckOffChainPoolFetchError pofe = do
   foundMeta <- existsPoolMetadataRefId (offChainPoolFetchErrorPmrId pofe)
   when (foundPool && foundMeta) . void $ insertCheckUnique "OffChainPoolFetchError" pofe
 
-insertOffChainVoteData :: (MonadBaseControl IO m, MonadIO m) => OffChainVoteData -> ReaderT SqlBackend m ()
+insertOffChainVoteData :: (MonadBaseControl IO m, MonadIO m) => OffChainVoteData -> ReaderT SqlBackend m (Maybe OffChainVoteDataId)
 insertOffChainVoteData ocvd = do
   foundVotingAnchor <- existsVotingAnchorId (offChainVoteDataVotingAnchorId ocvd)
-  when foundVotingAnchor . void $ insertCheckUnique "OffChainVoteData" ocvd
+  if foundVotingAnchor
+    then Just <$> insertCheckUnique "OffChainVoteData" ocvd
+    else pure Nothing
+
+insertOffChainVoteAuthors :: (MonadBaseControl IO m, MonadIO m) => [OffChainVoteAuthor] -> ReaderT SqlBackend m ()
+insertOffChainVoteAuthors = void . insertMany' "OffChainVoteAuthor"
+
+insertOffChainVoteReference :: (MonadBaseControl IO m, MonadIO m) => [OffChainVoteReference] -> ReaderT SqlBackend m ()
+insertOffChainVoteReference = void . insertMany' "OffChainVoteReference"
+
+insertOffChainVoteExternalUpdate :: (MonadBaseControl IO m, MonadIO m) => [OffChainVoteExternalUpdate] -> ReaderT SqlBackend m ()
+insertOffChainVoteExternalUpdate = void . insertMany' "OffChainVoteExternalUpdate"
 
 insertOffChainVoteFetchError :: (MonadBaseControl IO m, MonadIO m) => OffChainVoteFetchError -> ReaderT SqlBackend m ()
 insertOffChainVoteFetchError ocvfe = do