ci(fabric-connector-weaver): added ci jobs for fabric connector driver

Signed-off-by: Carlos Amaro <[email protected]>

Author: LordKubaya

.cspell.json

@@ -255,6 +255,18 @@
   ,"overriden"
   ,"Certificat"
   ,"adress"
+  ,"FabricProto"
+  ,"bnum"
+  ,"Requestby"
+  ,"ecies"
+  ,"ECIESKDF"
+  ,"kbuf"
+  ,"sjcl"
+  ,"ECIES"
+  ,"driverdbs"
+  ,"driverdb"
+  ,"fabproto"
+  ,"unsubscription"
   ],
   "dictionaries": [
     "typescript,node,npm,go,rust"

.github/workflows/ci_weaver.yaml

@@ -27,7 +27,7 @@ jobs:
   asset-transfer:
     with: 
       run_all: $RUN_ALL
-    uses: ./.github/workflows/test_weaver-asset-transfer.yaml
+    uses: ./.github/workflows/test_weaver-asset-transfer.yaml ./.github/workflows/test_weaver-asset-transfer-fabric-connector.yaml
   relay:
     with: 
       run_all: $RUN_ALL
@@ -47,7 +47,7 @@ jobs:
   data-sharing:
     with: 
       run_all: $RUN_ALL
-    uses: ./.github/workflows/test_weaver-data-sharing.yaml
+    uses: ./.github/workflows/test_weaver-data-sharing.yaml ./.github/workflows/test_weaver-data-sharing-fabric-connector.yaml
   node-pkgs:
     with: 
       run_all: $RUN_ALL 

.github/workflows/test_weaver-asset-transfer-fabric-connector.yaml

@@ -34,7 +34,7 @@
       "email": "[email protected]",
       "url": "https://accenture.com"
     },
-     {
+    {
       "name": "Carlos Amaro",
       "email": "[email protected]",
       "url": "https://accenture.com"
@@ -73,6 +73,7 @@
     "@hyperledger/cactus-common": "2.1.0",
     "@hyperledger/cactus-core": "2.1.0",
     "@hyperledger/cactus-core-api": "2.1.0",
+    "@hyperledger/cactus-plugin-keychain-memory": "2.1.0",
     "axios": "1.8.4",
     "bl": "6.1.0",
     "bn.js": "4.12.0",

.github/workflows/test_weaver-data-sharing-fabric-connector.yaml

@@ -1319,7 +1319,7 @@ export class PluginLedgerConnectorFabric
     return transientMap;
   }
 
-  // Main invoke function wtih logic to handle policy and turn response from chaincode into a view.
+  // Main invoke function with logic to handle policy and turn response from chaincode into a view.
   // 1. Prepare credentials/gateway for communicating with fabric network
   // 2. Set the endorser list for the transaction, this enforces that the list provided will endorse the proposed transaction
   // 3. Prepare the view and return.

packages/cactus-plugin-ledger-connector-fabric/package.json

@@ -48,7 +48,7 @@ export class Events {
   private readonly logger: Logger;
   private readonly connector: PluginLedgerConnectorFabric;
 
-  private listner: Listener;
+  private listener: Listener;
 
   private certificate: any;
 
@@ -59,7 +59,7 @@ export class Events {
     };
     this.logger = LoggerProvider.getOrCreate(logOptions);
     this.connector = options.driver.getConnectorInstance();
-    this.listner = options.driver.getListenerInstance();
+    this.listener = options.driver.getListenerInstance();
     this.certificate = options.certificate;
   }
 
@@ -98,7 +98,7 @@ export class Events {
         // event being subscribed for the first time
         // Start an appropriate type of event listener for this event subscription if one is not already active
         const [, error] = await handlePromise(
-          this.listner.registerListenerForEventSubscription(
+          this.listener.registerListenerForEventSubscription(
             call_request.eventMatcher!,
             gatewayOptions,
           ),
@@ -157,7 +157,7 @@ export class Events {
     gatewayOptions: GatewayOptions,
   ) {
     const [unregister, err] = await handlePromise(
-      this.listner.unregisterListenerForEventSubscription(
+      this.listener.unregisterListenerForEventSubscription(
         call_request.eventMatcher!,
         gatewayOptions,
       ),
@@ -198,7 +198,7 @@ export class Events {
       const ack_send = create(AckSchema, {
         requestId: newRequestId,
         // event got unsubscribed
-        message: `Event ${JSON.stringify(deletedSubscription)} unsubscription is successful!`,
+        message: `Event ${JSON.stringify(deletedSubscription)} unsubscription was successful!`,
         status: Ack_STATUS.OK,
       });
 

packages/cactus-plugin-ledger-connector-fabric/src/main/typescript/plugin-ledger-connector-fabric.ts

@@ -90,7 +90,7 @@ export class FabricDriverServer {
   private readonly relayEndpoint: string;
   private readonly mock: boolean;
   private readonly events: Events;
-  private readonly listner: Listener;
+  private readonly listener: Listener;
 
   private networkName: string = "network1";
   private monitorSyncPeriod: number = 30; // in seconds
@@ -153,7 +153,7 @@ export class FabricDriverServer {
       certificate: this.certificate,
     });
 
-    this.listner = new Listener({
+    this.listener = new Listener({
       logLevel: this.loglevel,
       driver: this,
       chainCodeId: this.interopChainCode,
@@ -183,7 +183,7 @@ export class FabricDriverServer {
   }
 
   public getListenerInstance(): Listener {
-    return this.listner;
+    return this.listener;
   }
 
   public getEventsInstance(): Events {
@@ -276,14 +276,14 @@ export class FabricDriverServer {
         });
         return create(AckSchema, {
           requestId: newRequestId,
-          message: "Mock Procesing addEventSubscription",
+          message: "Mock Processing addEventSubscription",
           status: Ack_STATUS.OK,
         });
       } else {
         this.spawnSubscribeEventHelper(request, newRequestId);
         const ackResponse = create(AckSchema, {
           requestId: newRequestId,
-          message: "Procesing addEventSubscription",
+          message: "Processing addEventSubscription",
           status: Ack_STATUS.OK,
         });
         // gRPC response.
@@ -587,7 +587,7 @@ export class FabricDriverServer {
     this.logger.info("Starting monitor...");
     this.logger.info(`Monitor sync period: ${this.monitorSyncPeriod}`);
     while (true) {
-      await this.listner.monitorBlockForMissedEvents(this.gatewayOptions);
+      await this.listener.monitorBlockForMissedEvents(this.gatewayOptions);
       await delay(this.monitorSyncPeriod * 1000);
     }
   }
@@ -609,7 +609,7 @@ export class FabricDriverServer {
     }
 
     // Register all listeners again
-    const status = await this.listner.loadEventSubscriptionsFromStorage(
+    const status = await this.listener.loadEventSubscriptionsFromStorage(
       this.gatewayOptions,
     );
     this.logger.info(`Load Event Subscriptions Status: ${status}`);

packages/cactus-plugin-ledger-connector-fabric/src/main/typescript/weaver/events.ts

@@ -26,7 +26,7 @@ import {
 } from "./utils";
 import { Events } from "./events";
 import { FabricDriverServer } from "./fabric-driver-server";
-import * as fabproto6 from "fabric-protos";
+import * as FabricProto6 from "fabric-protos";
 import {
   GatewayOptions,
   GetBlockResponseDecodedV1,
@@ -232,14 +232,14 @@ export class Listener {
     // Parse the block data; typically there is only one element in this array but we will interate over it just to be safe
     const blockNum = block.header.number;
     const blockData = (
-      (block as fabproto6.common.Block).data as fabproto6.common.BlockData
+      (block as FabricProto6.common.Block).data as FabricProto6.common.BlockData
     ).data;
     const blockMetadata = (
-      (block as fabproto6.common.Block)
-        .metadata as fabproto6.common.BlockMetadata
+      (block as FabricProto6.common.Block)
+        .metadata as FabricProto6.common.BlockMetadata
     ).metadata;
     const txFilterIndex =
-      fabproto6.common.BlockMetadataIndex.TRANSACTIONS_FILTER;
+      FabricProto6.common.BlockMetadataIndex.TRANSACTIONS_FILTER;
     const txValid = blockMetadata[txFilterIndex];
     this.logger.debug(
       `Event ${loggerName}: block #${blockNum}, #Transactions: ${blockData.length}`,
@@ -256,7 +256,7 @@ export class Listener {
         `Event ${loggerName}: Transaction with TxId: ${tx_id}, index: ${index}`,
       );
 
-      if (txValid[index] === fabproto6.protos.TxValidationCode.VALID) {
+      if (txValid[index] === FabricProto6.protos.TxValidationCode.VALID) {
         // Iterate through the transaction list
         transactions.forEach(async (transaction: any) => {
           // Check if block subscription and then call handle block event
@@ -326,7 +326,7 @@ export class Listener {
         });
       } else {
         this.logger.error(
-          `Event ${loggerName}: Transaction with TxId: ${tx_id} is invalid with code ${txValid[index]}:${fabproto6.protos.TxValidationCode[txValid[index]]}. Discarding.`,
+          `Event ${loggerName}: Transaction with TxId: ${tx_id} is invalid with code ${txValid[index]}:${FabricProto6.protos.TxValidationCode[txValid[index]]}. Discarding.`,
         );
       }
     });