Blame view

lib/history.js 758 Bytes
4fbfae95f   Adhidarma Hadiwinoto   Messages history
1
  'use strict';
8182d4cee   Adhidarma Hadiwinoto   History put on redis
2
  const redis = require('redis');
4fbfae95f   Adhidarma Hadiwinoto   Messages history
3
  const CircularBuffer = require("circular-buffer");
8182d4cee   Adhidarma Hadiwinoto   History put on redis
4
5
6
  
  const config = require('komodo-sdk/config');
  const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' });
3a34fe226   Adhidarma Hadiwinoto   Perbesar circular...
7
  const history = new CircularBuffer(1000);
4fbfae95f   Adhidarma Hadiwinoto   Messages history
8

8182d4cee   Adhidarma Hadiwinoto   History put on redis
9
10
11
12
13
14
15
16
  const REDIS_KEYWORD = `SHAKIR_SMS_HISTORY_${config.name||'SMS'}`;
  
  function fetchFromRedis() {
      redisClient.LRANGE(REDIS_KEYWORD, 0, -1, (err, reply) => {
          console.log(reply);
      })
  }
  fetchFromRedis();
4fbfae95f   Adhidarma Hadiwinoto   Messages history
17
  function push(item) {
8182d4cee   Adhidarma Hadiwinoto   History put on redis
18
      redisClient.LPUSH(REDIS_KEYWORD, JSON.stringify(item));
4fbfae95f   Adhidarma Hadiwinoto   Messages history
19
20
21
22
      history.push(item);
  }
  
  function dump() {
c747a8b35   Adhidarma Hadiwinoto   DEBUG
23
24
25
      const result = history.toarray();
      console.log(JSON.stringify(result, null, 2));
      return result;
4fbfae95f   Adhidarma Hadiwinoto   Messages history
26
27
28
29
  }
  
  exports.push = push;
  exports.dump = dump;