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