Integrate last sdk nestjs (#1516)

* update to latest sdk version

* fixes for latest sdk version

* add package-lock

* fix unit tests

Author: stefangutica

package-lock.json

@@ -89,14 +89,14 @@
     "@multiversx/sdk-core": "^13.2.2",
     "@multiversx/sdk-data-api-client": "^0.7.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-nestjs-auth": "6.0.0",
+    "@multiversx/sdk-nestjs-cache": "6.0.0",
+    "@multiversx/sdk-nestjs-common": "6.0.0",
+    "@multiversx/sdk-nestjs-elastic": "6.0.0",
+    "@multiversx/sdk-nestjs-http": "6.0.0",
+    "@multiversx/sdk-nestjs-monitoring": "6.0.0",
+    "@multiversx/sdk-nestjs-rabbitmq": "6.0.0",
+    "@multiversx/sdk-nestjs-redis": "6.0.0",
     "@multiversx/sdk-transaction-processor": "^0.1.35",
     "@nestjs/apollo": "12.0.11",
     "@nestjs/common": "10.2.0",

package.json

@@ -12,10 +12,10 @@ export class PubSubListenerController {
   ) { }
 
   @EventPattern('deleteCacheKeys')
-  async deleteCacheKey(keys: string[]) {
+  deleteCacheKey(keys: string[]) {
     for (const key of keys) {
       this.logger.log(`Deleting local cache key ${key}`);
-      await this.cachingService.deleteLocal(key);
+      this.cachingService.deleteLocal(key);
     }
   }
 

src/common/pubsub/pub.sub.listener.controller.ts

@@ -25,7 +25,7 @@ export class RabbitMqNftHandlerService {
   ) { }
 
   private async getCollectionType(collectionIdentifier: string): Promise<NftType | null> {
-    const type = await this.cachingService.getLocal<NftType>(CacheInfo.CollectionType(collectionIdentifier).key) ??
+    const type = this.cachingService.getLocal<NftType>(CacheInfo.CollectionType(collectionIdentifier).key) ??
       await this.getCollectionTypeRaw(collectionIdentifier);
 
     if (!type) {

src/common/rabbitmq/rabbitmq.nft.handler.service.ts

@@ -50,7 +50,7 @@ export class LocalCacheController {
     status: 404,
     description: 'Key not found',
   })
-  async delCache(@Param('key') key: string) {
-    await this.cachingService.deleteLocal(key);
+  delCache(@Param('key') key: string) {
+    this.cachingService.deleteLocal(key);
   }
 }

src/endpoints/caching/local.cache.controller.ts

@@ -373,7 +373,7 @@ export class EsdtAddressService {
       return result;
     }
 
-    const cachedValue = await this.cachingService.getLocal<{ [key: string]: any }>(`address:${address}:esdts`);
+    const cachedValue = this.cachingService.getLocal<{ [key: string]: any }>(`address:${address}:esdts`);
 
     if (cachedValue) {
       this.metricsService.incrementCachedApiHit('Gateway.AccountEsdts');

src/endpoints/esdt/esdt.address.service.ts

@@ -62,7 +62,7 @@ export class MexSettingsService {
   }
 
   async getMexContracts(): Promise<Set<string>> {
-    let contracts = await this.cachingService.getLocal<Set<string>>(CacheInfo.MexContracts.key);
+    let contracts = this.cachingService.getLocal<Set<string>>(CacheInfo.MexContracts.key);
     if (!contracts) {
       contracts = await this.getMexContractsRaw();
       this.cachingService.setLocal(CacheInfo.MexContracts.key, contracts, Constants.oneMinute() * 10);

src/endpoints/mex/mex.settings.service.ts

@@ -20,7 +20,7 @@ export class StakeActionRecognizerService implements TransactionActionRecognizer
   ) { }
 
   private async getProviders(): Promise<{ [key: string]: { providerName: string, providerAvatar: string } }> {
-    let providersDetails = await this.cachingService.getLocal<{ [key: string]: { providerName: string, providerAvatar: string } }>('plugins:staking:providerAddresses');
+    let providersDetails = this.cachingService.getLocal<{ [key: string]: { providerName: string, providerAvatar: string } }>('plugins:staking:providerAddresses');
     if (!providersDetails) {
       const providers = await this.providerService.getAllProviders();
       const identities = await this.identitiesService.getAllIdentities();

src/endpoints/transactions/transaction-action/recognizers/staking/transaction.action.stake.recognizer.service.ts

@@ -230,7 +230,7 @@ describe('Block Service', () => {
 
       const blses = ['bls_key_0', 'bls_key_1', 'bls_key_2'];
 
-      jest.spyOn(cacheService, 'getLocal').mockImplementation(() => Promise.resolve(blses));
+      jest.spyOn(cacheService, 'getLocal').mockImplementation(() => blses);
       jest.spyOn(blsService, 'getPublicKeys').mockImplementation(() => Promise.resolve(blses));
 
       const result = await blockService.computeProposerAndValidators(inputItem);
@@ -253,8 +253,8 @@ describe('Block Service', () => {
 
       const blses = ['bls_key_0', 'bls_key_1', 'bls_key_2'];
 
-      jest.spyOn(cacheService, 'getLocal').mockImplementationOnce(() => Promise.resolve(null));
-      jest.spyOn(cacheService, 'setLocal').mockImplementation(() => Promise.resolve());
+      jest.spyOn(cacheService, 'getLocal').mockImplementationOnce(() => null);
+      jest.spyOn(cacheService, 'setLocal').mockImplementation();
       jest.spyOn(blsService, 'getPublicKeys').mockImplementation(() => Promise.resolve(blses));
 
       await blockService.computeProposerAndValidators(inputItem);

src/test/unit/services/blocks.spec.ts

@@ -211,7 +211,7 @@ describe('EsdtAddressService', () => {
         },
       };
 
-      jest.spyOn(cacheService, 'getLocal').mockResolvedValue(cachedEsdts);
+      jest.spyOn(cacheService, 'getLocal').mockReturnValue(cachedEsdts);
       jest.spyOn(metricsService, 'incrementCachedApiHit');
 
       const result = await service.getAllEsdtsForAddressFromGateway(address);
@@ -224,7 +224,7 @@ describe('EsdtAddressService', () => {
       const address = 'some-address';
       const ttl = 1000;
 
-      jest.spyOn(cacheService, 'getLocal').mockResolvedValueOnce(null);
+      jest.spyOn(cacheService, 'getLocal').mockReturnValueOnce(null);
       jest.spyOn(cacheService, 'setLocal');
       jest.spyOn(protocolService, 'getSecondsRemainingUntilNextRound').mockResolvedValue(ttl);