Blame view
lib/partner-last-seen.js
1.24 KB
f53fe083f
|
1 |
"use strict"; |
f43dbc16a
|
2 |
const REDIS_TTL_SECS = 3600 * 24 * 31; |
f53fe083f
|
3 4 5 6 7 |
const config = require('komodo-sdk/config'); const redis = require('redis'); const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); |
f53fe083f
|
8 9 10 11 12 13 |
function _composeKeyword(partner) { return `POCHINKI_PARTNER_LAST_SEEN_${ partner }`; } function get(partnerNumber) { return new Promise(function(resolve) { |
51ea9b1ba
|
14 |
partnerNumber = (partnerNumber || '').replace(/^\+/, ''); |
f53fe083f
|
15 16 17 |
if (!partnerNumber) { resolve(null); } |
f53fe083f
|
18 19 20 21 22 23 24 25 26 |
else { const keyword = _composeKeyword(partnerNumber); redisClient.get(keyword, function(err, reply) { if (err) { resolve(null); } else if (reply) { resolve(Number(reply)); |
f53fe083f
|
27 28 29 30 31 32 33 34 35 36 |
} else { resolve(null); } }) } }) } function set(partnerNumber, modemName) { |
51ea9b1ba
|
37 |
partnerNumber = (partnerNumber || '').replace(/^\+/, ''); |
f53fe083f
|
38 39 40 |
if (!partnerNumber || !modemName) { return; } |
f53fe083f
|
41 42 43 44 45 46 |
const keyword = _composeKeyword(partnerNumber); redisClient.set(keyword, modemName, 'EX', REDIS_TTL_SECS); } exports.get = get; exports.set = set; |