feat: STUD-501 Update Stream token Metadata

Author: AndrewWestberg

newm-server/src/main/kotlin/io/newm/server/config/repo/ConfigRepository.kt

@@ -38,6 +38,7 @@ interface ConfigRepository {
         const val CONFIG_KEY_MINT_CASH_REGISTER_COLLECTION_AMOUNT = "mint.cashRegisterCollectionAmount"
         const val CONFIG_KEY_MINT_CIP68_POLICY = "mint.cip68Policy"
         const val CONFIG_KEY_MINT_CIP68_SCRIPT_ADDRESS = "mint.cip68ScriptAddress"
+        const val CONFIG_KEY_MINT_CIP68_UTXO_REFERENCE = "mint.cip68UtxoReference"
         const val CONFIG_KEY_MINT_SCRIPT_UTXO_REFERENCE = "mint.scriptUtxoReference"
         const val CONFIG_KEY_MINT_STARTER_TOKEN_UTXO_REFERENCE = "mint.starterTokenUtxoReference"
         const val CONFIG_KEY_MINT_MONITOR_PAYMENT_ADDRESS_TIMEOUT_MIN = "mint.monitorPaymentAddressTimeoutMin"

newm-server/src/main/kotlin/io/newm/server/database/migration/V79__ConfigUpdates.kt

@@ -0,0 +1,14 @@
+package io.newm.server.database.migration
+
+import org.flywaydb.core.api.migration.BaseJavaMigration
+import org.flywaydb.core.api.migration.Context
+import org.jetbrains.exposed.sql.transactions.transaction
+
+@Suppress("unused")
+class V79__ConfigUpdates : BaseJavaMigration() {
+    override fun migrate(context: Context?) {
+        transaction {
+            exec("INSERT INTO config VALUES ('mint.cip68UtxoReference','<update_me>') ON CONFLICT(id) DO NOTHING")
+        }
+    }
+}

newm-server/src/main/kotlin/io/newm/server/features/cardano/repo/CardanoRepository.kt

@@ -13,14 +13,14 @@ import io.newm.chain.grpc.TransactionBuilderRequestKt
 import io.newm.chain.grpc.TransactionBuilderResponse
 import io.newm.chain.grpc.Utxo
 import io.newm.chain.grpc.VerifySignDataResponse
+import io.newm.server.features.cardano.model.CardanoNftSong
 import io.newm.server.features.cardano.model.EncryptionRequest
 import io.newm.server.features.cardano.model.GetWalletSongsResponse
 import io.newm.server.features.cardano.model.Key
-import io.newm.server.features.cardano.model.CardanoNftSong
 import io.newm.server.features.song.model.SongFilters
 import io.newm.server.typealiases.UserId
-import kotlinx.coroutines.flow.Flow
 import java.util.UUID
+import kotlinx.coroutines.flow.Flow
 
 interface CardanoRepository {
     suspend fun saveKey(
@@ -121,6 +121,14 @@ interface CardanoRepository {
      */
     suspend fun saveScriptAddressToWhitelist(scriptAddress: String)
 
+    /**
+     * Get the utxo(s) holding this native asset
+     */
+    suspend fun queryUtxoByNativeAsset(
+        policyHex: String,
+        nameHex: String
+    ): Utxo
+
     companion object {
         const val MUTEX_NAME = "newm-server"
 

newm-server/src/main/kotlin/io/newm/server/features/cardano/repo/CardanoRepositoryImpl.kt

@@ -220,6 +220,19 @@ internal class CardanoRepositoryImpl(
         return response.utxosList
     }
 
+    override suspend fun queryUtxoByNativeAsset(
+        policyHex: String,
+        nameHex: String
+    ): Utxo {
+        val response = client.queryUtxoByNativeAsset(
+            queryByNativeAssetRequest {
+                policy = policyHex
+                name = nameHex
+            }
+        )
+        return response
+    }
+
     override fun signTransaction(
         transactionIdBytes: ByteArray,
         signingKeys: List<Key>

newm-server/src/main/kotlin/io/newm/server/features/minting/MintingMessageReceiver.kt

@@ -46,7 +46,19 @@ class MintingMessageReceiver : SqsMessageReceiver {
     override suspend fun onMessageReceived(message: Message) {
         log.info { "received: ${message.body()}" }
         val mintingStatusSqsMessage: MintingStatusSqsMessage = json.decodeFromString(message.body())
+
         val dbSong = songRepository.get(mintingStatusSqsMessage.songId)
+        if (mintingStatusSqsMessage.mintingStatus == MintingStatus.UpdateTokenMetadataRequested && dbSong.mintingStatus in listOf(
+                MintingStatus.Minted,
+                MintingStatus.Released
+            )
+        ) {
+            log.info { "Updating token metadata for ${dbSong.id} ..." }
+            val mintInfo = mintingRepository.updateTokenMetadata(dbSong)
+            log.info { "Updated ${dbSong.id}: $mintInfo" }
+            return
+        }
+
         if (dbSong.mintingStatus == MintingStatus.Released) {
             // Sometimes, we will manually reprocess a song. If it is already minted & released successfully when we do
             // dead-letter queue reprocessing, we can safely ignore these messages and let them be successfully
@@ -340,6 +352,8 @@ class MintingMessageReceiver : SqsMessageReceiver {
                     } else {
                         val mintInfo = mintingRepository.mint(song)
 
+                        log.info { "Minted ${song.id}: $mintInfo" }
+
                         // Update the song record with the minting info
                         songRepository.update(
                             songId = mintingStatusSqsMessage.songId,

newm-server/src/main/kotlin/io/newm/server/features/minting/repo/MintingRepository.kt

@@ -13,6 +13,8 @@ interface MintingRepository {
      */
     suspend fun mint(song: Song): MintInfo
 
+    suspend fun updateTokenMetadata(song: Song): MintInfo
+
     fun getTokenAgreementFileIndex(policyId: String): Int
 
     fun getAudioClipFileIndex(policyId: String): Int