fix(database): store produced utxos

Signed-off-by: Chris Gianelloni <wolf31o2@blinklabs.io>

Author: wolf31o2

database/plugin/metadata/sqlite/transaction.go

@@ -176,16 +176,35 @@ func (d *MetadataStoreSqlite) SetTransaction(
 		tmpTx.Metadata = tmpMetadata
 	}
 	collateralReturn := tx.CollateralReturn()
+	// For invalid transactions with collateral returns, fix indices via CBOR matching
+	// since Produced() uses enumerated indices rather than real transaction indices
+	var realIndexMap map[lcommon.Blake2b256]uint32
+	if !tx.IsValid() && collateralReturn != nil {
+		realIndexMap = make(map[lcommon.Blake2b256]uint32)
+		for idx, out := range tx.Outputs() {
+			if out != nil && idx <= int(^uint32(0)) {
+				// Hash CBOR for efficient map key
+				outputHash := lcommon.NewBlake2b256(out.Cbor())
+				//nolint:gosec // G115: idx bounds already checked above
+				realIndexMap[outputHash] = uint32(idx)
+			}
+		}
+	}
 	for _, utxo := range tx.Produced() {
 		if collateralReturn != nil && utxo.Output == collateralReturn {
-			utxo := models.UtxoLedgerToModel(utxo, point.Slot)
-			tmpTx.CollateralReturn = &utxo
+			m := models.UtxoLedgerToModel(utxo, point.Slot)
+			// Fix collateral return index for invalid transactions
+			if realIndexMap != nil && m.Cbor != nil {
+				outputHash := lcommon.NewBlake2b256(m.Cbor)
+				if realIdx, ok := realIndexMap[outputHash]; ok {
+					m.OutputIdx = realIdx
+				}
+			}
+			tmpTx.CollateralReturn = &m
 			continue
 		}
-		tmpTx.Outputs = append(
-			tmpTx.Outputs,
-			models.UtxoLedgerToModel(utxo, point.Slot),
-		)
+		m := models.UtxoLedgerToModel(utxo, point.Slot)
+		tmpTx.Outputs = append(tmpTx.Outputs, m)
 	}
 	result := txn.Clauses(clause.OnConflict{
 		Columns: []clause.Column{{Name: "hash"}}, // unique txn hash

database/transaction.go

@@ -34,18 +34,38 @@ func (d *Database) SetTransaction(
 		txn = d.Transaction(false)
 		defer txn.Commit() //nolint:errcheck
 	}
-	if tx.IsValid() {
-		for _, utxo := range tx.Produced() {
-			// Add UTxO to blob DB
-			key := UtxoBlobKey(
-				utxo.Id.Id().Bytes(),
-				utxo.Id.Index(),
-			)
-			err := txn.Blob().Set(key, utxo.Output.Cbor())
-			if err != nil {
-				return err
+	// Build index map for invalid transactions with collateral returns
+	var realIndexMap map[lcommon.Blake2b256]uint32
+	collateralReturn := tx.CollateralReturn()
+	if !tx.IsValid() && collateralReturn != nil {
+		realIndexMap = make(map[lcommon.Blake2b256]uint32)
+		for idx, out := range tx.Outputs() {
+			if out != nil && idx <= int(^uint32(0)) {
+				outputHash := lcommon.NewBlake2b256(out.Cbor())
+				//nolint:gosec // G115: idx bounds already checked above
+				realIndexMap[outputHash] = uint32(idx)
+			}
+		}
+	}
+	// Always store Produced UTxOs (outputs or collateral return)
+	for _, utxo := range tx.Produced() {
+		// For invalid transactions, use real index from CBOR matching
+		outputIdx := utxo.Id.Index()
+		if realIndexMap != nil {
+			outputHash := lcommon.NewBlake2b256(utxo.Output.Cbor())
+			if realIdx, ok := realIndexMap[outputHash]; ok {
+				outputIdx = realIdx
 			}
 		}
+		// Add UTxO to blob DB
+		key := UtxoBlobKey(
+			utxo.Id.Id().Bytes(),
+			outputIdx,
+		)
+		err := txn.Blob().Set(key, utxo.Output.Cbor())
+		if err != nil {
+			return err
+		}
 	}
 	err := d.metadata.SetTransaction(
 		tx,