feat(iroha-connector): add prometheus exporter to the plugin

Primary Changes ---------------- 1. Added Prometheus Exporter to Iroha ledger plugin 2. Added Prometheus Metrics tracker to relevant iroha tests. Fixes #1260 Signed-off-by: ashnashahgrover <ashnashahgrover777@gmail.com>
hyperledger-cacti · Aug 5, 2024 · 901cab4 · 901cab4
1 parent fdce6b3
commit 901cab4
Show file tree

Hide file tree

Showing 15 changed files with 390 additions and 4 deletions.
diff --git a/...ration/plugin-ledger-connector-besu/deploy-contract/v21-deploy-contract-from-json.test.ts b/...ration/plugin-ledger-connector-besu/deploy-contract/v21-deploy-contract-from-json.test.ts
@@ -463,6 +463,7 @@ describe("PluginLedgerConnectorBesu", () => {
 
   test("get prometheus exporter metrics", async () => {
     const res = await apiClient.getPrometheusMetricsV1();
+    //print(res.data) 
     const promMetricsOutput =
       "# HELP " +
       K_CACTUS_BESU_TOTAL_TX_COUNT +
@@ -474,6 +475,7 @@ describe("PluginLedgerConnectorBesu", () => {
       '{type="' +
       K_CACTUS_BESU_TOTAL_TX_COUNT +
       '"} 9';
+
 
     expect(res).toBeTruthy();
     expect(res.data).toBeTruthy();

diff --git a/packages/cactus-plugin-ledger-connector-iroha2/package.json b/packages/cactus-plugin-ledger-connector-iroha2/package.json
@@ -58,6 +58,7 @@
     "express": "4.19.2",
     "fast-safe-stringify": "2.1.1",
     "hada": "0.0.8",
+    "prom-client": "15.1.3",
     "rxjs": "7.8.1",
     "sanitize-html": "2.12.1",
     "socket.io": "4.6.2",

diff --git a/packages/cactus-plugin-ledger-connector-iroha2/src/main/json/openapi.json b/packages/cactus-plugin-ledger-connector-iroha2/src/main/json/openapi.json
@@ -488,6 +488,10 @@
           }
         }
       },
+      "PrometheusExporterMetricsResponse": {
+        "type": "string",
+        "nullable": false
+      },
       "GenerateTransactionRequestV1": {
         "type": "object",
         "description": "Request for generating transaction or query payload that can be signed on the client side.",
@@ -623,6 +627,31 @@
         }
       }
     },
+    "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/get-prometheus-exporter-metrics": {
+      "get": {
+        "x-hyperledger-cacti": {
+          "http": {
+            "verbLowerCase": "get",
+            "path": "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/get-prometheus-exporter-metrics"
+          }
+        },
+        "operationId": "getPrometheusMetricsV1",
+        "summary": "Get the Prometheus Metrics",
+        "parameters": [],
+        "responses": {
+          "200": {
+            "description": "OK",
+            "content": {
+              "text/plain": {
+                "schema": {
+                  "$ref": "#/components/schemas/PrometheusExporterMetricsResponse"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
     "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/query": {
       "post": {
         "x-hyperledger-cacti": {

diff --git a/packages/cactus-plugin-ledger-connector-iroha2/src/main/json/openapi.tpl.json b/packages/cactus-plugin-ledger-connector-iroha2/src/main/json/openapi.tpl.json
@@ -488,6 +488,10 @@
           }
         }
       },
+      "PrometheusExporterMetricsResponse": {
+        "type": "string",
+        "nullable": false
+      },
       "GenerateTransactionRequestV1": {
         "type": "object",
         "description": "Request for generating transaction or query payload that can be signed on the client side.",
@@ -623,6 +627,31 @@
         }
       }
     },
+    "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/get-prometheus-exporter-metrics": {
+      "get": {
+        "x-hyperledger-cacti": {
+          "http": {
+            "verbLowerCase": "get",
+            "path": "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/get-prometheus-exporter-metrics"
+          }
+        },
+        "operationId": "getPrometheusMetricsV1",
+        "summary": "Get the Prometheus Metrics",
+        "parameters": [],
+        "responses": {
+          "200": {
+            "description": "OK",
+            "content": {
+              "text/plain": {
+                "schema": {
+                  "$ref": "#/components/schemas/PrometheusExporterMetricsResponse"
+                }
+              }
+            }
+          }
+        }
+      }
+    },
     "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/query": {
       "post": {
         "x-hyperledger-cacti": {

diff --git a/...tus-plugin-ledger-connector-iroha2/src/main/typescript/cactus-iroha-sdk-wrapper/client.ts b/...tus-plugin-ledger-connector-iroha2/src/main/typescript/cactus-iroha-sdk-wrapper/client.ts
@@ -76,6 +76,7 @@ import {
   Iroha2BaseConfigTorii,
 } from "../generated/openapi/typescript-axios";
 import { IrohaV2PrerequisitesProvider } from "./prerequisites-provider";
+import { PrometheusExporter } from "../prometheus-exporter/prometheus-exporter";
 
 setCrypto(crypto);
 
@@ -843,6 +844,7 @@ export class CactusIrohaV2Client {
   public async sendSignedPayload(
     signedPayload: VersionedSignedTransaction | ArrayBufferView,
     waitForCommit = false,
+    prometheusExporter: PrometheusExporter, 
   ): Promise<TransactResponseV1> {
     Checks.truthy(signedPayload, "sendSigned arg signedPayload");
 
@@ -853,12 +855,18 @@ export class CactusIrohaV2Client {
     const hash = computeTransactionHash(signedPayload.as("V1").payload);
     if (waitForCommit) {
       const statusPromise = this.waitForTransactionStatus(hash);
+      //counter will increase here 
+      prometheusExporter.addCurrentTransaction() 
+
       await Torii.submit(
         this.prerequisitesProvider.getApiHttpProperties(),
         signedPayload,
       );
       return await statusPromise;
     } else {
+      //counter will increase here 
+      prometheusExporter.addCurrentTransaction() 
+
       await Torii.submit(
         this.prerequisitesProvider.getApiHttpProperties(),
         signedPayload,

diff --git a/...gin-ledger-connector-iroha2/src/main/typescript/generated/openapi/typescript-axios/api.ts b/...gin-ledger-connector-iroha2/src/main/typescript/generated/openapi/typescript-axios/api.ts
@@ -659,6 +659,36 @@ export const DefaultApiAxiosParamCreator = function (configuration?: Configurati
                 options: localVarRequestOptions,
             };
         },
+        /**
+         * 
+         * @summary Get the Prometheus Metrics
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        getPrometheusMetricsV1: async (options: AxiosRequestConfig = {}): Promise<RequestArgs> => {
+            const localVarPath = `/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-iroha2/get-prometheus-exporter-metrics`;
+            // use dummy base URL string because the URL constructor only accepts absolute URLs.
+            const localVarUrlObj = new URL(localVarPath, DUMMY_BASE_URL);
+            let baseOptions;
+            if (configuration) {
+                baseOptions = configuration.baseOptions;
+            }
+
+            const localVarRequestOptions = { method: 'GET', ...baseOptions, ...options};
+            const localVarHeaderParameter = {} as any;
+            const localVarQueryParameter = {} as any;
+
+
+
+            setSearchParams(localVarUrlObj, localVarQueryParameter);
+            let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
+            localVarRequestOptions.headers = {...localVarHeaderParameter, ...headersFromBaseOptions, ...options.headers};
+
+            return {
+                url: toPathString(localVarUrlObj),
+                options: localVarRequestOptions,
+            };
+        },
         /**
          * 
          * @summary Executes a query on a Iroha V2 ledger and returns it\'s results.
@@ -748,6 +778,16 @@ export const DefaultApiFp = function(configuration?: Configuration) {
             const localVarAxiosArgs = await localVarAxiosParamCreator.generateTransactionV1(generateTransactionRequestV1, options);
             return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);
         },
+        /**
+         * 
+         * @summary Get the Prometheus Metrics
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        async getPrometheusMetricsV1(options?: AxiosRequestConfig): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<string>> {
+            const localVarAxiosArgs = await localVarAxiosParamCreator.getPrometheusMetricsV1(options);
+            return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);
+        },
         /**
          * 
          * @summary Executes a query on a Iroha V2 ledger and returns it\'s results.
@@ -790,6 +830,15 @@ export const DefaultApiFactory = function (configuration?: Configuration, basePa
         generateTransactionV1(generateTransactionRequestV1?: GenerateTransactionRequestV1, options?: any): AxiosPromise<string> {
             return localVarFp.generateTransactionV1(generateTransactionRequestV1, options).then((request) => request(axios, basePath));
         },
+        /**
+         * 
+         * @summary Get the Prometheus Metrics
+         * @param {*} [options] Override http request option.
+         * @throws {RequiredError}
+         */
+        getPrometheusMetricsV1(options?: any): AxiosPromise<string> {
+            return localVarFp.getPrometheusMetricsV1(options).then((request) => request(axios, basePath));
+        },
         /**
          * 
          * @summary Executes a query on a Iroha V2 ledger and returns it\'s results.
@@ -832,6 +881,17 @@ export class DefaultApi extends BaseAPI {
         return DefaultApiFp(this.configuration).generateTransactionV1(generateTransactionRequestV1, options).then((request) => request(this.axios, this.basePath));
     }
 
+    /**
+     * 
+     * @summary Get the Prometheus Metrics
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     * @memberof DefaultApi
+     */
+    public getPrometheusMetricsV1(options?: AxiosRequestConfig) {
+        return DefaultApiFp(this.configuration).getPrometheusMetricsV1(options).then((request) => request(this.axios, this.basePath));
+    }
+
     /**
      * 
      * @summary Executes a query on a Iroha V2 ledger and returns it\'s results.

diff --git a/...ctus-plugin-ledger-connector-iroha2/src/main/typescript/plugin-ledger-connector-iroha2.ts b/...ctus-plugin-ledger-connector-iroha2/src/main/typescript/plugin-ledger-connector-iroha2.ts
@@ -64,6 +64,13 @@ import { CactusIrohaV2QueryClient } from "./cactus-iroha-sdk-wrapper/query";
 import { LengthOf, stringifyBigIntReplacer } from "./utils";
 import { createAccountId } from "./cactus-iroha-sdk-wrapper/data-factories";
 
+import {
+  GetPrometheusExporterMetricsEndpointV1,
+  IGetPrometheusExporterMetricsEndpointV1Options,
+} from "./web-services/get-prometheus-exporter-metrics-endpoint-v1";
+import { PrometheusExporter } from "./prometheus-exporter/prometheus-exporter";
+
+
 /**
  * Input options for PluginLedgerConnectorIroha2.
  */
@@ -72,6 +79,7 @@ export interface IPluginLedgerConnectorIroha2Options
   pluginRegistry: PluginRegistry;
   logLevel?: LogLevelDesc;
   defaultConfig?: Iroha2BaseConfig;
+  prometheusExporter?: PrometheusExporter;
 }
 
 /**
@@ -84,6 +92,7 @@ export class PluginLedgerConnectorIroha2
     IPluginWebService
 {
   private readonly instanceId: string;
+  public prometheusExporter: PrometheusExporter;
   private readonly log: Logger;
   private readonly defaultConfig: Iroha2BaseConfig | undefined;
   private endpoints: IWebServiceEndpoint[] | undefined;
@@ -102,6 +111,17 @@ export class PluginLedgerConnectorIroha2
 
     this.instanceId = options.instanceId;
 
+    this.prometheusExporter =
+      options.prometheusExporter ||
+      new PrometheusExporter({ pollingIntervalInMin: 1 });
+    Checks.truthy(
+      this.prometheusExporter,
+      `${fnTag} options.prometheusExporter`,
+    );
+
+    this.prometheusExporter.startMetricsCollection();
+
+
     this.defaultConfig = options.defaultConfig;
     // Remove proto in case we use merge method vulnerable to proto pollution
     if (this.defaultConfig instanceof Object) {
@@ -133,6 +153,16 @@ export class PluginLedgerConnectorIroha2
     return OAS;
   }
 
+  public getPrometheusExporter(): PrometheusExporter {
+    return this.prometheusExporter;
+  }
+
+  public async getPrometheusExporterMetrics(): Promise<string> {
+    const res: string = await this.prometheusExporter.getPrometheusMetrics();
+    this.log.debug(`getPrometheusExporterMetrics() response: %o`, res);
+    return res;
+  }
+
   /**
    * @warning Method not implemented - do not use!
    */
@@ -266,6 +296,15 @@ export class PluginLedgerConnectorIroha2
       }),
     ];
 
+    {
+      const opts: IGetPrometheusExporterMetricsEndpointV1Options = {
+        connector: this,
+        logLevel: this.options.logLevel,
+      };
+      const endpoint = new GetPrometheusExporterMetricsEndpointV1(opts);
+      endpoints.push(endpoint);
+    }
+
     this.endpoints = endpoints;
     return endpoints;
   }
@@ -584,12 +623,14 @@ export class PluginLedgerConnectorIroha2
    * @returns `TransactionPayloadParameters` or `undefined`
    */
   private tryParseTransactionParams(
+    prometheusExporter: PrometheusExporter,
     reqParams?: IrohaTransactionParametersV1,
   ): TransactionPayloadParameters | undefined {
     if (!reqParams) {
       return undefined;
     }
-
+    //counter will increase here
+    prometheusExporter.addCurrentTransaction() 
     return {
       ttl: reqParams.ttl ? BigInt(reqParams.ttl) : undefined,
       creationTime: reqParams.creationTime
@@ -610,12 +651,13 @@ export class PluginLedgerConnectorIroha2
   public async transact(req: TransactRequestV1): Promise<TransactResponseV1> {
     const fnTag = `${this.className}:transact()`;
     const client = await this.createClient(req.baseConfig);
-
+    //
+
     try {
       if (req.transaction) {
         this.processInstructionsRequests(client, req.transaction.instruction);
         return await client.send(
-          this.tryParseTransactionParams(req.transaction.params),
+          this.tryParseTransactionParams(this.prometheusExporter, req.transaction.params),
           req.waitForCommit,
         );
       } else if (req.signedTransaction) {
@@ -625,6 +667,7 @@ export class PluginLedgerConnectorIroha2
         return await client.sendSignedPayload(
           transactionBinary,
           req.waitForCommit,
+          this.prometheusExporter
         );
       } else {
         const eMsg =
@@ -695,7 +738,7 @@ export class PluginLedgerConnectorIroha2
     try {
       if ("instruction" in req.request) {
         this.processInstructionsRequests(client, req.request.instruction);
-        const txParams = this.tryParseTransactionParams(req.request.params);
+        const txParams = this.tryParseTransactionParams(this.prometheusExporter, req.request.params);
         const payloadTypedArray = client.getTransactionPayloadBuffer(txParams);
         const payloadBuffer = Buffer.from(payloadTypedArray);
         const payloadBase64 = payloadBuffer.toString("base64");

diff --git a/...us-plugin-ledger-connector-iroha2/src/main/typescript/prometheus-exporter/data-fetcher.ts b/...us-plugin-ledger-connector-iroha2/src/main/typescript/prometheus-exporter/data-fetcher.ts
@@ -0,0 +1,10 @@
+import { Transactions } from "./response.type";
+
+import { totalTxCount, K_CACTUS_IROHA2_TOTAL_TX_COUNT } from "./metrics";
+
+export async function collectMetrics(
+  transactions: Transactions,
+): Promise<void> {
+  transactions.counter++;
+  totalTxCount.labels(K_CACTUS_IROHA2_TOTAL_TX_COUNT).set(transactions.counter);
+}
diff --git a/.../cactus-plugin-ledger-connector-iroha2/src/main/typescript/prometheus-exporter/metrics.ts b/.../cactus-plugin-ledger-connector-iroha2/src/main/typescript/prometheus-exporter/metrics.ts
@@ -0,0 +1,10 @@
+import { Gauge } from "prom-client";
+
+export const K_CACTUS_IROHA2_TOTAL_TX_COUNT = "cactus_iroha2_total_tx_count";
+
+export const totalTxCount = new Gauge({
+  registers: [],
+  name: "cactus_iroha2_total_tx_count",
+  help: "Total transactions executed",
+  labelNames: ["type"],
+});