Komodo / komodo-center-sms

Download as
Browse Code ยป

Commit 8182d4cee270398a3b8709a81a61accae0b682a7

Authored by Adhidarma Hadiwinoto
1 parent 537499e090
Exists in master

History put on redis

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

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