src/readers/queryService.ts

@@ -54,12 +54,17 @@ export const queryService = async (db: DbConnection, cypher: QueryCypher, useCac
     result.nodeCounts.updatedAt = Date.now();
 
     // cache result
-    const compressedMessage = Bun.gzipSync(JSON.stringify(result));
-    const base64Message = Buffer.from(compressedMessage).toString('base64');
 
     if (QUERY_CACHE_DURATION !== '') {
+      log.info('Started gzipping...');
+      const compressedMessage = Bun.gzipSync(JSON.stringify(result));
+      log.info('Done gzipping, started encoding to base64...');
+      const base64Message = Buffer.from(compressedMessage).toString('base64');
+      log.info('Done encoding, sending to redis...');
+
       // if cache enabled, cache the result
       await redis.setWithExpire(cacheKey, base64Message, QUERY_CACHE_DURATION); // ttl in seconds
+      log.info('cached in redis');
     }
 
     return result;