Improvements for scheduled miniblocks and getShards call

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

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",

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;
+  }
+}