From 1a5a3629d73f4a3f84c55ee86387f6ab799bf4f6 Mon Sep 17 00:00:00 2001
From: Adhidarma Hadiwinoto <me@adhisimon.org>
Date: Tue, 30 Jul 2019 22:21:36 +0700
Subject: [PATCH] Load history from redis on start
---
lib/history.js | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
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();
--
1.9.0