add redis prefix to communication channel (#651)

wormhole-foundation · Aug 22, 2023 · 3fa1804 · 3fa1804
1 parent 0741ef7
commit 3fa1804
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/common/client/cache/notional/cache.go b/common/client/cache/notional/cache.go
@@ -65,7 +65,7 @@ func NewNotionalCache(ctx context.Context, redisClient *redis.Client, prefix str
  return &NotionalCache{
  client: redisClient,
  pubSub: pubsub,
- channel: channel,
+ channel: formatChannel(prefix, channel),
  notionalMap: sync.Map{},
  prefix: prefix,
  logger: log}, nil
@@ -180,3 +180,10 @@ func (c *NotionalCache) renderKey(key string) string {
 func (c *NotionalCache) renderRegExp() string {
  return "*" + c.renderKey(wormscanNotionalCacheKeyRegex)
 }
+
+func formatChannel(prefix string, channel string) string {
+ if prefix != "" {
+ return fmt.Sprintf("%s:%s", prefix, channel)
+ }
+ return channel
+}
diff --git a/jobs/jobs/notional/notional.go b/jobs/jobs/notional/notional.go
@@ -28,7 +28,7 @@ func NewNotionalJob(api *coingecko.CoingeckoAPI, cacheClient *redis.Client, cach
  coingeckoAPI: api,
  cacheClient: cacheClient,
  cachePrefix: cachePrefix,
- cacheChannel: cacheChannel,
+ cacheChannel: formatChannel(cachePrefix, cacheChannel),
  p2pNetwork: p2pNetwork,
  logger: logger,
  }