feat(connector-corda): enable Flow Database Access CorDapp

Added new corda-all-in-one image for flow-database-access sample Modified Corda main-server image to allow calls to invoke without executing any transaction. Modified Corda InvokeContractV1Response to add the new flowId field to return the flow handle id instead of use the callOutput field, which now is used for the data returned by the flow. The transactionId is not required because we can call invoke without executing any transaction. Resolves hyperledger-cacti#1493 Signed-off-by: Elena Izaguirre <e.izaguirre.equiza@accenture.com>
elenaizaguirre · Dec 9, 2021 · dd24eb9 · dd24eb9
1 parent 713df91
commit dd24eb9
Show file tree

Hide file tree

Showing 32 changed files with 948 additions and 49 deletions.
diff --git a/.cspell.json b/.cspell.json
@@ -39,6 +39,7 @@
         "execa",
         "faio",
         "fidm",
+        "flowdb",
         "fsouza",
         "GETHKEYCHAINPASSWORD",
         "ghcr",
@@ -83,6 +84,7 @@
         "myroot",
         "mysecretpassword",
         "myvolume",
+        "nogotiation",
         "Nerc",
         "NETWORKSCOPEALLFORTX",
         "NETWORKSCOPEANYFORTX",

diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -178,6 +178,18 @@ jobs:
     - name: Print Disk Usage Reports
       run: df ; echo "" ; docker system df
 
+    - name: ghcr.io/hyperledger/cactus-corda-all-in-one-obligation
+      run: DOCKER_BUILDKIT=1 docker build ./tools/docker/corda-all-in-one/ -f ./tools/docker/corda-all-in-one/corda-v4_8/Dockerfile
+
+    - name: Print Disk Usage Reports
+      run: df ; echo "" ; docker system df
+
+    - name: ghcr.io/hyperledger/cactus-corda-all-in-one-flowdb
+      run: DOCKER_BUILDKIT=1 docker build ./tools/docker/corda-all-in-one/corda-v4_8-flowdb/
+
+    - name: Print Disk Usage Reports
+      run: df ; echo "" ; docker system df
+
     # Skipping this one for now because it keeps making the CI fail most likely due to DockerHub rate limits.
     # TODO: Recommend the Fabric maintainers that they publish their images to ghcr.io as well or ask how can the
     # image registry be overridden in Fabric samples.

diff --git a/.taprc b/.taprc
@@ -60,6 +60,7 @@ files:
   - ./packages/cactus-plugin-ledger-connector-corda/src/test/typescript/integration/jvm-kotlin-spring-server-v4.8.test.ts
   - ./packages/cactus-plugin-ledger-connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes.test.ts
   - ./packages/cactus-plugin-ledger-connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.8.test.ts
+  - ./packages/cactus-plugin-ledger-connector-corda/src/test/typescript/integration/flow-database-access-v4.8.test.ts
   - ./packages/cactus-plugin-ledger-connector-corda/src/test/typescript/integration/jvm-kotlin-spring-server.test.ts
   - ./packages/cactus-plugin-keychain-google-sm/src/test/typescript/integration/plugin-factory-keychain.test.ts
   - ./packages/cactus-plugin-keychain-google-sm/src/test/typescript/integration/plugin-keychain-google-sm.test.ts

diff --git a/jest.config.js b/jest.config.js
diff --git a/...s-plugin-ledger-connector-corda/src/main-server/kotlin/gen/kotlin-spring/build.gradle.kts b/...s-plugin-ledger-connector-corda/src/main-server/kotlin/gen/kotlin-spring/build.gradle.kts
@@ -2,8 +2,8 @@ import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 
 val corda_release_group = "net.corda"
 val corda_core_release_group =  "net.corda"
-val corda_release_version = "4.5"
-val corda_core_release_version = "4.5"
+val corda_release_version = "4.6"
+val corda_core_release_version = "4.6"
 val corda_platform_version = 5
 
 tasks.named<Test>("test") {

diff --git a/...tus/plugin/ledger/connector/corda/server/impl/ApiPluginLedgerConnectorCordaServiceImpl.kt b/...tus/plugin/ledger/connector/corda/server/impl/ApiPluginLedgerConnectorCordaServiceImpl.kt
@@ -78,6 +78,49 @@ class ApiPluginLedgerConnectorCordaServiceImpl(
         val returnValue = flowHandle.returnValue.get(timeoutMs, TimeUnit.MILLISECONDS)
         val id = flowHandle.id
 
+        // allow returnValue to be something different to SignedTransaction
+        var callOutput: kotlin.Any = ""
+        var transactionId: kotlin.String? = null
+
+        if (returnValue is SignedTransaction) {
+            logger.trace("returnValue is SignedTransaction - using returnValue.id.toString() ...");
+            transactionId = returnValue.id.toString();
+
+            callOutput = mapOf(
+                "tx" to mapOf(
+                    "id" to returnValue.tx.id,
+                    "notary" to returnValue.tx.notary,
+                    "requiredSigningKeys" to returnValue.tx.requiredSigningKeys,
+                    "merkleTree" to returnValue.tx.merkleTree,
+                    "privacySalt" to returnValue.tx.privacySalt,
+                    "attachments" to returnValue.tx.attachments,
+                    "commands" to returnValue.tx.commands,
+                    // "digestService" to returnValue.tx.digestService,
+                    "inputs" to returnValue.tx.inputs,
+                    "networkParametersHash" to returnValue.tx.networkParametersHash,
+                    "references" to returnValue.tx.references,
+                    "timeWindow" to returnValue.tx.timeWindow
+                ),
+                "id" to returnValue.id,
+                "inputs" to returnValue.inputs,
+                "networkParametersHash" to returnValue.networkParametersHash,
+                "notary" to returnValue.notary,
+                "references" to returnValue.references,
+                "requiredSigningKeys" to returnValue.requiredSigningKeys,
+                "sigs" to returnValue.sigs
+            );
+
+        } else if (returnValue != null) {
+            callOutput = try {
+                val returnValueJson = writer.writeValueAsString(returnValue);
+                logger.trace("returnValue JSON serialized OK, using returnValue ...");
+                returnValueJson;
+            } catch (ex: Exception) {
+                logger.trace("returnValue JSON serialized failed, using returnValue.toString() ...");
+                returnValue.toString();
+            }
+        }
+
         logger.info("Progress(${progress.size})={}", progress)
         logger.info("ReturnValue={}", returnValue)
         logger.info("Id=$id")
@@ -96,7 +139,7 @@ class ApiPluginLedgerConnectorCordaServiceImpl(
         // org.hyperledger.cactus.plugin.ledger.connector.corda.server.model.InvokeContractV1Response["returnValue"]->
         // net.corda.client.jackson.internal.StxJson["wire"]->net.corda.client.jackson.internal.WireTransactionJson["outputs"])]
         // with root cause
-        return InvokeContractV1Response(true, id.toString(), (returnValue as SignedTransaction).id.toString(), progress)
+        return InvokeContractV1Response(true, callOutput, id.toString(), transactionId, progress)
     }
 
     // FIXME - make it clear in the documentation that this deployment endpoint is not recommended for production

diff --git a/...hyperledger/cactus/plugin/ledger/connector/corda/server/model/InvokeContractV1Response.kt b/...hyperledger/cactus/plugin/ledger/connector/corda/server/model/InvokeContractV1Response.kt
@@ -14,7 +14,8 @@ import javax.validation.Valid
 /**
  * 
  * @param success 
- * @param callOutput 
+ * @param callOutput Data returned from the JVM when no transaction is running
+ * @param flowId The id for the flow handle
  * @param transactionId The net.corda.core.flows.StateMachineRunId value returned by the flow execution.
  * @param progress An array of strings representing the aggregated stream of progress updates provided by a *tracked* flow invocation. If the flow invocation was not tracked, this array is still returned, but as empty.
  */
@@ -25,8 +26,10 @@ data class InvokeContractV1Response(
     @field:Valid
     @field:JsonProperty("callOutput", required = true) val callOutput: kotlin.Any,
 
+    @field:JsonProperty("flowId", required = true) val flowId: kotlin.String,
+
     @get:Size(min=1,max=1024)
-    @field:JsonProperty("transactionId", required = true) val transactionId: kotlin.String,
+    @field:JsonProperty("transactionId") val transactionId: kotlin.String? = null,
 
     @field:JsonProperty("progress") val progress: kotlin.collections.List<kotlin.String>? = null
 ) {

diff --git a/packages/cactus-plugin-ledger-connector-corda/src/main/json/openapi.json b/packages/cactus-plugin-ledger-connector-corda/src/main/json/openapi.json
@@ -455,16 +455,17 @@
                 "type": "object",
                 "required": [
                     "success",
-                    "transactionId",
-                    "callOutput"
+                    "callOutput",
+                    "flowId"                    
                 ],
                 "properties": {
                     "success": {
                         "type": "boolean",
                         "nullable": false
                     },
                     "callOutput": {
-                        "type": "object"
+                        "type": "object",
+                        "description": "Data returned from the JVM when no transaction is running"
                     },
                     "transactionId": {
                         "type": "string",
@@ -482,6 +483,10 @@
                             "maxItems": 10e6
                         },
                         "default": []
+                    },
+                    "flowId": {
+                        "type": "string",
+                        "description": "The id for the flow handle"
                     }
                 }
             },

diff --git a/...ugin-ledger-connector-corda/src/main/typescript/generated/openapi/typescript-axios/api.ts b/...ugin-ledger-connector-corda/src/main/typescript/generated/openapi/typescript-axios/api.ts
@@ -368,7 +368,7 @@ export interface InvokeContractV1Response {
      */
     success: boolean;
     /**
-     * 
+     * Data returned from the JVM when no transaction is running
      * @type {object}
      * @memberof InvokeContractV1Response
      */
@@ -378,13 +378,19 @@ export interface InvokeContractV1Response {
      * @type {string}
      * @memberof InvokeContractV1Response
      */
-    transactionId: string;
+    transactionId?: string;
     /**
      * An array of strings representing the aggregated stream of progress updates provided by a *tracked* flow invocation. If the flow invocation was not tracked, this array is still returned, but as empty.
      * @type {Array<string>}
      * @memberof InvokeContractV1Response
      */
     progress?: Array<string>;
+    /**
+     * The id for the flow handle
+     * @type {string}
+     * @memberof InvokeContractV1Response
+     */
+    flowId: string;
 }
 /**
  * 

diff --git a/...connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.7.test.ts b/...connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.7.test.ts
@@ -106,7 +106,7 @@ test.skip("Tests are passing on the JVM side", async (t: Test) => {
   const connector = new CordaConnectorContainer({
     logLevel,
     imageName: "ghcr.io/hyperledger/cactus-connector-corda-server",
-    imageVersion: "2021-11-11",
+    imageVersion: "2021-11-23--feat-1493",
     envVars: [envVarSpringAppJson],
   });
   t.ok(CordaConnectorContainer, "CordaConnectorContainer instantiated OK");

diff --git a/...r-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.8-express.test.ts b/...r-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.8-express.test.ts
@@ -111,7 +111,7 @@ test.skip("Tests are passing on the JVM side", async (t: Test) => {
   const connector = new CordaConnectorContainer({
     logLevel,
     imageName: "ghcr.io/hyperledger/cactus-connector-corda-server",
-    imageVersion: "2021-11-11",
+    imageVersion: "2021-11-23--feat-1493",
     envVars: [envVarSpringAppJson],
   });
   t.ok(CordaConnectorContainer, "CordaConnectorContainer instantiated OK");

diff --git a/...connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.8.test.ts b/...connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes-v4.8.test.ts
@@ -107,7 +107,7 @@ test.skip("Tests are passing on the JVM side", async (t: Test) => {
   const connector = new CordaConnectorContainer({
     logLevel,
     imageName: "ghcr.io/hyperledger/cactus-connector-corda-server",
-    imageVersion: "2021-11-11",
+    imageVersion: "2021-11-23--feat-1493",
     envVars: [envVarSpringAppJson],
   });
   t.ok(CordaConnectorContainer, "CordaConnectorContainer instantiated OK");

diff --git a/...dger-connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes.test.ts b/...dger-connector-corda/src/test/typescript/integration/deploy-cordapp-jars-to-nodes.test.ts
@@ -106,9 +106,7 @@ test.skip("Tests are passing on the JVM side", async (t: Test) => {
   const connector = new CordaConnectorContainer({
     logLevel,
     imageName: "ghcr.io/hyperledger/cactus-connector-corda-server",
-    imageVersion: "2021-11-11",
-    // imageName: "cccs",
-    // imageVersion: "latest",
+    imageVersion: "2021-11-23--feat-1493",
     envVars: [envVarSpringAppJson],
   });
   t.ok(CordaConnectorContainer, "CordaConnectorContainer instantiated OK");