Skip to content

Commit e1e6a14

Browse files
CmdvCmdv
committed
error with variant in MinIds fixed
1 parent 900bb76 commit e1e6a14

File tree

9 files changed

+104
-63
lines changed

9 files changed

+104
-63
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -339,7 +339,7 @@ mkSyncEnv metricSetters trce dbEnv syncOptions protoInfo nw nwMagic systemStart
339339
oarq <- newTBQueueIO 1000
340340
epochVar <- newTVarIO initCurrentEpochNo
341341
epochStatistics <- initEpochStatistics
342-
dbIsolationStateVar <- newTVarIO DB.SyncLagging -- For database transaction isolation optimisation
342+
dbIsolationStateVar <- newTVarIO DB.SyncLagging -- For database transaction isolation optimisation
343343
ledgerEnvType <-
344344
case (enpMaybeLedgerStateDir syncNP, hasLedger' syncNodeConfigFromFile) of
345345
(Just dir, True) ->

‎cardano-db-sync/src/Cardano/DbSync/Database.hs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ runDbThread syncEnv queue = do
8383
updateBlockMetrics :: IO ()
8484
updateBlockMetrics = do
8585
let metricsSetters = envMetricSetters syncEnv
86-
void $ async $ DB.runDbDirectLogged (fromMaybe mempty $ DB.dbTracer $ envDbEnv syncEnv) (envDbEnv syncEnv) $ do
87-
mBlock <- DB.queryLatestBlock
86+
void $ async $ do
87+
mBlock <- DB.runDbPoolLogged (fromMaybe mempty $ DB.dbTracer $ envDbEnv syncEnv) (envDbEnv syncEnv) DB.queryLatestBlock
8888
liftIO $ whenJust mBlock $ \block -> do
8989
let blockNo = BlockNo $ fromMaybe 0 $ DB.blockBlockNo block
9090
slotNo = SlotNo $ fromMaybe 0 $ DB.blockSlotNo block

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -251,8 +251,8 @@ determineIsolationLevel :: SyncEnv -> IO (Maybe DB.IsolationLevel)
251251
determineIsolationLevel syncEnv = do
252252
syncState <- readTVarIO (envDbIsolationState syncEnv)
253253
pure $ case syncState of
254-
DB.SyncLagging -> Just DB.ReadCommitted -- Syncing: use ReadCommitted for performance
255-
DB.SyncFollowing -> Nothing -- Following: use default RepeatableRead for consistency
254+
DB.SyncLagging -> Just DB.ReadCommitted -- Syncing: use ReadCommitted for performance
255+
DB.SyncFollowing -> Nothing -- Following: use default RepeatableRead for consistency
256256

257257
isWithinTwoMin :: SlotDetails -> Bool
258258
isWithinTwoMin sd = isSyncedWithinSeconds sd 120 == SyncFollowing

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,6 @@ insertBlockGroupedData ::
9797
insertBlockGroupedData syncEnv grouped = do
9898
disInOut <- liftIO $ getDisableInOutState syncEnv
9999

100-
-- Parallel preparation of independent data
101100
-- Parallel preparation of independent data
102101
(preparedTxIn, preparedMetadata, preparedMint, txOutChunks) <- liftIO $ do
103102
a1 <- async $ pure $ prepareTxInProcessing syncEnv grouped
@@ -200,7 +199,8 @@ resolveTxInputs syncEnv hasConsumed needsValue groupedOutputs txIn = do
200199
case eTxId of
201200
Right txId -> do
202201
-- Now get the TxOutId separately
203-
eTxOutId <- lift $ DB.resolveInputTxOutIdFromTxId txId (Generic.txInIndex txIn)
202+
let txOutVariantType = getTxOutVariantType syncEnv
203+
eTxOutId <- lift $ DB.resolveInputTxOutIdFromTxId txOutVariantType txId (Generic.txInIndex txIn)
204204
case eTxOutId of
205205
Right txOutId -> pure $ Right $ convertFoundTxOutId (txId, txOutId)
206206
Left err -> pure $ Left err
@@ -240,7 +240,6 @@ resolveTxInputs syncEnv hasConsumed needsValue groupedOutputs txIn = do
240240
DB.VCTxOutW cTxOut -> (txIn, VC.txOutCoreTxId cTxOut, Left txIn, Nothing)
241241
DB.VATxOutW vTxOut _ -> (txIn, VA.txOutAddressTxId vTxOut, Left txIn, Nothing)
242242

243-
244243
resolveRemainingInputs ::
245244
[ExtendedTxIn] ->
246245
[(DB.TxOutIdW, ExtendedTxOut)] ->

‎cardano-db/src/Cardano/Db/Run.hs

Lines changed: 33 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ runDbTransLogged ::
5858
MonadUnliftIO m =>
5959
Trace IO Text ->
6060
DbEnv ->
61-
Maybe IsolationLevel -> -- Optional isolation level
61+
Maybe IsolationLevel -> -- Optional isolation level
6262
DbM a ->
6363
m a
6464
runDbTransLogged tracer dbEnv mIsolationLevel action = do
@@ -90,7 +90,7 @@ runDbTransLogged tracer dbEnv mIsolationLevel action = do
9090
runDbTransSilent ::
9191
MonadUnliftIO m =>
9292
DbEnv ->
93-
Maybe IsolationLevel -> -- Optional isolation level
93+
Maybe IsolationLevel -> -- Optional isolation level
9494
DbM a ->
9595
m a
9696
runDbTransSilent dbEnv mIsolationLevel action = do
@@ -170,7 +170,7 @@ runDbPoolTransLogged ::
170170
MonadUnliftIO m =>
171171
Trace IO Text ->
172172
DbEnv ->
173-
Maybe IsolationLevel -> -- Optional isolation level
173+
Maybe IsolationLevel -> -- Optional isolation level
174174
DbM a ->
175175
m a
176176
runDbPoolTransLogged tracer dbEnv mIsolationLevel action = do
@@ -198,6 +198,36 @@ runDbPoolTransLogged tracer dbEnv mIsolationLevel action = do
198198
HsqlS.statement () commitTransactionStmt
199199
pure value
200200

201+
runDbPoolLogged ::
202+
MonadUnliftIO m =>
203+
Trace IO Text ->
204+
DbEnv ->
205+
DbM a ->
206+
m a
207+
runDbPoolLogged tracer dbEnv action = do
208+
case dbPoolConnection dbEnv of
209+
Nothing -> throwIO $ DbSessionError mkDbCallStack "No connection pool available in DbEnv"
210+
Just pool -> do
211+
runIohkLogging tracer $ do
212+
liftIO $ withResource pool $ \conn -> do
213+
result <- HsqlS.run (transactionSession conn) conn
214+
case result of
215+
Left sessionErr -> throwIO $ DbSessionError mkDbCallStack ("Pool transaction error: " <> formatSessionError sessionErr)
216+
Right dbResult -> pure dbResult
217+
where
218+
transactionSession conn = do
219+
HsqlS.statement () (beginTransactionStmt RepeatableRead)
220+
result <- liftIO $ try @SomeException $ do
221+
let tempDbEnv = createDbEnv conn (dbPoolConnection dbEnv) (dbTracer dbEnv)
222+
runReaderT (runDbM action) tempDbEnv
223+
case result of
224+
Left err -> do
225+
HsqlS.statement () rollbackTransactionStmt
226+
liftIO $ throwIO err
227+
Right value -> do
228+
HsqlS.statement () commitTransactionStmt
229+
pure value
230+
201231
-- | External service database runner with error handling
202232
--
203233
-- Designed for external services (like SMASH server) that manage their own connection pools.

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

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,9 +45,15 @@ newtype TxId = TxId {getTxId :: Int64}
4545
newtype TxMetadataId = TxMetadataId {getTxMetadataId :: Int64}
4646
deriving (Eq, Show, Ord)
4747

48+
-----------------------------------------------------------------------------------------------------------------------------------
4849
newtype TxInId = TxInId {getTxInId :: Int64}
4950
deriving (Eq, Show, Ord)
5051

52+
instance Read TxInId where
53+
readsPrec p s = [(TxInId x, r) | (x, r) <- readsPrec p s]
54+
55+
-----------------------------------------------------------------------------------------------------------------------------------
56+
5157
newtype CollateralTxInId = CollateralTxInId {getCollateralTxInId :: Int64}
5258
deriving (Eq, Show, Ord)
5359

@@ -97,13 +103,26 @@ newtype ExtraMigrationsId = ExtraMigrationsId {getExtraMigrationsId :: Int64}
97103
-- VARIANTS
98104
-----------------------------------------------------------------------------------------------------------------------------------
99105

106+
-----------------------------------------------------------------------------------------------------------------------------------
107+
100108
-- | TxOut variants
101109
newtype TxOutCoreId = TxOutCoreId {getTxOutCoreId :: Int64}
102110
deriving (Eq, Ord, Show)
103111

112+
instance Read TxOutCoreId where
113+
readsPrec p s = [(TxOutCoreId x, r) | (x, r) <- readsPrec p s]
114+
115+
-----------------------------------------------------------------------------------------------------------------------------------
116+
117+
-----------------------------------------------------------------------------------------------------------------------------------
104118
newtype TxOutAddressId = TxOutAddressId {getTxOutAddressId :: Int64}
105119
deriving (Eq, Ord, Show)
106120

121+
instance Read TxOutAddressId where
122+
readsPrec p s = [(TxOutAddressId x, r) | (x, r) <- readsPrec p s]
123+
124+
-----------------------------------------------------------------------------------------------------------------------------------
125+
107126
newtype TxOutUtxoHdId = TxOutUtxoHdId {getTxOutUtxoHdId :: Int64}
108127
deriving (Eq, Ord, Show)
109128

@@ -123,13 +142,26 @@ newtype CollateralTxOutUtxoHdId = CollateralTxOutUtxoHdId {getCollateralTxOutUtx
123142
newtype CollateralTxOutUtxoHdAddressId = CollateralTxOutUtxoHdAddressId {getCollateralTxOutUtxoHdAddressId :: Int64}
124143
deriving (Eq, Ord, Show)
125144

145+
-----------------------------------------------------------------------------------------------------------------------------------
146+
126147
-- | Multi-asset variants
127148
newtype MaTxOutCoreId = MaTxOutCoreId {getMaTxOutCoreId :: Int64}
128149
deriving (Eq, Ord, Show)
129150

151+
instance Read MaTxOutCoreId where
152+
readsPrec p s = [(MaTxOutCoreId x, r) | (x, r) <- readsPrec p s]
153+
154+
-----------------------------------------------------------------------------------------------------------------------------------
155+
156+
-----------------------------------------------------------------------------------------------------------------------------------
130157
newtype MaTxOutAddressId = MaTxOutAddressId {getMaTxOutAddressId :: Int64}
131158
deriving (Eq, Ord, Show)
132159

160+
instance Read MaTxOutAddressId where
161+
readsPrec p s = [(MaTxOutAddressId x, r) | (x, r) <- readsPrec p s]
162+
163+
-----------------------------------------------------------------------------------------------------------------------------------
164+
133165
newtype MaTxOutUtxoHdId = MaTxOutUtxoHdId {getMaTxOutUtxoHdId :: Int64}
134166
deriving (Eq, Ord, Show)
135167

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

Lines changed: 23 additions & 47 deletions
Original file line numberDiff line numberDiff line change
@@ -143,57 +143,33 @@ minIdsAddressToText minIds =
143143
textToMinIds :: TxOutVariantType -> Text -> Maybe MinIdsWrapper
144144
textToMinIds txOutVariantType txt =
145145
case Text.split (== ':') txt of
146-
[tminTxInId, tminTxOutId, tminMaTxOutId, typeId] ->
146+
[tminTxInId, tminTxOutId, tminMaTxOutId] ->
147147
let
148148
mTxInId =
149149
if Text.null tminTxInId
150150
then Nothing
151151
else Just $ Id.TxInId $ read $ Text.unpack tminTxInId
152152

153-
mTxOutId =
154-
if Text.null tminTxOutId
155-
then Nothing
156-
else case Text.head tminTxOutId of
157-
'C' ->
158-
Just $
159-
VCTxOutIdW $
160-
Id.TxOutCoreId $
161-
read $
162-
Text.unpack $
163-
Text.tail tminTxOutId
164-
'V' ->
165-
Just $
166-
VATxOutIdW $
167-
Id.TxOutAddressId $
168-
read $
169-
Text.unpack $
170-
Text.tail tminTxOutId
171-
_ -> Nothing
172-
173-
mMaTxOutId =
174-
if Text.null tminMaTxOutId
175-
then Nothing
176-
else case Text.head tminMaTxOutId of
177-
'C' ->
178-
Just $
179-
CMaTxOutIdW $
180-
Id.MaTxOutCoreId $
181-
read $
182-
Text.unpack $
183-
Text.tail tminMaTxOutId
184-
'V' ->
185-
Just $
186-
VMaTxOutIdW $
187-
Id.MaTxOutAddressId $
188-
read $
189-
Text.unpack $
190-
Text.tail tminMaTxOutId
191-
_ -> Nothing
192-
193-
minIds = MinIds mTxInId mTxOutId mMaTxOutId
153+
-- Based on txOutVariantType, parse the appropriate ID types
154+
(mTxOutId, mMaTxOutId, wrapper) = case txOutVariantType of
155+
TxOutVariantCore ->
156+
( if Text.null tminTxOutId
157+
then Nothing
158+
else Just $ VCTxOutIdW $ Id.TxOutCoreId $ read $ Text.unpack tminTxOutId
159+
, if Text.null tminMaTxOutId
160+
then Nothing
161+
else Just $ CMaTxOutIdW $ Id.MaTxOutCoreId $ read $ Text.unpack tminMaTxOutId
162+
, CMinIdsWrapper
163+
)
164+
TxOutVariantAddress ->
165+
( if Text.null tminTxOutId
166+
then Nothing
167+
else Just $ VATxOutIdW $ Id.TxOutAddressId $ read $ Text.unpack tminTxOutId
168+
, if Text.null tminMaTxOutId
169+
then Nothing
170+
else Just $ VMaTxOutIdW $ Id.MaTxOutAddressId $ read $ Text.unpack tminMaTxOutId
171+
, VMinIdsWrapper
172+
)
194173
in
195-
case (txOutVariantType, typeId) of
196-
(TxOutVariantCore, "C") -> Just $ CMinIdsWrapper minIds
197-
(TxOutVariantAddress, "V") -> Just $ VMinIdsWrapper minIds
198-
_otherwise -> Nothing
199-
_otherwise -> Nothing
174+
Just $ wrapper $ MinIds mTxInId mTxOutId mMaTxOutId
175+
_ -> Nothing

‎cardano-db/src/Cardano/Db/Statement/ConsumedTxOut.hs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -403,9 +403,9 @@ findMaxTxInIdStmt =
403403
[ "WITH target_block_no AS ("
404404
, " SELECT MAX(block_no) - $1 AS target_block_no FROM block"
405405
, ")"
406-
, "SELECT MAX(tx.id) AS max_tx_id"
407-
, "FROM tx"
408-
, "INNER JOIN block ON tx.block_id = block.id"
406+
, "SELECT MAX(tx.id) AS max_tx_id "
407+
, "FROM tx "
408+
, "INNER JOIN block ON tx.block_id = block.id "
409409
, "WHERE block.block_no <= (SELECT target_block_no FROM target_block_no)"
410410
]
411411

‎cardano-db/src/Cardano/Db/Statement/Variants/TxOut.hs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -297,15 +297,19 @@ queryTxOutIdByTxIdStmt =
297297
decoder = HsqlD.rowMaybe (HsqlD.column $ HsqlD.nonNullable HsqlD.int8)
298298

299299
resolveInputTxOutIdFromTxId ::
300+
TxOutVariantType ->
300301
Id.TxId ->
301302
Word64 ->
302303
DbM (Either DbLookupError TxOutIdW)
303-
resolveInputTxOutIdFromTxId txId index = do
304+
resolveInputTxOutIdFromTxId txOutVariantType txId index = do
304305
result <-
305306
runSession mkDbCallStack $
306307
HsqlSes.statement (txId, index) queryTxOutIdByTxIdStmt
307308
case result of
308-
Just txOutId -> pure $ Right $ VCTxOutIdW (Id.TxOutCoreId txOutId) -- Adjust based on your variant
309+
Just txOutId ->
310+
pure $ Right $ case txOutVariantType of
311+
TxOutVariantCore -> VCTxOutIdW (Id.TxOutCoreId txOutId)
312+
TxOutVariantAddress -> VATxOutIdW (Id.TxOutAddressId txOutId)
309313
Nothing ->
310314
pure $
311315
Left $

0 commit comments

Comments
 (0)