feat(weaver): weaver fabric driver connector implementation

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

Author: LordKubaya

packages/cactus-plugin-ccmodel-hephaestus/src/main/typescript/plugin-ccmodel-hephaestus.ts

@@ -260,6 +260,11 @@ export class CcModelHephaestus implements ICactusPlugin, IPluginWebService {
   private createReceiptFromRunTxReqWithTxId(
     data: IRunTxReqWithTxId,
   ): FabricV2TxReceipt {
+    if (!data.request.signingCredential) {
+      throw new Error(
+        `Cannot create FabricV2TxReceipt if signingCredential is missing in IRunTxReqWithTxId`,
+      );
+    }
     return {
       caseID: this.caseID,
       blockchainID: LedgerType.Fabric2,

packages/cactus-plugin-ledger-connector-fabric/.env.template

@@ -0,0 +1,19 @@
+CONNECTION_PROFILE=path_to_connection_profile
+RELAY_ENDPOINT=localhost:9080
+RELAY_TLS=false
+RELAY_TLSCA_CERT_PATH=path_to_tls_ca_cert_pem_for_relay
+DRIVER_ENDPOINT=localhost:9090
+DRIVER_TLS=false
+DRIVER_TLS_CERT_PATH=path_to_tls_cert_pem_for_driver
+DRIVER_TLS_KEY_PATH=path_to_tls_key_pem_for_driver
+NETWORK_NAME=network1
+DRIVER_CONFIG=
+INTEROP_CHAINCODE=interop
+MOCK=false
+DB_PATH=driverdbs
+WALLET_PATH=
+DEBUG=true
+LEVELDB_LOCKED_MAX_RETRIES=
+LEVELDB_LOCKED_RETRY_BACKOFF_MSEC=
+ENABLE_MONITOR=false
+MONITOR_SYNC_PERIOD=

packages/cactus-plugin-ledger-connector-fabric/.gitignore

@@ -0,0 +1,6 @@
+.env
+wallet-network1/*.id
+!wallet-network1/relay.id
+wallet-network2/*.id
+!wallet-network2/relay.id
+driverdbs

packages/cactus-plugin-ledger-connector-fabric/buf.gen.yaml

@@ -0,0 +1,13 @@
+version: v2
+clean: true
+plugins:
+  - local: protoc-gen-es
+    out: src/main/typescript/generated/protos/
+    opt: target=ts
+    strategy: directory
+  - local: protoc-gen-connect-es
+    out: src/main/typescript/generated/protos/
+    opt:
+      - target=ts
+      - js_import_style=module
+    strategy: directory

packages/cactus-plugin-ledger-connector-fabric/buf.yaml

@@ -0,0 +1,17 @@
+version: v2
+modules:
+  - path: src/main/protos/driver-protos
+  - path: src/main/protos/fabric-protos
+lint:
+  use:
+    - STANDARD
+  except:
+    - PACKAGE_VERSION_SUFFIX
+  enum_zero_value_suffix: _UNSPECIFIED
+  rpc_allow_same_request_response: true
+  rpc_allow_google_protobuf_empty_requests: true
+  rpc_allow_google_protobuf_empty_responses: true
+  service_suffix: Service
+breaking:
+  use:
+    - FILE

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

@@ -0,0 +1,14 @@
+{
+    "admin":{
+        "name":"admin",
+        "secret":"adminpw"
+    },
+    "relay": {
+        "name":"relay",
+        "affiliation":"org1.department1",
+        "role": "client",
+        "attrs": [{ "name": "relay", "value": "true", "ecert": true }]
+    },
+    "mspId":"Org1MSP",
+    "caUrl":""
+}

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

@@ -43,8 +43,10 @@
     "dist/*"
   ],
   "scripts": {
+    "start-fabric-weaver-driver": "node ./dist/lib/main/typescript/plugin-ledger-connector-fabric-cli.js",
     "codegen": "yarn run --top-level run-s 'codegen:*'",
     "codegen:openapi": "npm run generate-sdk",
+    "codegen:proto": "buf generate --verbose",
     "generate-sdk": "run-p 'generate-sdk:*'",
     "generate-sdk:go": "openapi-generator-cli generate -i ./src/main/json/openapi.json -g go -o ./src/main/go/generated/openapi/go-client/ --git-user-id hyperledger --git-repo-id $(echo $npm_package_name | replace @hyperledger/ \"\" -z)/src/main/go/generated/openapi/go-client --package-name $(echo $npm_package_name | replace @hyperledger/ \"\" -z)  --reserved-words-mappings protected=protected --ignore-file-override ../../openapi-generator-ignore",
     "generate-sdk:kotlin": "openapi-generator-cli generate -i ./src/main/json/openapi.json -g kotlin -o ./src/main/kotlin/generated/openapi/kotlin-client/ --reserved-words-mappings protected=protected --ignore-file-override ../../openapi-generator-ignore",
@@ -56,14 +58,21 @@
     "webpack:dev:web": "webpack --env=dev --target=web --config ../../webpack.config.js"
   },
   "dependencies": {
+    "@bufbuild/protobuf": "2.2.2",
+    "@connectrpc/connect": "2.0.0",
+    "@connectrpc/connect-express": "2.0.0",
+    "@connectrpc/connect-node": "2.0.0",
+    "@connectrpc/protoc-gen-connect-es": "1.6.1",
     "@fidm/x509": "1.2.1",
+    "@hyperledger/cacti-weaver-protos-js": "2.1.0",
     "@hyperledger/cactus-common": "2.1.0",
     "@hyperledger/cactus-core": "2.1.0",
     "@hyperledger/cactus-core-api": "2.1.0",
     "axios": "1.8.4",
     "bl": "6.1.0",
     "bn.js": "4.12.0",
     "dockerode": "3.3.0",
+    "dotenv": "17.2.3",
     "elliptic": "6.6.1",
     "express": "5.1.0",
     "fabric-ca-client": "2.5.0-snapshot.23",
@@ -72,11 +81,14 @@
     "fabric-protos": "2.5.0-snapshot.23",
     "fast-safe-stringify": "2.1.1",
     "form-data": "4.0.0",
+    "google-protobuf": "3.21.2",
     "http-errors": "2.0.0",
     "http-status-codes": "2.1.4",
+    "http2": "^3.3.7",
     "joi": "17.13.3",
     "json5": "2.2.3",
     "jsrsasign": "11.0.0",
+    "level": "8.0.0",
     "lodash": "4.17.21",
     "long": "5.2.3",
     "multer": "1.4.5-lts.1",
@@ -99,6 +111,10 @@
     "ws-identity-client": "1.0.2"
   },
   "devDependencies": {
+    "@bufbuild/buf": "1.47.2",
+    "@bufbuild/protoc-gen-es": "2.2.2",
+    "@grpc/grpc-js": "1.13.3",
+    "@grpc/proto-loader": "0.7.13",
     "@hyperledger/cactus-plugin-keychain-memory": "2.1.0",
     "@hyperledger/cactus-test-tooling": "2.1.0",
     "@types/bn.js": "5.1.0",
@@ -107,6 +123,7 @@
     "@types/elliptic": "6.4.16",
     "@types/express": "5.0.1",
     "@types/fs-extra": "11.0.4",
+    "@types/google-protobuf": "3.15.12",
     "@types/http-errors": "2.0.4",
     "@types/jsrsasign": "8.0.13",
     "@types/lodash": "4.14.172",
@@ -118,7 +135,9 @@
     "@types/uuid": "10.0.0",
     "body-parser": "1.20.3",
     "fs-extra": "11.2.0",
+    "grpc_tools_node_protoc_ts": "5.3.3",
     "internal-ip": "6.2.0",
+    "protobufjs": "7.2.5",
     "socket.io": "4.6.2",
     "ws-wallet": "1.1.5"
   },

packages/cactus-plugin-ledger-connector-fabric/src/main/go/generated/openapi/go-client/.openapi-generator/FILES

@@ -22,11 +22,15 @@ model_deploy_contract_v1_request_constructor_args.go
 model_deploy_contract_v1_response.go
 model_deployment_target_org_fabric2x.go
 model_deployment_target_organization.go
+model_endorsed_proposal_response.go
+model_endorsement.go
 model_error_exception_response_v1.go
+model_event_type.go
 model_fabric_certificate_identity_v1.go
 model_fabric_contract_invocation_type.go
 model_fabric_signing_credential.go
 model_fabric_signing_credential_type.go
+model_fabric_view.go
 model_fabric_x509_certificate_v1.go
 model_file_base64.go
 model_full_block_transaction_action_v1.go
@@ -53,8 +57,13 @@ model_get_discovery_results_response_v1_orderers_value_endpoints_inner.go
 model_get_discovery_results_response_v1_peers_by_msp_value.go
 model_get_discovery_results_response_v1_peers_by_msp_value_peers_inner.go
 model_get_discovery_results_response_v1_peers_by_msp_value_peers_inner_chaincodes_inner.go
+model_get_latest_block_number_request_v1.go
+model_get_latest_block_number_response_v1.go
 model_get_transaction_receipt_response.go
+model_proposal_response_payload.go
 model_run_delegated_sign_transaction_request.go
+model_run_invoke_request.go
+model_run_invoke_response.go
 model_run_transaction_request.go
 model_run_transaction_response.go
 model_run_transaction_response_type.go

packages/cactus-plugin-ledger-connector-fabric/src/main/go/generated/openapi/go-client/README.md

@@ -81,6 +81,7 @@ Class | Method | HTTP request | Description
 *DefaultApi* | [**GetBlockV1**](docs/DefaultApi.md#getblockv1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-block | Get block from the channel using one of selectors from the input. Works only on Fabric 2.x.
 *DefaultApi* | [**GetChainInfoV1**](docs/DefaultApi.md#getchaininfov1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-chain-info | Get fabric ledger chain info.
 *DefaultApi* | [**GetDiscoveryResultsV1**](docs/DefaultApi.md#getdiscoveryresultsv1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-discovery-results | Get fabric ledger node structure (from the discovery service).
+*DefaultApi* | [**GetLatestBlockNumberV1**](docs/DefaultApi.md#getlatestblocknumberv1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-latest-block-number | Get block number from the channel using one of selectors from the input. Works only on Fabric 2.x.
 *DefaultApi* | [**GetPrometheusMetricsV1**](docs/DefaultApi.md#getprometheusmetricsv1) | **Get** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-prometheus-exporter-metrics | Get the Prometheus Metrics
 *DefaultApi* | [**GetTransactionReceiptByTxIDV1**](docs/DefaultApi.md#gettransactionreceiptbytxidv1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/get-transaction-receipt-by-txid | get a transaction receipt by tx id on a Fabric ledger.
 *DefaultApi* | [**RunDelegatedSignTransactionV1**](docs/DefaultApi.md#rundelegatedsigntransactionv1) | **Post** /api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-fabric/run-delegated-sign-transaction | Runs a transaction on a Fabric ledger using user-provided signing callback.
@@ -105,11 +106,15 @@ Class | Method | HTTP request | Description
  - [DeployContractV1Response](docs/DeployContractV1Response.md)
  - [DeploymentTargetOrgFabric2x](docs/DeploymentTargetOrgFabric2x.md)
  - [DeploymentTargetOrganization](docs/DeploymentTargetOrganization.md)
+ - [EndorsedProposalResponse](docs/EndorsedProposalResponse.md)
+ - [Endorsement](docs/Endorsement.md)
  - [ErrorExceptionResponseV1](docs/ErrorExceptionResponseV1.md)
+ - [EventType](docs/EventType.md)
  - [FabricCertificateIdentityV1](docs/FabricCertificateIdentityV1.md)
  - [FabricContractInvocationType](docs/FabricContractInvocationType.md)
  - [FabricSigningCredential](docs/FabricSigningCredential.md)
  - [FabricSigningCredentialType](docs/FabricSigningCredentialType.md)
+ - [FabricView](docs/FabricView.md)
  - [FabricX509CertificateV1](docs/FabricX509CertificateV1.md)
  - [FileBase64](docs/FileBase64.md)
  - [FullBlockTransactionActionV1](docs/FullBlockTransactionActionV1.md)
@@ -136,8 +141,13 @@ Class | Method | HTTP request | Description
  - [GetDiscoveryResultsResponseV1PeersByMSPValue](docs/GetDiscoveryResultsResponseV1PeersByMSPValue.md)
  - [GetDiscoveryResultsResponseV1PeersByMSPValuePeersInner](docs/GetDiscoveryResultsResponseV1PeersByMSPValuePeersInner.md)
  - [GetDiscoveryResultsResponseV1PeersByMSPValuePeersInnerChaincodesInner](docs/GetDiscoveryResultsResponseV1PeersByMSPValuePeersInnerChaincodesInner.md)
+ - [GetLatestBlockNumberRequestV1](docs/GetLatestBlockNumberRequestV1.md)
+ - [GetLatestBlockNumberResponseV1](docs/GetLatestBlockNumberResponseV1.md)
  - [GetTransactionReceiptResponse](docs/GetTransactionReceiptResponse.md)
+ - [ProposalResponsePayload](docs/ProposalResponsePayload.md)
  - [RunDelegatedSignTransactionRequest](docs/RunDelegatedSignTransactionRequest.md)
+ - [RunInvokeRequest](docs/RunInvokeRequest.md)
+ - [RunInvokeResponse](docs/RunInvokeResponse.md)
  - [RunTransactionRequest](docs/RunTransactionRequest.md)
  - [RunTransactionResponse](docs/RunTransactionResponse.md)
  - [RunTransactionResponseType](docs/RunTransactionResponseType.md)