TPS support for sovereign

config/config.devnet-old.yaml

@@ -24,6 +24,8 @@ flags:
   processNfts: true
   collectionPropertiesFromGateway: false
 features:
+  sovereign:
+    enabled: false
   eventsNotifier:
     enabled: false
     port: 5674

config/config.devnet.yaml

@@ -20,6 +20,8 @@ flags:
   processNfts: true
   collectionPropertiesFromGateway: false
 features:
+  sovereign:
+    enabled: false
   eventsNotifier:
     enabled: false
     port: 5674

config/config.e2e-mocked.mainnet.yaml

@@ -5,6 +5,8 @@ api:
   private: true
   graphql: true
 features:
+  sovereign:
+    enabled: false
   dataApi:
     enabled: false
     serviceUrl: 'https://data-api.multiversx.com'

config/config.e2e.mainnet.yaml

@@ -5,6 +5,8 @@ api:
   private: true
   graphql: true
 features:
+  sovereign:
+    enabled: false
   dataApi:
     enabled: false
     serviceUrl: 'https://data-api.multiversx.com'

config/config.mainnet.yaml

@@ -20,6 +20,8 @@ flags:
   processNfts: true
   collectionPropertiesFromGateway: false
 features:
+  sovereign:
+    enabled: false
   eventsNotifier:
     enabled: false
     port: 5674

config/config.testnet.yaml

@@ -20,6 +20,8 @@ flags:
   processNfts: true
   collectionPropertiesFromGateway: false
 features:
+  sovereign:
+    enabled: false
   eventsNotifier:
     enabled: false
     port: 5674

src/common/api-config/api.config.service.ts

@@ -327,6 +327,15 @@ export class ApiConfigService {
     return isCronActive;
   }
 
+  isSovereignActive(): boolean {
+    const isSovereignActiveFlag = this.configService.get<boolean>('features.sovereign.enabled');
+    if (isSovereignActiveFlag === undefined) {
+      return false;
+    }
+
+    return isSovereignActiveFlag;
+  }
+
   isEventsNotifierFeatureActive(): boolean {
     const isEventsNotifierActive = this.configService.get<boolean>('features.eventsNotifier.enabled');
     if (isEventsNotifierActive === undefined) {

src/common/protocol/protocol.service.ts

@@ -52,7 +52,10 @@ export class ProtocolService {
       result.push(i);
     }
 
-    result.push(metaChainShardId);
+    if (!this.apiConfigService.isSovereignActive()) {
+      result.push(metaChainShardId);
+    }
+
     return result;
   }
 

src/crons/tps/tps-warmer.service.ts

@@ -47,7 +47,10 @@ export class TpsWarmerService {
     const shardCount = await this.protocolService.getShardCount();
     const metaChainShardId = this.apiConfigService.getMetaChainShardId();
 
-    const shards = [...Array.from({ length: shardCount }, (_, i) => i), metaChainShardId];
+    const shards = [...Array.from({ length: shardCount }, (_, i) => i)];
+    if (!this.apiConfigService.isSovereignActive()) {
+      shards.push(metaChainShardId);
+    }
 
     await Promise.all(shards.map(shardId => this.processTpsForShard(shardId)));
   }

src/endpoints/tps/tps.service.ts

@@ -63,7 +63,10 @@ export class TpsService {
 
   async getTransactionCount(): Promise<number> {
     const totalShards = await this.protocolService.getShardCount();
-    const shardIds = [...Array.from({ length: totalShards }, (_, i) => i), this.apiConfigService.getMetaChainShardId()];
+    const shardIds = [...Array.from({ length: totalShards }, (_, i) => i)];
+    if (!this.apiConfigService.isSovereignActive()) {
+      shardIds.push(this.apiConfigService.getMetaChainShardId());
+    }
 
     let totalTransactions = 0;