history.js
761 Bytes
'use strict';
const redis = require('redis');
const CircularBuffer = require("circular-buffer");
const config = require('komodo-sdk/config');
const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' });
const history = new CircularBuffer(1000);
const REDIS_KEYWORD = `SHAKIR_SMS_HISTORY_${config.name||'SMS'}`;
function fetchFromRedis() {
redisClient.LRANGE(REDIS_KEYWORD, 0, -1, (err, reply) => {
console.log(reply);
})
}
fetchFromRedis();
function push(item) {
redisClient.LPUSH(REDIS_KEYWORD, JSON.stringify(item));
history.push(item);
}
function dump() {
const result = history.toarray();
// console.log(JSON.stringify(result, null, 2));
return result;
}
exports.push = push;
exports.dump = dump;