AuthorizeStateContractUpgrade.kt

// Authorise the upgrade of all the State instances using OldContract.
listOf(partyAProxy, partyBProxy).forEach { proxy ->
// Extract all the unconsumed State instances from the vault.
val stateAndRefs = proxy.vaultQuery(OldState::class.java).states
// Run the upgrade flow for each one.
stateAndRefs
  .filter { stateAndRef ->
      stateAndRef.state.contract.equals(OldContract.id)
      }.forEach { stateAndRef ->
        proxy.startFlowDynamic(
          ContractUpgradeFlow.Authorise::class.java,
          stateAndRef,
          NewContractAndState::class.java)
      }
}

Thread.sleep(5000)