From b41248571e4f949042a4ced5aced96be4fa89ca8 Mon Sep 17 00:00:00 2001
From: Alexander <zavorotynskiy@pm.me>
Date: Mon, 14 Apr 2025 16:24:22 +0200
Subject: [PATCH] feat(assist-server): correct redis prefix

---
 ee/assist-server/app/cache.js | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/ee/assist-server/app/cache.js b/ee/assist-server/app/cache.js
index 68cd8e31a..de2345886 100644
--- a/ee/assist-server/app/cache.js
+++ b/ee/assist-server/app/cache.js
@@ -24,7 +24,7 @@ const nodeID = process.env.HOSTNAME || generateNodeID();
 
 const addSessionToCache =  async function (sessionID, sessionData) {
     try {
-        await redisClient.set(`active_sessions:${sessionID}`, JSON.stringify(sessionData), {EX: pingInterval});
+        await redisClient.set(`assist:online_sessions:${sessionID}`, JSON.stringify(sessionData), {EX: pingInterval});
         logger.debug(`Session ${sessionID} stored in Redis`);
     } catch (error) {
         logger.error(error);
@@ -33,7 +33,7 @@ const addSessionToCache =  async function (sessionID, sessionData) {
 
 const renewSession = async function (sessionID){
     try {
-        await redisClient.expire(`active_sessions:${sessionID}`, pingInterval);
+        await redisClient.expire(`assist:online_sessions:${sessionID}`, pingInterval);
         logger.debug(`Session ${sessionID} renewed in Redis`);
     } catch (error) {
         logger.error(error);
@@ -42,7 +42,7 @@ const renewSession = async function (sessionID){
 
 const getSessionFromCache = async function (sessionID) {
     try {
-        const sessionData = await redisClient.get(`active_sessions:${sessionID}`);
+        const sessionData = await redisClient.get(`assist:online_sessions:${sessionID}`);
         if (sessionData) {
             logger.debug(`Session ${sessionID} retrieved from Redis`);
             return JSON.parse(sessionData);
@@ -56,7 +56,7 @@ const getSessionFromCache = async function (sessionID) {
 
 const removeSessionFromCache = async function (sessionID) {
     try {
-        await redisClient.del(`active_sessions:${sessionID}`);
+        await redisClient.del(`assist:online_sessions:${sessionID}`);
         logger.debug(`Session ${sessionID} removed from Redis`);
     } catch (error) {
         logger.error(error);
@@ -65,7 +65,7 @@ const removeSessionFromCache = async function (sessionID) {
 
 const setNodeSessions = async function (nodeID, sessionIDs) {
     try {
-        await redisClient.set(`node:${nodeID}:sessions`, JSON.stringify(sessionIDs), {EX: cacheRefreshInterval});
+        await redisClient.set(`assist:nodes:${nodeID}:sessions`, JSON.stringify(sessionIDs), {EX: cacheRefreshInterval});
         logger.debug(`Node ${nodeID} sessions stored in Redis`);
     } catch (error) {
         logger.error(error);