diff --git a/lib/history.js b/lib/history.js index d87e9a1..732e79a 100644 --- a/lib/history.js +++ b/lib/history.js @@ -4,6 +4,8 @@ const redis = require('redis'); const CircularBuffer = require("circular-buffer"); const config = require('komodo-sdk/config'); +const logger = require('komodo-sdk/logger'); + const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); const history = new CircularBuffer(1000); @@ -11,7 +13,13 @@ const REDIS_KEYWORD = `SHAKIR_SMS_HISTORY_${config.name||'SMS'}`; function fetchFromRedis() { redisClient.LRANGE(REDIS_KEYWORD, 0, -1, (err, reply) => { - console.log(reply); + reply.forEach((el) => { + try { + history.push(JSON.parse(el)); + } catch (e) { + logger.warn(`Error parsing JSON on redis history. ${e.toString()}`); + } + }); }) } fetchFromRedis();