From 103d7c2bb204128e9b3d54ebb884bb54ede3190b Mon Sep 17 00:00:00 2001 From: Dave Richer Date: Tue, 24 Sep 2024 20:10:15 -0400 Subject: [PATCH] IO-2935-Add-Enhanced-Websocket-Provider - Add additional try catch statements Signed-off-by: Dave Richer --- server/utils/redisHelpers.js | 20 ++++++++++++++++---- 1 file changed, 16 insertions(+), 4 deletions(-) diff --git a/server/utils/redisHelpers.js b/server/utils/redisHelpers.js index b4c4e1f0d..ee8acc890 100644 --- a/server/utils/redisHelpers.js +++ b/server/utils/redisHelpers.js @@ -74,16 +74,28 @@ const applyRedisHelpers = (pubClient, app) => { // Add methods to manage room users const addUserToRoom = async (bodyshopUUID, user) => { - await pubClient.sAdd(`bodyshopRoom:${bodyshopUUID}`, JSON.stringify(user)); + try { + await pubClient.sAdd(`bodyshopRoom:${bodyshopUUID}`, JSON.stringify(user)); + } catch (err) { + console.error(`Error adding user to room: ${bodyshopUUID}`); + } }; const removeUserFromRoom = async (bodyshopUUID, user) => { - await pubClient.sRem(`bodyshopRoom:${bodyshopUUID}`, JSON.stringify(user)); + try { + await pubClient.sRem(`bodyshopRoom:${bodyshopUUID}`, JSON.stringify(user)); + } catch (err) { + console.error(`Error remove user from room: ${bodyshopUUID}`); + } }; const getUsersInRoom = async (bodyshopUUID) => { - const users = await pubClient.sMembers(`bodyshopRoom:${bodyshopUUID}`); - return users.map((user) => JSON.parse(user)); + try { + const users = await pubClient.sMembers(`bodyshopRoom:${bodyshopUUID}`); + return users.map((user) => JSON.parse(user)); + } catch (err) { + console.error(`Error getUsersInRoom: ${bodyshopUUID}`); + } }; const api = {