どーも、のぶこふです。
今回は、RPCを利用して、Flowの実行（IOUの発行）を行います。
手順としては、下記の通りです。
- 公式からテンプレをクローン
- ファイル修正
- ノード起動
- RPC実行
では、一つずつ実施していきます。
0.開発環境
私の環境は以下の通りです。
- Mac High Sierra（10.13.6）
- IntelliJ（2019.1.2）
なお、修正対象のファイルはGithubに配置しているので、問題がありましたら、そちらも御覧ください。
1.テンプレからクローン
ディレクトリを作成するよ
$ mkdir cordaRPCTest
$ cd cordaRPCTest/
公式Githubからクローンするよ
$ git clone https://github.com/corda/cordapp-template-kotlin.git
$ cd cordapp-template-kotlin/
確認するよ
$ ll
total 80
-rw-r--r-- 1 nobkovskii staff 579 6 24 15:01 LICENCE
-rw-r--r-- 1 nobkovskii staff 4798 6 24 15:01 README.md
-rw-r--r-- 1 nobkovskii staff 232 6 24 15:01 TRADEMARK
-rw-r--r-- 1 nobkovskii staff 4014 6 24 15:01 build.gradle
drwxr-xr-x 4 nobkovskii staff 128 6 24 15:01 clients
drwxr-xr-x 4 nobkovskii staff 128 6 24 15:01 config
drwxr-xr-x 4 nobkovskii staff 128 6 24 15:01 contracts
drwxr-xr-x 3 nobkovskii staff 96 6 24 15:01 gradle
-rw-r--r-- 1 nobkovskii staff 65 6 24 15:01 gradle.properties
-rwxr-xr-x 1 nobkovskii staff 5296 6 24 15:01 gradlew
-rw-r--r-- 1 nobkovskii staff 2176 6 24 15:01 gradlew.bat
-rw-r--r-- 1 nobkovskii staff 57 6 24 15:01 settings.gradle
drwxr-xr-x 4 nobkovskii staff 128 6 24 15:01 workflows
2.ファイル修正
修正するファイル一覧
./workflows/src/main/kotlin/com/template/flows/Flows.kt./contracts/src/main/kotlin/com/template/states/TemplateState.kt./clients/src/main/kotlin/com/template/Client.kt
IntelliJでプロジェクトを開く
- IntelliJを開く
- Open ＞
cordapp-template-kotlin/build.gradleを選択 ＞ Open - Open As Project ＞ 「Use auto-import」にチェック ＞ OK
Stateの修正
公式の手順通り修正していきます。
下記のコピペでOKです。
修正箇所は、コード内のコメントに記述してあります。
./contracts/src/main/kotlin/com/template/states/TemplateState.kt
package com.template.states
import com.template.contracts.TemplateContract
import net.corda.core.contracts.BelongsToContract
import net.corda.core.contracts.ContractState
// import net.corda.core.identity.AbstractParty // <--- [ 削除 ]
import net.corda.core.identity.Party // <--- [ 追加 ]
// *********
// * State *
// *********
@BelongsToContract(TemplateContract::class)
data class TemplateState(val value: Int,
val lender: Party,
val borrower: Party) : ContractState {
override val participants get() = listOf(lender, borrower)
} // <--- [ 引数と処理を修正 ]
Flowの修正
Stateと同様、手順通り修正します。
こちら側は、まるっと修正しています。
./workflows/src/main/kotlin/com/template/flows/Flows.kt
import co.paralleluniverse.fibers.Suspendable
import com.template.contracts.TemplateContract
import com.template.states.TemplateState
import net.corda.core.contracts.Command
import net.corda.core.contracts.requireThat
import net.corda.core.flows.*
import net.corda.core.identity.Party
import net.corda.core.transactions.SignedTransaction
import net.corda.core.transactions.TransactionBuilder
import net.corda.core.utilities.ProgressTracker
@InitiatingFlow
@StartableByRPC
class TemplateFlow(val iouValue: Int,
val otherParty: Party) : FlowLogic<Unit>() {
override val progressTracker = ProgressTracker()
@Suspendable
override fun call() {
val notary = serviceHub.networkMapCache.notaryIdentities[0]
val outputState = TemplateState(iouValue, ourIdentity, otherParty)
val command = Command(TemplateContract.Commands.Action(), ourIdentity.owningKey)
val txBuilder = TransactionBuilder(notary = notary)
.addOutputState(outputState, TemplateContract.ID)
.addCommand(command)
val signedTx = serviceHub.signInitialTransaction(txBuilder)
val otherPartySession = initiateFlow(otherParty)
subFlow(FinalityFlow(signedTx, otherPartySession))
}
}
@InitiatedBy(TemplateFlow::class)
class TemplateFlowResponder(private val otherPartySession: FlowSession) : FlowLogic<Unit>() {
@Suspendable
override fun call() {
val signTxFlow = object : SignTransactionFlow(otherPartySession){
override fun checkTransaction(stx: SignedTransaction) = requireThat{
val output = stx.tx.outputs.single().data
val mys = output as TemplateState
}
}
val expectedTxid = subFlow(signTxFlow).id
subFlow(ReceiveFinalityFlow(otherPartySession,expectedTxid))
}
}
Clientの修正
このファイルでRPCで呼び出すFlowを指定します。（今回は固定Flow）
./clients/src/main/kotlin/com/template/Client.kt
package com.template
import TemplateFlow // <--- [ 追加 ]
import net.corda.client.rpc.CordaRPCClient
import net.corda.core.messaging.startTrackedFlow // <--- [ 追加 ]
import net.corda.core.utilities.NetworkHostAndPort.Companion.parse
import net.corda.core.utilities.loggerFor
/**
* Connects to a Corda node via RPC and performs RPC operations on the node.
*
* The RPC connection is configured using command line arguments.
*/
fun main(args: Array<String>) = Client().main(args)
private class Client {
companion object {
val logger = loggerFor<Client>()
}
fun main(args: Array<String>) {
// Create an RPC connection to the node.
require(args.size == 3) { "Usage: Client <node address> <rpc username> <rpc password>" }
val nodeAddress = parse(args[0])
val rpcUsername = args[1]
val rpcPassword = args[2]
val client = CordaRPCClient(nodeAddress)
val proxy = client.start(rpcUsername, rpcPassword).proxy
// Interact with the node.
// For example, here we print the nodes on the network.
val nodes = proxy.networkMapSnapshot()
logger.info("{}", nodes)
// PartyA -> Value 1 -> PartyB
proxy.startTrackedFlow(::TemplateFlow,1,nodes[2].legalIdentities[0]) // <--- [ 追加 ]
}
}
3.ノード起動
デプロイするよ
$ pwd
/cordaRPCTest/cordapp-template-kotlin
$ ./gradlew clean deployNodes
〜略〜
BUILD SUCCESSFUL in 37s
18 actionable tasks: 14 executed, 4 up-to-date
ノード起動（全て起動するまで、操作禁止！！）
$ ./build/nodes/runnodes
ノード確認
開かれたタブの中で、PartyAのタブを開きます。
画面上部あたりのログか、Welcome to the Corda interactive shell.と書かれているすぐ上あたりを見ると、どのノードなのかがわかるかと思います。
PartyAで実行
bash -c 'cd "/cordaRPCTest/cordapp-template-kotlin/build/nodes/PartyA" ;
〜略〜
______ __
/ ____/ _________/ /___ _
/ / __ / ___/ __ / __ `/ People used to laugh at me when I said I wanted
/ /___ /_/ / / / /_/ / /_/ / to be a comedian. Well they're not laughing now!
\____/ /_/ \__,_/\__,_/
--- Corda Open Source 4.0 (503a2ff) -------------------------------------------------------------
〜略〜
Node for "PartyA" started up and registered in 26.03 sec
Welcome to the Corda interactive shell.
Useful commands include 'help' to see what is available, and 'bye' to shut down the node.
PartyAで実行
// Flow一覧を表示する
Mon Jun 24 16:02:46 JST 2019>>> flow list
TemplateFlow
net.corda.core.flows.ContractUpgradeFlow$Authorise
net.corda.core.flows.ContractUpgradeFlow$Deauthorise
net.corda.core.flows.ContractUpgradeFlow$Initiate
// ネットワークに登録されているノード一覧を表示する
Mon Jun 24 16:03:16 JST 2019>>> run networkMapSnapshot
- addresses:
- "localhost:10005"
legalIdentitiesAndCerts:
- "O=PartyA, L=London, C=GB"
platformVersion: 4
serial: 1561359724664
- addresses:
- "localhost:10002"
legalIdentitiesAndCerts:
- "O=Notary, L=London, C=GB"
platformVersion: 4
serial: 1561359724945
- addresses:
- "localhost:10008"
legalIdentitiesAndCerts:
- "O=PartyB, L=New York, C=US"
platformVersion: 4
serial: 1561359722697
PartyAで実行
// 保持しているStateを確認する
Mon Jun 24 16:03:23 JST 2019>>> run vaultQuery contractStateType: com.template.states.TemplateState
states: []
statesMetadata: []
totalStatesAvailable: -1
stateTypes: "UNCONSUMED"
otherResults: []
無事、ノードが起動されていることが確認できました。
うまくノードが起動できていなかった場合は、再度デプロイ→起動を試してみてください
4.RPC実行
RPCは、最初のターミナルから実行します。
ターミナルでRPCを実行するよ
$ ./gradlew runTemplateClient
> Task :clients:runTemplateClient
I 16:13:40 1 RPCClient.logElapsedTime - Startup took 1143 msec
I 16:13:40 1 Client.main - [NodeInfo(addresses=[localhost:10005], legalIdentitiesAndCerts=[O=PartyA, L=London, C=GB], platformVersion=4, serial=1561359724664), NodeInfo(addresses=[localhost:10002], legalIdentitiesAndCerts=[O=Notary, L=London, C=GB], platformVersion=4, serial=1561359724945), NodeInfo(addresses=[localhost:10008], legalIdentitiesAndCerts=[O=PartyB, L=New York, C=US], platformVersion=4, serial=1561359722697)]
BUILD SUCCESSFUL in 7s
14 actionable tasks: 7 executed, 7 up-to-date
再びPartyAのタブに戻り、Stateを確認します。
PartyAで実行
Mon Jun 24 16:15:21 JST 2019>>> run vaultQuery contractStateType: com.template.states.TemplateState
states:
- state:
data: !<com.template.states.TemplateState>
value: 1
lender: "O=PartyA, L=London, C=GB"
borrower: "O=PartyB, L=New York, C=US"
contract: "com.template.contracts.TemplateContract"
notary: "O=Notary, L=London, C=GB"
encumbrance: null
constraint: !<net.corda.core.contracts.SignatureAttachmentConstraint>
key: "aSq9DsNNvGhYxYyqA9wd2eduEAZ5AXWgJTbTEw3G5d2maAq8vtLE4kZHgCs5jcB1N31cx1hpsLeqG2ngSysVHqcXhbNts6SkRWDaV7xNcr6MtcbufGUchxredBb6"
ref:
txhash: "73E84ECA842336D73E9A648F6900049545A12033D92DDCB59511AAA9E3597E79"
index: 0
statesMetadata:
- ref:
txhash: "73E84ECA842336D73E9A648F6900049545A12033D92DDCB59511AAA9E3597E79"
index: 0
contractStateClassName: "com.template.states.TemplateState"
recordedTime: "2019-06-24T07:13:43.489Z"
consumedTime: null
status: "UNCONSUMED"
notary: "O=Notary, L=London, C=GB"
lockId: null
lockUpdateTime: null
relevancyStatus: "RELEVANT"
constraintInfo:
constraint:
key: "aSq9DsNNvGhYxYyqA9wd2eduEAZ5AXWgJTbTEw3G5d2maAq8vtLE4kZHgCs5jcB1N31cx1hpsLeqG2ngSysVHqcXhbNts6SkRWDaV7xNcr6MtcbufGUchxredBb6"
totalStatesAvailable: -1
stateTypes: "UNCONSUMED"
otherResults: []
PartyAからPartyBへNotaryを介してIOU（Value:1）が発行されているのがわかるかと思います。
↓の部分
states:
- state:
data: !<com.template.states.TemplateState>
value: 1
lender: "O=PartyA, L=London, C=GB"
borrower: "O=PartyB, L=New York, C=US"
contract: "com.template.contracts.TemplateContract"
notary: "O=Notary, L=London, C=GB"
RPC実行で使用したrunTemplateClientのtaskは、/clients/build.gradleにあります。
/clients/build.gradle
task runTemplateClient(type: JavaExec, dependsOn: assemble) {
classpath = sourceSets.main.runtimeClasspath
main = 'com.template.ClientKt'
args 'localhost:10006', 'user1', 'test'
}
5.おわりに
PartyAのタブからでもFlowは実行できますが、このようにRPCを使ってFlowを実行することができ、より実用的？な内容だったかと思います。
まだまだ知らないことが多いです。
先日までドキュメントを片っ端から読んでまとめていて、改めてサンプルを実行したら「こういう仕組みだったのか」と、自分の浅はかさを実感することが出来ました。
ドキュメント読むの大事。
とはいえ、今回修正したファイル以外だと、いじるのはコントラクトのファイルくらいだと思うので、これらをどう組み合わせていくかー？に頭を悩ませていきそうです。
今回は以上です、ありがとうございました。