corda - 执行 ContractUpgradeFlow 后状态合同不会改变

问题描述

我尝试按照这篇文章https://docs.corda.net/contract-upgrade.html升级合同，然后在执行 ContractUpgradeFlow 后没有错误，但是当查询保险库时，它似乎状态仍然属于旧合同。

在表中它已经插入到 node_contract_upgrades

但是当从保险库查询状态时，我仍然得到旧合同，如果我与（旧状态+新合同）进行交易，它将显示合同约束

Flow Internal Error : java.util.concurrent.ExecutionException: net.corda.core.contracts.TransactionVerificationException$ContractConstraintRejection: Contract constraints failed for th.co.jventures.ddlp.cordapp.contracts.CustomerContractV01, transaction: 418A9A1562A1A7F3C465EC2CC5DDEFB83F5D9C71269EDF83BFBA1094274F926F

这里我的 client.kt 用于运行流程升级

       <pre>`<pre>fun main(args: Array<String>) {
        UpgradeContractClient().main(args)
    }

    /**
     *  A utility demonstrating the contract upgrade process.
     *  In this case, we are upgrading the states' contracts, but not the states
     *  themselves.
     **/
    private class UpgradeContractClient {
        companion object {
            val logger: Logger = loggerFor<UpgradeContractClient>()
        }

        fun main(args: Array<String>) {


            val clientDs = CordaRPCClient(parse("localhost:10009"))
            val dsProxy = clientDs.start("user1", "test").proxy

            val clientPah = CordaRPCClient(parse("localhost:10008"))
            val pahProxy = clientPah.start("user1", "test").proxy

            // Authorise the upgrade of all the State instances using OldContract.
            println("Doing Authorise")
            listOf(dsProxy, pahProxy).forEach { proxy ->
                // Extract all the unconsumed State instances from the vault.
                val stateAndRefs = proxy.vaultQuery(CustomerStateV01::class.java).states
                println("Found customerState=${stateAndRefs.size} for node : ${proxy.nodeInfo()}")

                // Run the upgrade flow for each one.
                stateAndRefs.filter { stateAndRef ->
                    stateAndRef.state.contract == CustomerContractV01.CONTRACT_ID
                }.forEach { stateAndRef ->
                    proxy.startFlowDynamic(
                            ContractUpgradeFlow.Authorise::class.java,
                            stateAndRef,
                            CustomerContractV02::class.java).returnValue.getOrThrow()
                }

                println("Finished")

            }
            Thread.sleep(5000)

            // Initiate the upgrade of all the State instances using OldContract.
            println("Doing Initiate")
            dsProxy.vaultQuery(CustomerStateV01::class.java).states
                    .filter { stateAndRef ->
                        stateAndRef.state.contract == CustomerContractV01.CONTRACT_ID
                    }
                    .forEach { stateAndRef ->
                        dsProxy.startFlowDynamic(
                                ContractUpgradeFlow.Initiate::class.java,
                                stateAndRef,
                                CustomerContractV02::class.java)
                    }

            // Log all the State instances in the vault to show they are using NewContract.
            dsProxy.vaultQuery(CustomerStateV01::class.java).states.forEach { println("${it.state}") }
            dsProxy.vaultQuery(CustomerStateV01::class.java).states.forEach { println("${it.state.contract}") }
        }}`

这是我的合同V02

class CustomerContractV02 : UpgradedContract<CustomerStateV01, CustomerStateV01>{
override val legacyContract: ContractClassName
    get() = CustomerContractV01.CONTRACT_ID


override fun upgrade(state: CustomerStateV01): CustomerStateV01 {
    return state
}

我期望旧合同的状态应该与新合同进行交易还是我误解了概念？

标签： corda

corda - 执行 ContractUpgradeFlow 后状态合同不会改变

问题描述

解决方案

推荐阅读