Fix cache invalidation

src/modules/campaigns/campaigns-caching.service.ts

@@ -1,14 +1,15 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
 import '../../utils/extensions';
 import { Constants } from '@multiversx/sdk-nestjs-common';
 import { CacheService } from '@multiversx/sdk-nestjs-cache';
 import { CollectionType } from '../assets/models/Collection.type';
 import { CacheInfo } from 'src/common/services/caching/entities/cache.info';
 import { Campaign } from './models';
+import { ClientProxy } from '@nestjs/microservices';
 
 @Injectable()
 export class CampaignsCachingService {
-  constructor(private cacheService: CacheService) {}
+  constructor(private cacheService: CacheService, @Inject('PUBSUB_SERVICE') private clientProxy: ClientProxy) {}
 
   public async getAllMarketplaces(getCampaignsFromDb: () => any): Promise<CollectionType<Campaign>> {
     return await this.cacheService.getOrSet(CacheInfo.Campaigns.key, () => getCampaignsFromDb(), Constants.oneHour());
@@ -24,5 +25,16 @@
 
   public async invalidateCache() {
     await this.cacheService.deleteInCache(CacheInfo.Campaigns.key);
+    await this.refreshCacheKey(CacheInfo.Campaigns.key, CacheInfo.MarketplaceAddressCollection.ttl);
+  }
+
+  private async refreshCacheKey(key: string, ttl: number) {
+    this.clientProxy.emit<{
+      key: string;
+      ttl: number;
+    }>('refreshCacheKey', {
+      key,
+      ttl,
+    });
   }
 }