Improvements for scheduled miniblocks and getShards call (#25)

* Improvements for scheduled miniblocks and getShards call * code review fixes * shardIds as instance variable instead of static --------- Co-authored-by: tanghel <[email protected]>
multiversx · Oct 1, 2024 · 2ba4f53 · 2ba4f53
1 parent dae4ef4
commit 2ba4f53
Show file tree

Hide file tree

Showing 20 changed files with 380 additions and 177 deletions.
diff --git a/example/crons/transaction.processor.service.ts b/example/crons/transaction.processor.service.ts
@@ -18,7 +18,7 @@ export class TransactionProcessorService {
   async handleNewMultiversxTransactions() {
     Locker.lock('newMultiversxTransactions', async () => {
       await this.transactionProcessor.start({
-        mode: TransactionProcessorMode.Hyperblock,
+        mode: TransactionProcessorMode.Shardblock,
         gatewayUrl: 'https://gateway.multiversx.com', // mainnet
         getLastProcessedNonce: async (_shardId: number, _currentNonce: number) => {
           // In ProcessByHyperblockTransactions shardId will always be METACHAIN

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@multiversx/sdk-transaction-processor",
-  "version": "0.1.34",
+  "version": "0.1.35",
   "description": "Real-time transaction processor",
   "main": "lib/transaction.processor.js",
   "types": "lib/transaction.processor.d.ts",

diff --git a/src/shards-maintainer.service.ts b/src/shards-maintainer.service.ts
@@ -0,0 +1,34 @@
+import { METACHAIN } from "./utils/constants";
+import { HttpService } from "./utils/http.service";
+
+export class ShardsMaintainerService {
+  private shardIds: number[] | undefined = undefined;
+
+  async get(
+    baseUrl: string | undefined,
+    timeout: number | undefined,
+  ) {
+    if (this.shardIds != null) {
+      return this.shardIds;
+    }
+
+    return this.shardIds = await this.getShards(baseUrl, timeout);
+  }
+
+  private async getShards(
+    baseUrl: string | undefined,
+    timeout: number | undefined,
+  ): Promise<number[]> {
+    const httpService = new HttpService(baseUrl, timeout);
+    const networkConfig = await httpService.get('network/config');
+    const shardCount = networkConfig.config.erd_num_shards_without_meta;
+
+    const result = [];
+    for (let i = 0; i < shardCount; i++) {
+      result.push(i);
+    }
+    result.push(METACHAIN);
+
+    return result;
+  }
+}