关于附件上传和下载的问题

Question

首先，我读了corda关于使用附件的文档。然而，我仍然有问题的过程上传和下载附件。

我的任务是编写一个简单的cordapp,用于将文件从NodeA传输到NodeB。从NodeA shell上传一个zip文件后，我收到一个散列，然后将其包含在事务中。流动成功。然而，在NodeB中，我无法取回该文件。然后我尝试使用该散列从NodeA获取文件。但是，shell返回错误消息并表示InvalidInputSteam。

下面是流程部分：

@InitiatingFlow
@StartableByRPC
class FileInitiateFlow(
    val receiver: Party,
    val comment: String,
    val hash: SecureHash.SHA256) : FlowLogic<SignedTransaction>() {
    companion object {
    object GENERATING_TRANSACTION : Step("Generating transaction")
    object VERIFYING_TRANSACTION : Step("Verifying contract constraints.")
    object SIGNING_TRANSACTION : Step("Signing transaction with sender private key.")
    object GATHERING_SIGS : Step("Gathering the receiver's signature."){
        override fun childProgressTracker() = CollectSignaturesFlow.tracker()
    }

    object FINALISING_TRANSACTION : Step("Obtaining notary signature and recording transaction.") {
        override fun childProgressTracker() = FinalityFlow.tracker()
    }

    fun tracker() = ProgressTracker(
            GENERATING_TRANSACTION,
            VERIFYING_TRANSACTION,
            SIGNING_TRANSACTION,
            GATHERING_SIGS,
            FINALISING_TRANSACTION
    )
}

override val progressTracker = tracker()


@Suspendable
override fun call(): SignedTransaction {
    // Obtain a reference to the notary we want to use.
    val notary = serviceHub.networkMapCache.notaryIdentities[0]
    val sender = serviceHub.myInfo.legalIdentities.first()
    // Stage 1.
    progressTracker.currentStep = GENERATING_TRANSACTION
    // Generate an unsigned transaction.
    val fileState = FileState(sender, receiver,comment)
    val txCommand = Command(RoamingContract.Commands.FileInitiate(), fileState.participants.map { it.owningKey })
    val txBuilder = TransactionBuilder(notary)
            .addOutputState(fileState, ID)
            .addCommand(txCommand)
            .addAttachment(hash)

    // Stage 2.
    progressTracker.currentStep = VERIFYING_TRANSACTION
    // Verify that the transaction is valid.
    txBuilder.verify(serviceHub)

    // Stage 3.
    progressTracker.currentStep = SIGNING_TRANSACTION
    // Sign the transaction.
    val partSignedTx = serviceHub.signInitialTransaction(txBuilder)

    // Stage 4.
    progressTracker.currentStep = GATHERING_SIGS
    // Send the state to the counterparty, and receive it back with their signature.
    val otherPartyFlow = initiateFlow(receiver)
    val fullySignedTx = subFlow(CollectSignaturesFlow(partSignedTx, setOf(otherPartyFlow), GATHERING_SIGS.childProgressTracker()))

    // Stage 5.
    progressTracker.currentStep = FINALISING_TRANSACTION
    // Notarise and record the transaction in both parties' vaults.
    return subFlow(FinalityFlow(fullySignedTx, FINALISING_TRANSACTION.childProgressTracker()))
}
}

@InitiatedBy(FileInitiateFlow::class)
class FileInitiateRespond(val senderFlow: FlowSession) :         FlowLogic<SignedTransaction>() {
@Suspendable
override fun call(): SignedTransaction{
    val signedTransactionFlow = object : SignTransactionFlow(senderFlow) {
        override fun checkTransaction(stx: SignedTransaction) = requireThat {
            val output = stx.tx.outputs.single().data
            "This must be an File State" using (output is FileState)
        }
    }
    return subFlow(signedTransactionFlow)
}
}

因此，我首先运行uploadAttachment上载zip文件，获得哈希值，然后启动流，以哈希值作为输入。流是成功的，但在接收者的一方，我无法获得哈希键为上传的文件从检查现有的状态。

Answer 1

修复程序在这里:https://github.com/Corda/Corda/pull/3248，并将在Corda4中提供。