From 737eaa0b3cdc3deb6ba30af39bdfaeb2c7c0e886 Mon Sep 17 00:00:00 2001 From: redesyef Date: Thu, 26 Sep 2024 14:06:38 -0500 Subject: [PATCH] format string LowerCase and replace spaces --- src/websocket/messageHandler.ts | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/src/websocket/messageHandler.ts b/src/websocket/messageHandler.ts index 10c698b..b01669f 100644 --- a/src/websocket/messageHandler.ts +++ b/src/websocket/messageHandler.ts @@ -29,7 +29,11 @@ type WSMessage = { focusMode: string; history: Array<[string, string]>; }; - +const formatString = (str: string) => { + let lowerCased = str.toLowerCase(); + let formatted = lowerCased.trim().replace(/\s+/g, ' '); + return formatted; +}; const searchHandlers = { webSearch: handleWebSearch, academicSearch: handleAcademicSearch, @@ -101,7 +105,11 @@ const handleEmitterEvents = ( metadata: JSON.stringify(sources), }; await redisClient - .setEx(cacheKey, 86400, JSON.stringify(responseWithSources)) + .setEx( + formatString(cacheKey), + 86400, + JSON.stringify(responseWithSources), + ) .then(() => logger.info(`Cache set for ${cacheKey}`)) .catch((err) => logger.error(`Redis setEx error: ${err}`)); } @@ -143,7 +151,7 @@ export const handleMessage = async ( const shouldCache = parsedMessage.cache === '1'; if (shouldCache) { - const cachedResponse = await redisClient.get(cacheKey); + const cachedResponse = await redisClient.get(formatString(cacheKey)); if (cachedResponse) { const jsonDatabase = JSON.parse(cachedResponse);