Commit 269c423d29692e397b67ba4f7f5c678041caf8d2
1 parent
b01439988e
Exists in
master
DEBUG REDIS
Showing 1 changed file with 3 additions and 0 deletions Inline Diff
lib/partner-last-seen.js
| 1 | "use strict"; | 1 | "use strict"; |
| 2 | 2 | ||
| 3 | const REDIS_TTL_SECS = 3600 * 24 * 7; | 3 | const REDIS_TTL_SECS = 3600 * 24 * 7; |
| 4 | 4 | ||
| 5 | const config = require('komodo-sdk/config'); | 5 | const config = require('komodo-sdk/config'); |
| 6 | const logger = require('komodo-sdk/logger'); | ||
| 6 | 7 | ||
| 7 | const redis = require('redis'); | 8 | const redis = require('redis'); |
| 8 | const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); | 9 | const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); |
| 9 | 10 | ||
| 10 | const _caches = {}; | 11 | const _caches = {}; |
| 11 | 12 | ||
| 12 | 13 | ||
| 13 | function _composeKeyword(partner) { | 14 | function _composeKeyword(partner) { |
| 14 | return `POCHINKI_PARTNER_LAST_SEEN_${ partner }`; | 15 | return `POCHINKI_PARTNER_LAST_SEEN_${ partner }`; |
| 15 | } | 16 | } |
| 16 | 17 | ||
| 17 | function get(partnerNumber) { | 18 | function get(partnerNumber) { |
| 18 | return new Promise(function(resolve) { | 19 | return new Promise(function(resolve) { |
| 19 | 20 | ||
| 20 | if (!partnerNumber) { | 21 | if (!partnerNumber) { |
| 21 | resolve(null); | 22 | resolve(null); |
| 22 | } | 23 | } |
| 23 | else if (_caches[partnerNumber]) { | 24 | else if (_caches[partnerNumber]) { |
| 24 | resolve(_caches[partnerNumber]); | 25 | resolve(_caches[partnerNumber]); |
| 25 | } | 26 | } |
| 26 | else { | 27 | else { |
| 27 | const keyword = _composeKeyword(partnerNumber); | 28 | const keyword = _composeKeyword(partnerNumber); |
| 29 | logger.verbose(`REDIS-DEBUG: GET`, {keyword}); | ||
| 28 | 30 | ||
| 29 | redisClient.get(keyword, function(err, reply) { | 31 | redisClient.get(keyword, function(err, reply) { |
| 30 | if (err) { | 32 | if (err) { |
| 31 | resolve(null); | 33 | resolve(null); |
| 32 | } | 34 | } |
| 33 | else if (reply) { | 35 | else if (reply) { |
| 34 | resolve(Number(reply)); | 36 | resolve(Number(reply)); |
| 35 | _caches[partnerNumber] = Number(reply); | 37 | _caches[partnerNumber] = Number(reply); |
| 36 | } | 38 | } |
| 37 | else { | 39 | else { |
| 38 | resolve(null); | 40 | resolve(null); |
| 39 | } | 41 | } |
| 40 | }) | 42 | }) |
| 41 | } | 43 | } |
| 42 | }) | 44 | }) |
| 43 | } | 45 | } |
| 44 | 46 | ||
| 45 | function set(partnerNumber, modemName) { | 47 | function set(partnerNumber, modemName) { |
| 46 | if (!partnerNumber || !modemName) { | 48 | if (!partnerNumber || !modemName) { |
| 47 | return; | 49 | return; |
| 48 | } | 50 | } |
| 49 | 51 | ||
| 50 | _caches[partnerNumber] = modemName; | 52 | _caches[partnerNumber] = modemName; |
| 51 | 53 | ||
| 52 | const keyword = _composeKeyword(partnerNumber); | 54 | const keyword = _composeKeyword(partnerNumber); |
| 55 | logger.verbose('REDIS-DEBUG: SET', { keyword }) | ||
| 53 | redisClient.set(keyword, modemName, 'EX', REDIS_TTL_SECS); | 56 | redisClient.set(keyword, modemName, 'EX', REDIS_TTL_SECS); |
| 54 | } | 57 | } |
| 55 | 58 | ||
| 56 | exports.get = get; | 59 | exports.get = get; |
| 57 | exports.set = set; | 60 | exports.set = set; |
| 58 | 61 |