Commit b904e709444956ce7736dbe7b068ebf04cd6792f

Authored by Adhidarma Hadiwinoto
1 parent 81d714d872
Exists in master

DEBUG

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

1 'use strict'; 1 'use strict';
2 2
3 const redis = require('redis'); 3 const redis = require('redis');
4 const CircularBuffer = require("circular-buffer"); 4 const CircularBuffer = require("circular-buffer");
5 5
6 const config = require('komodo-sdk/config'); 6 const config = require('komodo-sdk/config');
7 const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); 7 const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' });
8 const history = new CircularBuffer(1000); 8 const history = new CircularBuffer(1000);
9 9
10 const REDIS_KEYWORD = `SHAKIR_SMS_HISTORY_${config.name||'SMS'}`; 10 const REDIS_KEYWORD = `SHAKIR_SMS_HISTORY_${config.name||'SMS'}`;
11 11
12 function fetchFromRedis() { 12 function fetchFromRedis() {
13 redisClient.LRANGE(REDIS_KEYWORD, 0, -1, (err, reply) => { 13 redisClient.LRANGE(REDIS_KEYWORD, 0, -1, (err, reply) => {
14 console.log(reply); 14 console.log(reply);
15 }) 15 })
16 } 16 }
17 fetchFromRedis(); 17 fetchFromRedis();
18 18
19 function push(item) { 19 function push(item) {
20 redisClient.LPUSH(REDIS_KEYWORD, JSON.stringify(item)); 20 redisClient.LPUSH(REDIS_KEYWORD, JSON.stringify(item));
21 history.push(item); 21 history.push(item);
22 } 22 }
23 23
24 function dump() { 24 function dump() {
25 const result = history.toarray(); 25 const result = history.toarray();
26 console.log(JSON.stringify(result, null, 2)); 26 // console.log(JSON.stringify(result, null, 2));
27 return result; 27 return result;
28 } 28 }
29 29
30 exports.push = push; 30 exports.push = push;
31 exports.dump = dump; 31 exports.dump = dump;