From 68c65a14e17135d0370acd683354b019216aa4d4 Mon Sep 17 00:00:00 2001
From: Karen Stepanyan <karen.stepanyan@smartcontract.com>
Date: Wed, 4 Sep 2024 12:23:52 +0400
Subject: [PATCH] add prefix support for redis subscription set key

---
 src/util/subscription-set/subscription-set.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/util/subscription-set/subscription-set.ts b/src/util/subscription-set/subscription-set.ts
index 887a9d49..bacfb80b 100644
--- a/src/util/subscription-set/subscription-set.ts
+++ b/src/util/subscription-set/subscription-set.ts
@@ -22,12 +22,14 @@ export class SubscriptionSetFactory {
   private redisClient?: Redis
   private adapterName?: string
   private capacity: AdapterSettings['SUBSCRIPTION_SET_MAX_ITEMS']
+  private cachePrefix: AdapterSettings['CACHE_PREFIX']
 
   constructor(adapterSettings: AdapterSettings, adapterName: string, redisClient?: Redis) {
     this.cacheType = adapterSettings.CACHE_TYPE
     this.redisClient = redisClient
     this.adapterName = adapterName
     this.capacity = adapterSettings.SUBSCRIPTION_SET_MAX_ITEMS
+    this.cachePrefix = adapterSettings.CACHE_PREFIX
   }
 
   buildSet<T>(endpointName: string, transportName: string): SubscriptionSet<T> {
@@ -39,7 +41,8 @@ export class SubscriptionSetFactory {
           throw new Error('Redis client undefined. Cannot create Redis subscription set')
         }
         // Identifier key used for the subscription set in redis
-        const subscriptionSetKey = `${this.adapterName}-${endpointName}-${transportName}-subscriptionSet`
+        const cachePrefix = this.cachePrefix ? `${this.cachePrefix}-` : ''
+        const subscriptionSetKey = `${cachePrefix}${this.adapterName}-${endpointName}-${transportName}-subscriptionSet`
         return new RedisSubscriptionSet<T>(this.redisClient, subscriptionSetKey)
       }
     }