ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2024-12-20 05:28:21 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge branch 'cbdc/conclave-corda-int' into cbdc/poc-encrypt-backchain-merge

Browse Source
This commit is contained in:
adam.houston 2022-03-10 15:51:32 +00:00
commit 91c28f1872
1 changed files with 66 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
common/mock-enclave/src/main/kotlin/com/r3/conclave/encryptedtx/enclave/LedgerTxHelper.kt Normal file
View File

@ -0,0 +1,66 @@
package com.r3.conclave.encryptedtx.enclave
import com.r3.conclave.encryptedtx.dto.ConclaveLedgerTxModel
import net.corda.core.contracts.CommandWithParties
import net.corda.core.contracts.ComponentGroupEnum
import net.corda.core.contracts.ContractState
import net.corda.core.contracts.StateRef
import net.corda.core.contracts.TransactionResolutionException
import net.corda.core.contracts.TransactionState
import net.corda.core.crypto.SecureHash
import net.corda.core.internal.SerializedStateAndRef
import net.corda.core.serialization.SerializedBytes
import net.corda.core.transactions.LedgerTransaction
import net.corda.core.transactions.SignedTransaction
class LedgerTxHelper {
companion object {
@JvmStatic
fun toLedgerTxInternal(conclaveLedgerTxModel: ConclaveLedgerTxModel, dependencies: Set<SignedTransaction>): LedgerTransaction {
val wireTransaction = conclaveLedgerTxModel.signedTransaction.tx
val dependencyMap = dependencies.associateBy { it.tx.id }
val serializedResolvedInputs = conclaveLedgerTxModel.inputStates.map {
resolveStateRefBinaryComponent(it.ref, dependencyMap) ?: throw TransactionResolutionException(it.ref.txhash)
}
val serializedResolvedReferences = conclaveLedgerTxModel.references.map {
resolveStateRefBinaryComponent(it.ref, dependencyMap) ?: throw TransactionResolutionException(it.ref.txhash)
}
return LedgerTransaction.createForConclaveVerify(
inputs = conclaveLedgerTxModel.inputStates.toList(),
outputs = wireTransaction.outputs,
commands = wireTransaction.commands.map {
CommandWithParties(it.signers, emptyList(), it.value)
},
attachments = conclaveLedgerTxModel.attachments.toList(),
id = wireTransaction.id,
notary = wireTransaction.notary,
timeWindow = wireTransaction.timeWindow,
privacySalt = wireTransaction.privacySalt,
networkParameters = conclaveLedgerTxModel.networkParameters,
references = conclaveLedgerTxModel.references.toList(),
componentGroups = wireTransaction.componentGroups,
serializedInputs = serializedResolvedInputs,
serializedReferences = serializedResolvedReferences,
digestService = wireTransaction.digestService
)
}
@JvmStatic
fun resolveStateRefBinaryComponent(stateRef: StateRef, dependencyMap: Map<SecureHash, SignedTransaction>)
: SerializedStateAndRef? {
val wireTransaction = dependencyMap[stateRef.txhash]?.tx
?: throw TransactionResolutionException(stateRef.txhash)
val resolvedState = wireTransaction.componentGroups
.firstOrNull { it.groupIndex == ComponentGroupEnum.OUTPUTS_GROUP.ordinal }
?.components
?.get(stateRef.index) as SerializedBytes<TransactionState<ContractState>>?
return resolvedState?.let { SerializedStateAndRef(it, stateRef) }
}
}
}