Komodo / komodo-center-sms

Browse Code »

Commit a21e7a161eb3b8eeb6e6885d17887b2f29ce635f

Authored by Adhidarma Hadiwinoto 6 years ago

1 parent f031376361

Exists in master

modem-chooser for sending message

Showing 4 changed files with 73 additions and 2 deletions Inline Diff

config.sample.json
index.js
lib/modem-chooser.js
lib/transport.js

config.sample.json

Diff comments View file @ a21e7a1

 {
     "name": "SMS",
     "# messaging_url": "messaging service url",
     "messaging_url": "http://localhost:32979/",
     "# listen_port": "HTTP port untuk mendapat perintah dari CORE",
     "listen_port": 16480,
     "apiserver": {
         "# listen_port": "HTTP port untuk mendapat pesan masuk dari modem handler",
         "listen_port": 16481,
         "apikey": "PLEASE_CHANGE_ME"
     },
     "number_suffix": "@phonenumber",
     "modems": {
         "SMS0": {
             "url": "http://localhost:2110/sms",
             "apikey": "PLEASE_CHANGE_ME"
         }
     },
     "do_not_trim_long_sms": false,
     "default_modem": "SMS0",
     "# handler_chooser_algorithm": "algoritma untuk memilih modem dalam mengirim SMS. Pilihan: LAST-SEEN, FORCED. Default: LAST-SEEN",
     "handler_chooser_algorithm": "LAST-SEEN",
     "# sending handler": "list modem yang dipakai untuk mengirim jika handler_chooser_algorithm === 'FORCED'",
     "sending_handler": [
         "SMS0",
         "SMS1"
     ],
+    "imsi_senders": {
+        "prefix_names": {
+            "TELKOMSEL": [
+                "510890944235402"
+            ],
+            "XL": [
+                "510890944262917"
+            ]
+        },
+        "default": [
+            "510890944235513"
+        ]
+    },
     "redis": {
         "host": "127.0.0.1"
     }
 }

index.js

Diff comments View file @ a21e7a1

 "use strict";
 process.chdir(__dirname);
 const fs = require('fs');
 fs.writeFileSync('pid.txt', process.pid);
 const config = require('komodo-sdk/config');
 global.KOMODO_LOG_LABEL = `KOMODO-CENTER@${(config && typeof config.name === 'string') ? config.name.toUpperCase() : 'SMS'}`;
 process.title = global.KOMODO_LOG_LABEL;
+const logger = require('komodo-sdk/logger');
+global.KOMODO_LOGGER = logger;
 require('./lib/prefixes');
 require('./lib/transport');
 require('./lib/apiserver');

lib/modem-chooser.js

Diff comments View file @ a21e7a1

File was created	1	'use strict';
	2
	3	const prefixes = require('./prefixes');
	4	const modems = require('./modems2');
	5	const partnerLastSeen = require('./partner-last-seen');
	6
	7	function filterOutCandidates(candidates) {
	8	if (!Array.isArray(candidates)) {
	9	return [];
	10	}
	11
	12	return candidates.filter((item) => {
	13	const modem = modems.get('by_imsi', item);
	14
	15	if (!modem) return false;
	16	return true;
	17	});
	18	}
	19
	20	exports.chooser = async function chooser(destination, config) {
	21	const logger = global.KOMODO_LOGGER;
	22
	23	const prefixName = await prefixes.lookup(destination);
	24	if (logger) logger.verbose('Choosing suitable senders', { destination, prefixName });
	25
	26	let imsiSenders = [];
	27	if (config.imsi_senders && config.imsi_senders.prefix_names && config.imsi_senders.prefix_names[prefixName]) {
	28	imsiSenders = filterOutCandidates(config.imsi_senders.prefix_names[prefixName]);
	29	if (logger) logger.verbose('Suitable senders by prefix name', { destination, prefixName, imsiSenders });
	30	}
	31
	32	if (!imsiSenders.length && config.imsi_senders.default && Array.isArray(config.imsi_senders.default) && config.imsi_senders.default.length) {
	33	imsiSenders = filterOutCandidates(config.imsi_senders.default);
	34	if (logger) logger.verbose('Suitable default senders', { destination, prefixName, imsiSenders });
	35	}
	36
	37	if (!imsiSenders.length) {
	38	imsiSenders = filterOutCandidates([ await partnerLastSeen.get(destination) ]);
	39	if (logger) logger.verbose('Suitable senders by last seen', { destination, prefixName, imsiSenders });
	40	}
	41
	42	if (!imsiSenders.length) {
	43	if (logger) logger.verbose('No suitable sender found', { destination, prefixName });
	44	return;
	45	}
	46
	47	const count = imsiSenders.length;
	48	const idx = Math.round(Math.random() * (count - 1));
	49	const imsiChoosed = imsiSenders[idx];
	50	if (logger) logger.verbose(`Choose modem with IMSI ${imsiChoosed}`, { destination, prefixName, imsiSenders });
	51	return imsiChoosed;
	52	}

lib/transport.js

Diff comments View file @ a21e7a1

 "use strict";
 const MAX_SMS_LENGTH = 160;
 const url = require('url');
 const request = require('request');
 const uuidv4 = require('uuid/v4');
 const moment = require('moment');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const messagingService = require('komodo-center-messaging-client-lib');
 const common = require('./common');
 const modems = require('./modems2');
-const partnerLastSeen = require('./partner-last-seen');
+const modemChooser = require('./modem-chooser');
+// const partnerLastSeen = require('./partner-last-seen');
 const history = require('./history');
 const prefixes = require('./prefixes');
 function _send(destinationNumber, msg, handlerIMSI) {
     if (msg.length > 160) {
         logger.info('Splitting message');
         const newMsg = msg.slice(0, MAX_SMS_LENGTH);
         const remainingMsg = msg.slice(MAX_SMS_LENGTH);
         _send(destinationNumber, newMsg, handlerIMSI);
         setTimeout(() => {
             _send(destinationNumber, remainingMsg, handlerIMSI);
         }, 1000);
         return;
     }
     const modem = modems.get('imsi', handlerIMSI);
     if (!modem) {
         logger.warn('Not knowing modem to use. Ignoring message', { destination_number: destinationNumber, msg: msg, modem_imsi: handlerIMSI });
         return;
     }
     if (!modem.reportIp || !modem.reportPort || !modem.reportApikey) {
         logger.warn('Invalid modem configuration', { modem });
         return;
     }
     const reqId = uuidv4();
     history.push({
         ts: moment().format('YYYY-MM-DD HH:mm:ss'),
         modem: {
             name: modem.name,
             imsi: modem.imsi,
             msisdn: modem.msisdn,
         },
         direction: 'OUTGOING',
         partner: destinationNumber,
         message: msg,
     });
     logger.verbose('TRANSPORT: saving outgoing message');
     messagingService.onIncomingMessage({
         me: modem.name,
         partner: destinationNumber,
         partner_raw: `+${destinationNumber}`.replace(/^\++/, '+'),
         msg: msg,
         origin_label: `IMSI_${modem.imsi || 'UNKNOWN'}`,
         origin_transport: 'SMS',
         origin_partner: destinationNumber,
         do_not_forward_to_core: true,
         is_outgoing: true,
     });
     const requestOptions = {
         url: url.format({
             protocol: 'http',
             hostname: modem.reportIp,
             port: modem.reportPort,
             pathname: modem.reportPathSms || '/sms',
         }),
         qs: {
             msg: msg,
             number: destinationNumber,
             reqid: reqId,
             apikey: modem.reportApikey,
         }
     }
     logger.info('Sending message to modem handler', { req_id: reqId, destination_number: destinationNumber, msg: msg, msg_length: msg.length, modem_name: modem.name, modem_imsi: modem.imsi });
     request(requestOptions, function(err, res, body) {
         if (err) {
             logger.warn('Error requesting to modem handler. ' + err.toString(), { req_id: reqId, modem_name: modem.name, modem_imsi: modem.imsi });
         }
         else if (res.statusCode != 200) {
             logger.warn('Modem handler not responding with HTTP status code 200.', { http_status_code: res.statusCode, req_id: reqId, modem_name: modem.name, modem_imsi: modem.imsi });
         }
         else {
             logger.verbose('Message sent to handler', { req_id: reqId, modem_name: modem.name, modem_imsi: modem.imsi, response_body: body });
         }
     })
 }
 async function send(partner, msg) {
     if (!partner) return;
     if (typeof msg !== 'string') {
         logger.warn('Message to send is not a string, ignoring message');
         return;
     }
     msg = msg.trim();
     if (!msg) return;
     const destinationNumber = common.removeSuffixFromNumber(partner, config.number_suffix);
     const prefixName = await prefixes.lookup(destinationNumber);
     logger.verbose('Destination number prefix lookup', {partner: destinationNumber, prefix: prefixName});
     // logger.verbose('Choosing handler name', { partner, destinationNumber, msg, origin });
-    const handlerIMSI = await partnerLastSeen.get(destinationNumber) ;
+    // const handlerIMSI = await partnerLastSeen.get(destinationNumber) ;
+    const handlerIMSI = await modemChooser.chooser(destinationNumber, config);
     if (!handlerIMSI) {
         logger.warn(`Unknown handler for sending message to partner`, { partner, destinationNumber });
         return;
     }
     _send(destinationNumber, msg, handlerIMSI);
 }
 exports.send = send;