refactor(database): move convertMultiAssetToModels to models (#974)

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

Author: wolf31o2

database/models/asset.go

@@ -14,7 +14,12 @@
 
 package models
 
-import "github.com/blinklabs-io/dingo/database/types"
+import (
+	"encoding/hex"
+
+	"github.com/blinklabs-io/dingo/database/types"
+	lcommon "github.com/blinklabs-io/gouroboros/ledger/common"
+)
 
 type Asset struct {
 	Name        []byte       `gorm:"index"`
@@ -29,3 +34,47 @@ type Asset struct {
 func (Asset) TableName() string {
 	return "asset"
 }
+
+// ConvertMultiAssetToModels converts a MultiAsset structure into a slice of Asset models.
+// Each asset is populated with its name, hex-encoded name, policy ID, fingerprint, and amount.
+// Returns an empty slice if multiAsset is nil or contains no assets.
+func ConvertMultiAssetToModels(
+	multiAsset *lcommon.MultiAsset[lcommon.MultiAssetTypeOutput],
+) []Asset {
+	if multiAsset == nil {
+		return []Asset{}
+	}
+	numAssets := 0
+	// Get all policy IDs
+	policyIds := multiAsset.Policies()
+	for _, policyId := range policyIds {
+		numAssets += len(multiAsset.Assets(policyId))
+	}
+	assets := make([]Asset, 0, numAssets)
+	for _, policyId := range policyIds {
+		policyIdBytes := policyId.Bytes()
+
+		// Get asset names for this policy
+		assetNames := multiAsset.Assets(policyId)
+		for _, assetNameBytes := range assetNames {
+			amount := multiAsset.Asset(policyId, assetNameBytes)
+
+			// Calculate fingerprint
+			fingerprint := lcommon.NewAssetFingerprint(
+				policyIdBytes,
+				assetNameBytes,
+			)
+
+			asset := Asset{
+				Name:        assetNameBytes,
+				NameHex:     []byte(hex.EncodeToString(assetNameBytes)),
+				PolicyId:    policyIdBytes,
+				Fingerprint: []byte(fingerprint.String()),
+				Amount:      types.Uint64(amount),
+			}
+			assets = append(assets, asset)
+		}
+	}
+
+	return assets
+}

database/plugin/metadata/sqlite/utxo.go

@@ -15,12 +15,10 @@
 package sqlite
 
 import (
-	"encoding/hex"
 	"errors"
 	"fmt"
 
 	"github.com/blinklabs-io/dingo/database/models"
-	"github.com/blinklabs-io/dingo/database/types"
 	"github.com/blinklabs-io/gouroboros/ledger"
 	lcommon "github.com/blinklabs-io/gouroboros/ledger/common"
 	"gorm.io/gorm"
@@ -216,7 +214,7 @@ func (d *MetadataStoreSqlite) SetUtxo(
 
 	// Handle assets if present
 	if assets != nil {
-		tmpUtxo.Assets = convertMultiAssetToModels(assets)
+		tmpUtxo.Assets = models.ConvertMultiAssetToModels(assets)
 	}
 
 	var result *gorm.DB
@@ -323,44 +321,9 @@ func utxoLedgerToModel(
 		MultiAsset() *lcommon.MultiAsset[lcommon.MultiAssetTypeOutput]
 	}); ok {
 		if multiAsset := multiAssetOutput.MultiAsset(); multiAsset != nil {
-			ret.Assets = convertMultiAssetToModels(multiAsset)
+			ret.Assets = models.ConvertMultiAssetToModels(multiAsset)
 		}
 	}
 
 	return ret
 }
-
-func convertMultiAssetToModels(
-	multiAsset *lcommon.MultiAsset[lcommon.MultiAssetTypeOutput],
-) []models.Asset {
-	var assets []models.Asset
-
-	// Get all policy IDs
-	policyIds := multiAsset.Policies()
-	for _, policyId := range policyIds {
-		policyIdBytes := policyId.Bytes()
-
-		// Get asset names for this policy
-		assetNames := multiAsset.Assets(policyId)
-		for _, assetNameBytes := range assetNames {
-			amount := multiAsset.Asset(policyId, assetNameBytes)
-
-			// Calculate fingerprint
-			fingerprint := lcommon.NewAssetFingerprint(
-				policyIdBytes,
-				assetNameBytes,
-			)
-
-			asset := models.Asset{
-				Name:        assetNameBytes,
-				NameHex:     []byte(hex.EncodeToString(assetNameBytes)),
-				PolicyId:    policyIdBytes,
-				Fingerprint: []byte(fingerprint.String()),
-				Amount:      types.Uint64(amount),
-			}
-			assets = append(assets, asset)
-		}
-	}
-
-	return assets
-}