Corda 在单个流调用中返回多个事务 ()答案

【问题标题】：Corda returning Multiple transactions in a single flow call ()Corda 在单个流调用中返回多个事务 ()
【发布时间】：2018-06-14 16:41:25
【问题描述】：

我有这样的场景，其中一方需要读取状态列表（例如 DEAL STATE），然后遍历列表以找出匹配的记录。如果匹配，我们需要通过组合匹配的字段来创建新的输出状态。

所以一旦在循环内执行匹配，我们就可以得到输入和输出状态的列表。

但我对从其他方收集签名感到困惑，因为每条记录的交易对手都不同。另外，我将如何在单个流调用方法中调用多个事务的最终流？

@joel，另一个问题 - 假设 outputstate1 参与者是 A、B、C，而 outputstate2 参与者是 B、C、D，即 B 和 C 参与 2 笔交易。所以在匹配状态循环中，当我们制作 flowsessions 映射时，它的签名者是 A、B、C、D。但是当我们调用 CollectSignaturesFlow 时，我们需要传递每个部分签名的 trxn 和会话。那么如何通过一个trxn对应的session呢？

【问题讨论】：

标签： corda

【解决方案1】：

以下是我们如何收集每个州的签名的示例：

val flowSessionMap = mutableMapOf<Party, FlowSession>()

val fullySignedTransactions = matchingStates.forEach { matchingState ->
    val requiredSigners: List<Party> = TODO("Derive this from the matching state somehow.")
    val signedTransaction: SignedTransaction = TODO("Build transaction.")

    val sessions = requiredSigners.map { signer ->
        flowSessionMap.getOrPut(signer) {
            initiateFlow(signer)
        }
    }

    val fullySignedTransaction = subFlow(CollectSignaturesInitiatingFlow(
        signedTransaction, sessions)
    )
}

其中CollectSignaturesInitiatingFlow定义如下：

@InitiatingFlow
class CollectSignaturesInitiatingFlow(val signedTransaction: SignedTransaction, val sessions: List<FlowSession>): FlowLogic<SignedTransaction>() {
    override fun call(): SignedTransaction {
        return subFlow(CollectSignaturesFlow(signedTransaction, sessions))
    }
}

CollectSignaturesInitiatingFlow 的响应者定义如下：

@InitiatedBy(CollectSignaturesInitiatingFlow::class)
class CollectSignaturesInitiatingFlowResponder(val otherPartyFlow: FlowSession) : FlowLogic<SignedTransaction>() {
    @Suspendable
    override fun call(): SignedTransaction {
        val signTransactionFlow = object : SignTransactionFlow(otherPartyFlow) {
            override fun checkTransaction(stx: SignedTransaction) {
                TODO("Check the transaction here.")
            }
        }

        return subFlow(signTransactionFlow)
    }
}

请注意：

我们小心翼翼地只为每个交易对手创建一个会话。从 Corda 3 开始，如果流程为每个交易对手创建多个会话，则会引发错误
我们将对CollectSignaturesFlow 的调用封装在CollectSignaturesInitiatingFlow 中。为什么？在 Corda 中，有两种类型的流：Initiating 和内联。每个Initiating 流实例都有一个唯一的 ID，而每个内联流都继承了将其称为子流的流的 ID。从 Corda 3 开始，如果响应者为同一个流 ID 调用两次，则会引发异常。通过将 CollectSignaturesFlow（内联流）包装在 CollectSignaturesInitiatingFlow（Initiating 流）中，我们为每次收集签名的尝试创建一个新的流 ID，并且不会引发异常

获得完全签名的交易后，您可以循环调用FinalityFlow：

for (transaction in fullySignedTransactions) {
    subFlow(FinalityFlow(transaction))
}

【讨论】：