diff --git a/src/readers/queryService.ts b/src/readers/queryService.ts index 56d445566ae748af55bb11a8dfd6c8d404f28243..e972fab426cc7b67484aa2a16a9190ad2c5271a8 100644 --- a/src/readers/queryService.ts +++ b/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;