jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(assist-server): correct redis prefix

Browse source
This commit is contained in:
Alexander 2025-04-14 16:24:22 +02:00
parent b7df5c7f87
commit b41248571e
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ee/assist-server/app/cache.js
View file

@ -24,7 +24,7 @@ const nodeID = process.env.HOSTNAME || generateNodeID();
const addSessionToCache = async function (sessionID, sessionData) { const addSessionToCache = async function (sessionID, sessionData) {
try { 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`); logger.debug(`Session ${sessionID} stored in Redis`);
} catch (error) { } catch (error) {
logger.error(error); logger.error(error);
@ -33,7 +33,7 @@ const addSessionToCache = async function (sessionID, sessionData) {
const renewSession = async function (sessionID){ const renewSession = async function (sessionID){
try { try {
await redisClient.expire(`active_sessions:${sessionID}`, pingInterval); await redisClient.expire(`assist:online_sessions:${sessionID}`, pingInterval);
logger.debug(`Session ${sessionID} renewed in Redis`); logger.debug(`Session ${sessionID} renewed in Redis`);
} catch (error) { } catch (error) {
logger.error(error); logger.error(error);
@ -42,7 +42,7 @@ const renewSession = async function (sessionID){
const getSessionFromCache = async function (sessionID) { const getSessionFromCache = async function (sessionID) {
try { try {
const sessionData = await redisClient.get(`active_sessions:${sessionID}`); const sessionData = await redisClient.get(`assist:online_sessions:${sessionID}`);
if (sessionData) { if (sessionData) {
logger.debug(`Session ${sessionID} retrieved from Redis`); logger.debug(`Session ${sessionID} retrieved from Redis`);
return JSON.parse(sessionData); return JSON.parse(sessionData);
@ -56,7 +56,7 @@ const getSessionFromCache = async function (sessionID) {
const removeSessionFromCache = async function (sessionID) { const removeSessionFromCache = async function (sessionID) {
try { try {
await redisClient.del(`active_sessions:${sessionID}`); await redisClient.del(`assist:online_sessions:${sessionID}`);
logger.debug(`Session ${sessionID} removed from Redis`); logger.debug(`Session ${sessionID} removed from Redis`);
} catch (error) { } catch (error) {
logger.error(error); logger.error(error);
@ -65,7 +65,7 @@ const removeSessionFromCache = async function (sessionID) {
const setNodeSessions = async function (nodeID, sessionIDs) { const setNodeSessions = async function (nodeID, sessionIDs) {
try { 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`); logger.debug(`Node ${nodeID} sessions stored in Redis`);
} catch (error) { } catch (error) {
logger.error(error); logger.error(error);