fixes event emitting on client

Signed-off-by: Konstantina Blazhukova <konstantina.blajukova@gmail.com>

Author: konstantinabl

packages/relay/src/lib/clients/cache/redisCache.ts

@@ -6,7 +6,6 @@ import { Registry } from 'prom-client';
 import { createClient } from 'redis';
 
 import { Utils } from '../../../utils';
-import { RedisCacheError } from '../../errors/RedisCacheError';
 import { IRedisCacheClient } from './IRedisCacheClient';
 
 /**
@@ -51,15 +50,6 @@ export class RedisCache implements IRedisCacheClient {
     this.logger = logger;
     this.register = register;
     this.client = client;
-
-    this.client.on('error', (error) => {
-      const redisError = new RedisCacheError(error);
-      if (redisError.isSocketClosed()) {
-        logger.error(`Error occurred with Redis Connection when closing socket: ${redisError.message}`);
-      } else {
-        logger.error(`Error occurred with Redis Connection: ${redisError.fullError}`);
-      }
-    });
   }
 
   async getConnectedClient(): Promise<ReturnType<typeof createClient>> {

packages/relay/src/lib/relay.ts

@@ -17,6 +17,7 @@ import { HbarSpendingPlanRepository } from './db/repositories/hbarLimiter/hbarSp
 import { IPAddressHbarSpendingPlanRepository } from './db/repositories/hbarLimiter/ipAddressHbarSpendingPlanRepository';
 import { DebugImpl } from './debug';
 import { RpcMethodDispatcher } from './dispatcher';
+import { RedisCacheError } from './errors/RedisCacheError';
 import { EthImpl } from './eth';
 import { NetImpl } from './net';
 import { CacheService } from './services/cacheService/cacheService';
@@ -364,10 +365,17 @@ export class Relay {
     redisClient.on('ready', () => {
       this.logger.info(`Redis client connected to ${redisUrl}`);
     });
+    redisClient.on('end', () => {
+      this.logger.info('Disconnected from Redis server!');
+    });
     redisClient.on('error', (error) => {
-      this.logger.error(error, 'Redis connection could not be established!');
+      const redisError = new RedisCacheError(error);
+      if (redisError.isSocketClosed()) {
+        this.logger.error(`Error occurred with Redis Connection when closing socket: ${redisError.message}`);
+      } else {
+        this.logger.error(`Error occurred with Redis Connection: ${redisError.fullError}`);
+      }
     });
-
     return redisClient;
   }
 }