Function addMessageToCache

run/websockets/redis.js:31–47

(roomName, msg)

// Insert new messages into the Redis cache
async function addMessageToCache(roomName, msg) {
  // Check for current cache
  let room = await getRoomFromCache(roomName);
  if (room) {
    // Update old room
    room.messages.push(msg);
  } else {
    // Create a new room
    room = {
      room: roomName,
      messages: [msg],
    };
  }
  await redisClient.set(roomName, JSON.stringify(room));
  // Insert message to the database as well
  addMessageToDb(room);
}

// Query Redis for messages for a specific room
// If not in Redis, query the database