preocompute account details

config/config.devnet.yaml

@@ -68,6 +68,9 @@ features:
     enabled: false
     cronExpression: '*/5 * * * * *'
     activationEpoch: 1043
+  chainAndromeda:
+    enabled: false
+    activationEpoch: 4
   nodeEpochsLeft:
     enabled: false
   transactionProcessor:

config/config.e2e.mainnet.yaml

@@ -62,6 +62,9 @@ features:
     enabled: false
     cronExpression: '*/5 * * * * *'
     activationEpoch: 1391
+  chainAndromeda:
+    enabled: false
+    activationEpoch: 4
   nodeEpochsLeft:
     enabled: false
   transactionProcessor:

config/config.mainnet.yaml

@@ -62,6 +62,9 @@ features:
     enabled: false
     cronExpression: '*/5 * * * * *'
     activationEpoch: 1391
+  chainAndromeda:
+    enabled: false
+    activationEpoch: 4
   nodeEpochsLeft:
     enabled: false
   transactionProcessor:

config/config.testnet.yaml

@@ -61,6 +61,9 @@ features:
     enabled: false
     cronExpression: '*/5 * * * * *'
     activationEpoch: 1043
+  chainAndromeda:
+    enabled: false
+    activationEpoch: 4
   nodeEpochsLeft:
     enabled: false
   transactionProcessor:

package.json

@@ -84,21 +84,19 @@
   },
   "dependencies": {
     "@aws-sdk/client-s3": "^3.54.0",
-    "@elrondnetwork/erdjs-dex": "^0.2.12-alpha",
-    "@elrondnetwork/native-auth": "^0.1.19",
-    "@elrondnetwork/transaction-processor": "^0.1.26",
     "@golevelup/nestjs-rabbitmq": "^4.0.0",
     "@multiversx/sdk-core": "^13.2.2",
     "@multiversx/sdk-data-api-client": "^0.7.0",
-    "@multiversx/sdk-nestjs-auth": "4.2.0",
-    "@multiversx/sdk-nestjs-cache": "4.2.0",
-    "@multiversx/sdk-nestjs-common": "4.2.0",
-    "@multiversx/sdk-nestjs-elastic": "^4.2.0",
-    "@multiversx/sdk-nestjs-http": "4.2.0",
-    "@multiversx/sdk-nestjs-monitoring": "4.2.0",
-    "@multiversx/sdk-nestjs-rabbitmq": "4.2.0",
-    "@multiversx/sdk-nestjs-redis": "4.2.0",
-    "@multiversx/sdk-wallet": "^4.0.0",
+    "@multiversx/sdk-exchange": "^0.2.21",
+    "@multiversx/sdk-nestjs-auth": "5.0.0",
+    "@multiversx/sdk-nestjs-cache": "5.0.0",
+    "@multiversx/sdk-nestjs-common": "5.0.0",
+    "@multiversx/sdk-nestjs-elastic": "5.0.0",
+    "@multiversx/sdk-nestjs-http": "5.0.0",
+    "@multiversx/sdk-nestjs-monitoring": "5.0.0",
+    "@multiversx/sdk-nestjs-rabbitmq": "5.0.0",
+    "@multiversx/sdk-nestjs-redis": "5.0.0",
+    "@multiversx/sdk-transaction-processor": "^0.1.35",
     "@nestjs/apollo": "12.0.11",
     "@nestjs/common": "10.2.0",
     "@nestjs/config": "3.0.1",

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

@@ -2,8 +2,8 @@ import { Constants } from '@multiversx/sdk-nestjs-common';
 import { Injectable } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
 import { DatabaseConnectionOptions } from '../persistence/entities/connection.options';
-import { LogTopic } from '@elrondnetwork/transaction-processor';
 import { StatusCheckerThresholds } from './entities/status-checker-thresholds';
+import { LogTopic } from '@multiversx/sdk-transaction-processor/lib/types/log-topic';
 
 @Injectable()
 export class ApiConfigService {
@@ -862,6 +862,14 @@ export class ApiConfigService {
     return deepHistoryUrl;
   }
 
+  isChainAndromedaEnabled(): boolean {
+    return this.configService.get<boolean>('features.chainAndromeda.enabled') ?? false;
+  }
+
+  getChainAndromedaActivationEpoch(): number {
+    return this.configService.get<number>('features.chainAndromeda.activationEpoch') ?? 99999;
+  }
+
   isAssetsCdnFeatureEnabled(): boolean {
     return this.configService.get<boolean>('features.assetsFetch.enabled') ?? false;
   }

src/common/indexer/elastic/elastic.indexer.service.ts

@@ -890,7 +890,7 @@ export class ElasticIndexerService implements IndexerInterface {
   async getAllFungibleTokens(): Promise<any[]> {
     const query = ElasticQuery.create()
       .withMustMatchCondition('type', TokenType.FungibleESDT)
-      .withFields(["name", "type", "currentOwner", "numDecimals", "properties", "timestamp", "ownersHistory"])
+      .withFields(["name", "type", "currentOwner", "numDecimals", "properties", "timestamp", "ownersHistory", "paused"])
       .withMustNotExistCondition('identifier')
       .withPagination({ from: 0, size: 1000 });
 

src/common/locked-asset/locked-asset.service.ts

@@ -1,5 +1,4 @@
 import { Injectable } from '@nestjs/common';
-import { LockedAssetAttributes, UnlockMilestone, LockedTokenAttributes } from '@elrondnetwork/erdjs-dex';
 import { ApiConfigService } from '../api-config/api.config.service';
 import { VmQueryService } from '../../endpoints/vm.query/vm.query.service';
 import { CacheInfo } from '../../utils/cache.info';
@@ -10,6 +9,7 @@ import { GatewayService } from '../gateway/gateway.service';
 import { MexSettingsService } from 'src/endpoints/mex/mex.settings.service';
 import { LockedTokensInterface } from './entities/locked.tokens.interface';
 import { UnlockMileStoneModel } from './entities/unlock.milestone.model';
+import { LockedAssetAttributes, UnlockMilestone, LockedTokenAttributes } from '@multiversx/sdk-exchange';
 
 @Injectable()
 export class LockedAssetService {

src/common/websockets/web-socket-publisher-controller.ts

@@ -1,5 +1,5 @@
 import { OriginLogger } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Controller } from "@nestjs/common";
 import { EventPattern } from "@nestjs/microservices";
 import { WebSocketPublisherService } from "src/common/websockets/web-socket-publisher-service";

src/common/websockets/web-socket-publisher-service.ts

@@ -1,5 +1,5 @@
 import { AddressUtils } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Injectable } from "@nestjs/common";
 import { WebSocketGateway, WebSocketServer } from "@nestjs/websockets";
 import { Server, Socket } from 'socket.io';

src/crons/transaction.processor/batch.transaction.processor.service.ts

@@ -1,5 +1,5 @@
 import { CacheService } from "@multiversx/sdk-nestjs-cache";
-import { ShardTransaction, TransactionProcessor } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction, TransactionProcessor } from "@multiversx/sdk-transaction-processor";
 import { Inject, Injectable, Logger } from "@nestjs/common";
 import { ClientProxy } from "@nestjs/microservices";
 import { Cron } from "@nestjs/schedule";

src/crons/transaction.processor/extractor/nft.create.transaction.extractor.ts

@@ -1,5 +1,5 @@
 import { AddressUtils, BinaryUtils, OriginLogger } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Logger } from "@nestjs/common";
 import { TransactionDetailed } from "src/endpoints/transactions/entities/transaction.detailed";
 import { TransactionExtractorInterface } from "./transaction.extractor.interface";

src/crons/transaction.processor/extractor/nft.update.attributes.transaction.extractor.ts

@@ -1,5 +1,5 @@
 import { BinaryUtils } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Logger } from "@nestjs/common";
 import { TransactionExtractorInterface } from "./transaction.extractor.interface";
 

src/crons/transaction.processor/extractor/sft.change.transaction.extractor.ts

@@ -1,5 +1,5 @@
 import { BinaryUtils } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Logger } from "@nestjs/common";
 import { TransactionExtractorInterface } from "./transaction.extractor.interface";
 

src/crons/transaction.processor/extractor/transaction.extractor.interface.ts

@@ -1,4 +1,4 @@
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { TransactionDetailed } from "src/endpoints/transactions/entities/transaction.detailed";
 
 export interface TransactionExtractorInterface<T> {

src/crons/transaction.processor/extractor/transfer.ownership.extractor.ts

@@ -1,5 +1,5 @@
 import { BinaryUtils } from "@multiversx/sdk-nestjs-common";
-import { ShardTransaction } from "@elrondnetwork/transaction-processor";
+import { ShardTransaction } from "@multiversx/sdk-transaction-processor";
 import { Logger } from "@nestjs/common";
 import { TransactionExtractorInterface } from "./transaction.extractor.interface";
 

src/crons/transaction.processor/transaction.completed.service.ts

@@ -1,5 +1,4 @@
 import { CacheService } from "@multiversx/sdk-nestjs-cache";
-import { LogTopic, TransactionProcessor } from "@elrondnetwork/transaction-processor";
 import { Inject, Injectable, Logger } from "@nestjs/common";
 import { ClientProxy } from "@nestjs/microservices";
 import { Cron } from "@nestjs/schedule";
@@ -8,6 +7,8 @@ import { CacheInfo } from "src/utils/cache.info";
 import { LogMetricsEvent } from "src/common/entities/log.metrics.event";
 import { EventEmitter2 } from "@nestjs/event-emitter";
 import { MetricsEvents } from "src/utils/metrics-events.constants";
+import { TransactionProcessor } from "@multiversx/sdk-transaction-processor";
+import { LogTopic } from "@multiversx/sdk-transaction-processor/lib/types/log-topic";
 
 @Injectable()
 export class TransactionCompletedService {

src/crons/transaction.processor/transaction.processor.service.ts

@@ -3,7 +3,6 @@ import { ClientProxy } from "@nestjs/microservices";
 import { Cron } from "@nestjs/schedule";
 import { ApiConfigService } from "src/common/api-config/api.config.service";
 import { NodeService } from "src/endpoints/nodes/node.service";
-import { ShardTransaction, TransactionProcessor } from "@elrondnetwork/transaction-processor";
 import { CacheInfo } from "src/utils/cache.info";
 import { EventEmitter2 } from '@nestjs/event-emitter';
 import { SftChangeTransactionExtractor } from "./extractor/sft.change.transaction.extractor";
@@ -15,7 +14,7 @@ import { CacheService } from "@multiversx/sdk-nestjs-cache";
 import { BinaryUtils, OriginLogger } from "@multiversx/sdk-nestjs-common";
 import { PerformanceProfiler } from "@multiversx/sdk-nestjs-monitoring";
 import { StakeFunction } from "src/endpoints/transactions/transaction-action/recognizers/staking/entities/stake.function";
-
+import { ShardTransaction, TransactionProcessor } from "@multiversx/sdk-transaction-processor";
 
 @Injectable()
 export class TransactionProcessorService {

src/endpoints/blocks/block.service.ts

@@ -9,6 +9,7 @@ import { CacheService } from "@multiversx/sdk-nestjs-cache";
 import { IndexerService } from "src/common/indexer/indexer.service";
 import { NodeService } from "../nodes/node.service";
 import { IdentitiesService } from "../identities/identities.service";
+import { ApiConfigService } from "../../common/api-config/api.config.service";
 
 @Injectable()
 export class BlockService {
@@ -20,13 +21,14 @@ export class BlockService {
     private readonly nodeService: NodeService,
     @Inject(forwardRef(() => IdentitiesService))
     private readonly identitiesService: IdentitiesService,
+    private readonly apiConfigService: ApiConfigService,
   ) { }
 
   async getBlocksCount(filter: BlockFilter): Promise<number> {
     return await this.cachingService.getOrSet(
       CacheInfo.BlocksCount(filter).key,
       async () => await this.indexerService.getBlocksCount(filter),
-      CacheInfo.BlocksCount(filter).ttl
+      CacheInfo.BlocksCount(filter).ttl,
     );
   }
 
@@ -96,21 +98,27 @@ export class BlockService {
       validators = validators.map((index: number) => blses[index]);
     }
 
-    return { shardId, epoch, validators, ...rest, proposer };
+    return {shardId, epoch, validators, ...rest, proposer};
   }
 
   async getBlock(hash: string): Promise<BlockDetailed> {
     const result = await this.indexerService.getBlock(hash) as any;
 
+    const isChainAndromedaEnabled = this.apiConfigService.isChainAndromedaEnabled()
+      && result.epoch >= this.apiConfigService.getChainAndromedaActivationEpoch();
+
     if (result.round > 0) {
       const publicKeys = await this.blsService.getPublicKeys(result.shardId, result.epoch);
       result.proposer = publicKeys[result.proposer];
-      result.validators = result.validators.map((validator: number) => publicKeys[validator]);
+      if (!isChainAndromedaEnabled) {
+        result.validators = result.validators.map((validator: number) => publicKeys[validator]);
+      } else {
+        result.validators = publicKeys;
+      }
     } else {
       result.validators = [];
     }
 
-
     const block = BlockDetailed.mergeWithElasticResponse(new BlockDetailed(), result);
     await this.applyProposerIdentity([block]);
 
@@ -131,7 +139,7 @@ export class BlockService {
       CacheInfo.BlocksLatest(ttl).key,
       async () => await this.getLatestBlockRaw(),
       CacheInfo.BlocksLatest(ttl).ttl,
-      Math.round(CacheInfo.BlocksLatest(ttl).ttl / 10)
+      Math.round(CacheInfo.BlocksLatest(ttl).ttl / 10),
     );
   }
 

src/endpoints/dapp-config/dapp.config.controller.ts

@@ -14,8 +14,8 @@ export class DappConfigController {
   @ApiOperation({ summary: 'Dapp configuration', description: 'Returns configuration used in dapps' })
   @ApiOkResponse({ type: DappConfig })
   @ApiNotFoundResponse({ description: 'Network configuration not found' })
-  getDappConfiguration(): DappConfig {
-    const configuration = this.dappConfigService.getDappConfiguration();
+  async getDappConfiguration(): Promise<DappConfig | undefined> {
+    const configuration = await this.dappConfigService.getDappConfiguration();
     if (!configuration) {
       throw new NotFoundException(`Network configuration not found`);
     }

src/endpoints/dapp-config/dapp.config.service.ts

@@ -2,18 +2,34 @@ import { FileUtils } from "@multiversx/sdk-nestjs-common";
 import { Injectable } from "@nestjs/common";
 import { ApiConfigService } from "src/common/api-config/api.config.service";
 import { DappConfig } from "./entities/dapp-config";
+import { GatewayService } from "src/common/gateway/gateway.service";
 
 @Injectable()
 export class DappConfigService {
   private readonly dappConfig: DappConfig | undefined;
 
   constructor(
     private readonly apiConfigService: ApiConfigService,
+    private readonly gatewayService: GatewayService,
   ) {
     this.dappConfig = this.getDappConfigurationRaw();
   }
 
-  getDappConfiguration(): DappConfig | undefined {
+  async getDappConfiguration(): Promise<DappConfig | undefined> {
+    if (!this.dappConfig) {
+      return undefined;
+    }
+
+    const networkConfig = await this.gatewayService.getNetworkConfig();
+    const refreshRate = networkConfig.erd_round_duration;
+
+    if (refreshRate) {
+      return {
+        ...this.dappConfig,
+        refreshRate,
+      };
+    }
+
     return this.dappConfig;
   }
 

src/endpoints/dapp-config/entities/dapp-config.ts

@@ -43,4 +43,7 @@ export class DappConfig {
 
   @ApiProperty({ type: String, example: '1' })
   chainId: string = '';
+
+  @ApiProperty({ type: Number, example: 6000 })
+  refreshRate: number = 0;
 }

src/endpoints/esdt/esdt.service.ts

@@ -227,7 +227,7 @@ export class EsdtService {
       canAddSpecialRoles: elasticProperties.properties?.canAddSpecialRoles ?? false,
       canTransferNFTCreateRole: elasticProperties.properties?.canTransferNFTCreateRole ?? false,
       NFTCreateStopped: elasticProperties.properties?.NFTCreateStopped ?? false,
-      isPaused: elasticProperties.properties?.isPaused ?? false,
+      isPaused: elasticProperties.paused ?? false,
       timestamp: elasticProperties.timestamp,
     });
 

src/endpoints/media/media.service.ts

@@ -1,6 +1,6 @@
 import { OriginLogger } from "@multiversx/sdk-nestjs-common";
 import { ApiService } from "@multiversx/sdk-nestjs-http";
-import { BadRequestException, Injectable } from "@nestjs/common";
+import { Injectable } from "@nestjs/common";
 import { ApiConfigService } from "src/common/api-config/api.config.service";
 
 @Injectable()
@@ -17,7 +17,8 @@ export class MediaService {
   public async getRedirectUrl(uri: string): Promise<string | undefined> {
     const isFeatureEnabled = this.apiConfigService.isMediaRedirectFeatureEnabled();
     if (!isFeatureEnabled) {
-      throw new BadRequestException('Media redirect is not allowed');
+      // TODO: throw error
+      // throw new BadRequestException('Media redirect is not allowed');
     }
 
     // providers logos

src/endpoints/nfts/nft.service.ts

@@ -653,25 +653,31 @@ export class NftService {
   }
 
   private applyRedirectMedia(nft: Nft) {
+    // FIXME: This is a temporary fix to avoid breaking the API
     const isMediaRedirectFeatureEnabled = this.apiConfigService.isMediaRedirectFeatureEnabled();
     if (!isMediaRedirectFeatureEnabled) {
-      return;
+      // return;
     }
 
     if (!nft.media || nft.media.length === 0) {
       return;
     }
 
-    const network = this.apiConfigService.getNetwork();
-    const defaultMediaUrl = `https://${network === 'mainnet' ? '' : `${network}-`}media.elrond.com`;
+    try {
+      const network = this.apiConfigService.getNetwork();
+      // const defaultMediaUrl = `https://${network === 'mainnet' ? '' : `${network}-`}media.elrond.com`;
+      const defaultMediaUrl = `https://${network === 'mainnet' ? '' : `${network}-`}api.multiversx.com/media`;
 
-    for (const media of nft.media) {
-      if (media.url) {
-        media.url = media.url.replace(defaultMediaUrl, this.apiConfigService.getMediaUrl());
-      }
-      if (media.thumbnailUrl) {
-        media.thumbnailUrl = media.thumbnailUrl.replace(defaultMediaUrl, this.apiConfigService.getMediaUrl());
+      for (const media of nft.media) {
+        if (media.url) {
+          media.url = media.url.replace(defaultMediaUrl, this.apiConfigService.getMediaUrl());
+        }
+        if (media.thumbnailUrl) {
+          media.thumbnailUrl = media.thumbnailUrl.replace(defaultMediaUrl, this.apiConfigService.getMediaUrl());
+        }
       }
+    } catch {
+      // TODO: there are some cases where the nft.media is an empty object, we should investigate why
     }
   }
 }