Compare View
Commits (4)
Changes
Showing 4 changed files Side-by-side Diff
lib/partner-last-seen.js
... | ... | @@ -3,6 +3,7 @@ |
3 | 3 | const REDIS_TTL_SECS = 3600 * 24 * 7; |
4 | 4 | |
5 | 5 | const config = require('komodo-sdk/config'); |
6 | +// const logger = require('komodo-sdk/logger'); | |
6 | 7 | |
7 | 8 | const redis = require('redis'); |
8 | 9 | const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' }); |
... | ... | @@ -17,6 +18,8 @@ function _composeKeyword(partner) { |
17 | 18 | function get(partnerNumber) { |
18 | 19 | return new Promise(function(resolve) { |
19 | 20 | |
21 | + partnerNumber = (partnerNumber || '').replace(/^\+/, ''); | |
22 | + | |
20 | 23 | if (!partnerNumber) { |
21 | 24 | resolve(null); |
22 | 25 | } |
... | ... | @@ -25,6 +28,7 @@ function get(partnerNumber) { |
25 | 28 | } |
26 | 29 | else { |
27 | 30 | const keyword = _composeKeyword(partnerNumber); |
31 | + // logger.verbose(`REDIS-DEBUG: GET`, {keyword}); | |
28 | 32 | |
29 | 33 | redisClient.get(keyword, function(err, reply) { |
30 | 34 | if (err) { |
... | ... | @@ -43,6 +47,8 @@ function get(partnerNumber) { |
43 | 47 | } |
44 | 48 | |
45 | 49 | function set(partnerNumber, modemName) { |
50 | + partnerNumber = (partnerNumber || '').replace(/^\+/, ''); | |
51 | + | |
46 | 52 | if (!partnerNumber || !modemName) { |
47 | 53 | return; |
48 | 54 | } |
... | ... | @@ -50,6 +56,7 @@ function set(partnerNumber, modemName) { |
50 | 56 | _caches[partnerNumber] = modemName; |
51 | 57 | |
52 | 58 | const keyword = _composeKeyword(partnerNumber); |
59 | + // logger.verbose('REDIS-DEBUG: SET', { keyword }) | |
53 | 60 | redisClient.set(keyword, modemName, 'EX', REDIS_TTL_SECS); |
54 | 61 | } |
55 | 62 |
lib/transport.js
... | ... | @@ -136,7 +136,7 @@ async function send(partner, msg, origin) { |
136 | 136 | |
137 | 137 | const destinationNumber = modems.removeSuffixFromNumber(partner, config); |
138 | 138 | |
139 | - logger.verbose('Choosing handler name', { partner: partner, msg: msg, origin: origin }); | |
139 | + logger.verbose('Choosing handler name', { partner, destinationNumber, msg, origin }); | |
140 | 140 | let handlerName = ( await _getApproriateHandler(destinationNumber) ); |
141 | 141 | |
142 | 142 | _send(destinationNumber, msg, handlerName); |
package-lock.json