mirror of
https://github.com/corda/corda.git
synced 2025-04-09 04:15:35 +00:00
ENT-10122: Now also added consuming transaction id in the resolveAndMakeUpdate code path. (#7459)
This commit is contained in:
parent
7500df76f4
commit
3ae6db8c04
@ -410,7 +410,8 @@ class NodeVaultService(
|
||||
} else {
|
||||
Vault.UpdateType.NOTARY_CHANGE
|
||||
}
|
||||
return Vault.Update(consumedStateAndRefs.toSet(), producedStateAndRefs.toSet(), null, updateType, referenceStateAndRefs.toSet())
|
||||
val consumedTxIds = consumedStateAndRefs.associate { Pair(it.ref, tx.id) }
|
||||
return Vault.Update(consumedStateAndRefs.toSet(), producedStateAndRefs.toSet(), null, updateType, referenceStateAndRefs.toSet(), consumingTxIds = consumedTxIds)
|
||||
}
|
||||
|
||||
|
||||
|
@ -740,7 +740,7 @@ class NodeVaultServiceTest {
|
||||
}
|
||||
|
||||
val expectedIssueUpdate = Vault.Update(emptySet(), setOf(initialCashState), null)
|
||||
val expectedNotaryChangeUpdate = Vault.Update(setOf(initialCashState), setOf(cashStateWithNewNotary), null, Vault.UpdateType.NOTARY_CHANGE)
|
||||
val expectedNotaryChangeUpdate = Vault.Update(setOf(initialCashState), setOf(cashStateWithNewNotary), null, Vault.UpdateType.NOTARY_CHANGE, consumingTxIds = mapOf(initialCashState.ref to changeNotaryTx.id))
|
||||
val expectedMoveUpdate = Vault.Update(setOf(cashStateWithNewNotary), emptySet(), null, consumingTxIds = mapOf(cashStateWithNewNotary.ref to moveTx.id))
|
||||
|
||||
val observedUpdates = vaultSubscriber.onNextEvents
|
||||
|
Loading…
x
Reference in New Issue
Block a user