Skip to content

Running a complete flow

Jump to bottom
Nadine Quin edited this page May 19, 2022 · 19 revisions

Currently (2022-05-18), we only support running CorDapp 'flows'.

To run a CorDapp flow:

  1. Create a CPI file from the CPB file generated for the CorDapp.

  2. Upload the CPI to your corda cluster.

  3. Create a virtual node in the corda cluster to run the CorDapp.

    You can now start flows and collect results from completed flows.

Prequisites

Known Issues

The following are known issues to be fixed in the future:

  • You must allow some time for the CPI to arrive and be unpacked in the flow-worker after an upload.
  • Only the first CPI uploaded is accepted, if two or more CPIs only differ by GroupPolicy.json. Subsequent uploads seem to 'succeed' but do not.

Create a CPI from a CorDapp

To create a CPI follow the instructions in the corda/corda-cli-plugin-host repository.

Uploading a CPI

The following instructions assume you are using bash. The scripts in the Scripts for testing section echo these steps again in bash but also in PowerShell v7.

Set the CPI environment variable to the location of your CPI file:

CPI=<path-to-CPI-file>
curl --insecure -u admin:admin  -s -F upload=@$CPI https://localhost:8888/api/v1/cpi/

Again, but capturing the REQUEST_ID from the JSON reponse from the cluster.

read REQUEST_ID < <(echo $(curl --insecure -u admin:admin  -s -F upload=@$CPI https://localhost:8888/api/v1/cpi/ | jq -r '.id'))

You need REQUEST_ID to [determine the status](#Checking-the-status-of-the-CPI-and-getting-the-CPI Hash), which returns the CPI_HASH and allows you to create a virtual node.

Checking the status of the CPI and getting the CPI Hash

Use the cpi/status/:requestId end point:

# curl --insecure -u admin:admin  https://localhost:8888/api/v1/cpi/status/6eb3bec9-791e-4695-80e1-cdb5337e0db9

curl --insecure -u admin:admin  https://localhost:8888/api/v1/cpi/status/$REQUEST_ID

Create a virtual node

Note: Pick one of the following two methods. Attempting to create the virtual node a second time results in an error that will not contain the holding ID hash that is needed.

Given some X500 name and a CPI_HASH (of a successful upload) we can create a virtual node:

curl --insecure -u admin:admin -d '{ "request": { "cpiFileChecksum": "0123456789ab", "x500Name": "CN=Testing, OU=Application, O=R3, L=London, C=GB"  } }' https://localhost:8888/api/v1/virtualnode

Alternatively, using variable capture from above:

X500="CN=Testing, OU=Application, O=R3, L=London, C=GB"

# Capture the HOLDING_ID
HOLDING_ID=$(curl --insecure -u admin:admin -s -d '{ "request": { "cpiFileChecksum": "'"$CPI_HASH"'", "x500Name": "'"$X500"'"  } }' https://localhost:8888/api/v1/virtualnode | jq -r '.holdingIdHash')

NB. quote-soup due to bash treating everything as text inside single quotes.

Execute flow

curl --insecure -u admin:admin -X PUT -d '{ "requestBody": "{ \"a\":10, \"b\":20 }" }' https://localhost:8888/api/v1/flow/$HOLDING_ID/r1/net.corda.testing.calculator.CalculatorFlow

Check flow status

curl --insecure -u admin:admin https://localhost:8888/api/v1/flow/$HOLDING_ID/r1

Scripts for testing

Bash script

We assume each step just works:

### Change this line though!

$CPI=<path-to-CPI-file>

#  Upload CPI
read REQUEST_ID < <(echo $(curl --insecure -u admin:admin  -s -F upload=@$CPB https://localhost:8888/api/v1/cpi/ | jq -r '.id'))
printf "\nRequest id = $REQUEST_ID  \n\n"

#  Check status
sleep 1
read STATUS CPI_HASH < <(echo $(curl --insecure -u admin:admin -s https://localhost:8888/api/v1/cpi/status/$REQUEST_ID | jq -r '.status, .checksum'))
printf "\nRequest id = $REQUEST_ID   CPI hash = $CPI_HASH   Status = $STATUS\n\n"

#  Create virtual node
X500_BOB="CN=Bob, OU=Application, O=R3, L=London, C=GB"

HOLDING_ID_BOB=$(curl --insecure -u admin:admin -s -d '{ "request": { "cpiFileChecksum": "'"$CPI_HASH"'", "x500Name": "'"$X500_BOB"'"  } }' https://localhost:8888/api/v1/virtualnode | jq -r '.holdingIdHash')
printf "\nHolding id = $HOLDING_ID_BOB\n\n"


#  WARNING - wait here for a bit for the cpk to arrive in the flow worker
sleep 5


# Start a flow
curl --insecure -u admin:admin -d '{ "requestBody": "{ \"a\":10, \"b\":20 }" }' https://localhost:8888/api/v1/flow/$HOLDING_ID_BOB/r1/net.corda.testing.calculator.CalculatorFlow


# Check status
sleep 2
curl --insecure -u admin:admin https://localhost:8888/api/v1/flow/status/$HOLDING_ID_BOB/r1


## BONUS:  SECOND VNODE
X500_ALICE="CN=Alice, OU=Application, O=R3, L=London, C=GB"
HOLDING_ID_ALICE=$(curl --insecure -u admin:admin -s -d '{ "request": { "cpiFileChecksum": "'"$CPI_HASH"'", "x500Name": "'"$X500_ALICE"'"  } }' https://localhost:8888/api/v1/virtualnode | jq -r '.holdingIdHash')
printf "\nHolding id = $HOLDING_ID_ALICE\n\n"


curl --insecure -u admin:admin -X PUT -d '{ "requestBody": "{ \"a\":30, \"b\":40 }" }' https://localhost:8888/api/v1/flow/start/$HOLDING_ID_ALICE/r1/net.corda.testing.calculator.CalculatorFlow

sleep 2
curl --insecure -u admin:admin https://localhost:8888/api/v1/flow/$HOLDING_ID_ALICE/r1

Powershell 7.x

Works on Windows, and even Linux/MacOS

### Change this line!
$CPI=<path-to-CPI-file>

echo '{"groupId":"placeholder"}' > ~/GroupPolicy.json
Compress-Archive -update ~/GroupPolicy.json $CPB

# Upload the CPB
$JSON = curl --insecure -u admin:admin  -s -F upload=@$CPB https://localhost:8888/api/v1/cpi/
$REQUEST_ID =(echo $JSON | ConvertFrom-Json).id

echo "Request id = $REQUEST_ID"

# Check upload status
sleep 2
$JSON = curl --insecure -u admin:admin  https://localhost:8888/api/v1/cpi/status/$REQUEST_ID
$CPI_HASH =(echo $JSON | ConvertFrom-Json).cpiFileChecksum
echo "Request id = $REQUEST_ID   CPI Hash = $CPI_HASH"

# Create Virtual Node
$X500_BOB="CN=Bob, OU=Application, O=R3, L=London, C=GB"
$PAYLOAD=@{ request = @{ cpiFileChecksum = "$CPI_HASH"; x500Name = "$X500_BOB" } }
$JSON = $PAYLOAD | ConvertTo-Json | curl --insecure -u admin:admin -s -d '@-' https://localhost:8888/api/v1/virtualnode
$HOLDING_ID_BOB =(echo $JSON | ConvertFrom-Json).holdingIdHash
echo "Holding id = $HOLDING_ID_BOB"

#  WARNING - wait here for a bit for the cpk to arrive in the flow-worker
sleep 5

# Start Flow
$PAYLOAD=@{ requestBody= "`{ `"a`":10, `"b`":20 `}" }
$JSON = $PAYLOAD | ConvertTo-Json | curl --insecure -u admin:admin -s -X PUT -d '@-' https://localhost:8888/api/v1/flow/$HOLDING_ID_BOB/r1/net.corda.testing.calculator.CalculatorFlow
echo $JSON
echo ""
sleep 1

# Check flow status
curl --insecure -u admin:admin https://localhost:8888/api/v1/flow/$HOLDING_ID_BOB/r1
Clone this wiki locally