Komodo / komodo-center-sms

Download as
Browse Code ยป

Commit 5157ab43c3bc9aa83472e0320f8ecdba6cf6d62a

Authored by Adhidarma Hadiwinoto
1 parent 4a81b13bb0
Exists in master

MODEM-CHOOSER: safe config

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

lib/modem-chooser.js
Diff comments   View file @ 5157ab4
1 'use strict'; 1 'use strict';
2 2
3 const prefixes = require('./prefixes'); 3 const prefixes = require('./prefixes');
4 const modems = require('./modems2'); 4 const modems = require('./modems2');
5 const partnerLastSeen = require('./partner-last-seen'); 5 const partnerLastSeen = require('./partner-last-seen');
6 6
7 function filterOutCandidates(candidates) { 7 function filterOutCandidates(candidates) {
8 if (!Array.isArray(candidates)) { 8 if (!Array.isArray(candidates)) {
9 return []; 9 return [];
10 } 10 }
11 11
12 return candidates.filter((item) => { 12 return candidates.filter((item) => {
13 if (item.indexOf('#') >= 0) return false; 13 if (item.indexOf('#') >= 0) return false;
14 14
15 const modem = modems.get('by_imsi', item); 15 const modem = modems.get('by_imsi', item);
16 if (!modem) return false; 16 if (!modem) return false;
17 17
18 return true; 18 return true;
19 }); 19 });
20 } 20 }
21 21
22 exports.chooser = async function chooser(destination, config) { 22 exports.chooser = async function chooser(destination, config) {
23 const logger = global.KOMODO_LOGGER; 23 const logger = global.KOMODO_LOGGER;
24 24
25 let prefixName = await prefixes.lookup(destination); 25 let prefixName = await prefixes.lookup(destination);
26 if (typeof prefixName === 'string') { 26 if (typeof prefixName === 'string') {
27 prefixName = prefixName.toUpperCase(); 27 prefixName = prefixName.toUpperCase();
28 } 28 }
29 29
30 if (logger) logger.verbose('MODEM-CHOOSER: Choosing suitable senders', { destination, prefixName }); 30 if (logger) logger.verbose('MODEM-CHOOSER: Choosing suitable senders', { destination, prefixName });
31 31
32 let imsiSenders = []; 32 let imsiSenders = [];
33 if (config.imsi_senders && prefixName && config.imsi_senders.prefix_names && config.imsi_senders.prefix_names[prefixName]) { 33 if (config.imsi_senders && prefixName && config.imsi_senders.prefix_names && config.imsi_senders.prefix_names[prefixName]) {
34 imsiSenders = filterOutCandidates(config.imsi_senders.prefix_names[prefixName]); 34 imsiSenders = filterOutCandidates(config.imsi_senders.prefix_names[prefixName]);
35 if (logger) logger.verbose('MODEM-CHOOSER: Try to use imsi senders by prefix name', { destination, prefixName, imsiSenders }); 35 if (logger) logger.verbose('MODEM-CHOOSER: Try to use imsi senders by prefix name', { destination, prefixName, imsiSenders });
36 } 36 }
37 37
38 if (!imsiSenders.length && config.imsi_senders.default && Array.isArray(config.imsi_senders.default) && config.imsi_senders.default.length) { 38 if (!imsiSenders.length && config.imsi_senders && config.imsi_senders.default && Array.isArray(config.imsi_senders.default) && config.imsi_senders.default.length) {
39 imsiSenders = filterOutCandidates(config.imsi_senders.default); 39 imsiSenders = filterOutCandidates(config.imsi_senders.default);
40 if (logger) logger.verbose('MODEM-CHOOSER: Try to use default senders', { destination, prefixName, imsiSenders }); 40 if (logger) logger.verbose('MODEM-CHOOSER: Try to use default senders', { destination, prefixName, imsiSenders });
41 } 41 }
42 42
43 if (!imsiSenders.length) { 43 if (!imsiSenders.length) {
44 imsiSenders = filterOutCandidates([ await partnerLastSeen.get(destination) ]); 44 imsiSenders = filterOutCandidates([ await partnerLastSeen.get(destination) ]);
45 if (logger) logger.verbose('MODEM-CHOOSER: Try to use sender by last seen', { destination, prefixName, imsiSenders }); 45 if (logger) logger.verbose('MODEM-CHOOSER: Try to use sender by last seen', { destination, prefixName, imsiSenders });
46 } 46 }
47 47
48 if (!imsiSenders.length) { 48 if (!imsiSenders.length) {
49 if (logger) logger.warn('MODEM-CHOOSER: No suitable sender found', { destination, prefixName }); 49 if (logger) logger.warn('MODEM-CHOOSER: No suitable sender found', { destination, prefixName });
50 return; 50 return;
51 } 51 }
52 52
53 const count = imsiSenders.length; 53 const count = imsiSenders.length;
54 const idx = Math.round(Math.random() * (count - 1)); 54 const idx = Math.round(Math.random() * (count - 1));
55 const imsiChoosed = imsiSenders[idx]; 55 const imsiChoosed = imsiSenders[idx];
56 56
57 if (logger) logger.verbose(`MODEM-CHOOSER: gonna use modem with IMSI ${imsiChoosed}`, { destination, prefixName, imsiSenders }); 57 if (logger) logger.verbose(`MODEM-CHOOSER: gonna use modem with IMSI ${imsiChoosed}`, { destination, prefixName, imsiSenders });
58 58
59 return imsiChoosed; 59 return imsiChoosed;
60 } 60 }