Komodo / komodo-center-sms

Download as
Browse Code ยป

Commit 005d613db10b0b2f40b767fa444eaefc9e766443

Authored by Adhidarma Hadiwinoto
1 parent 9b262f47d2
Exists in master

jangan log modems/set

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

lib/apiserver/index.js
Diff comments   View file @ 005d613
1 "use strict"; 1 "use strict";
2 2
3 /** 3 /**
4 * Modul untuk menerima callback dari modem handler jika ada SMS masuk. 4 * Modul untuk menerima callback dari modem handler jika ada SMS masuk.
5 */ 5 */
6 6
7 7
8 const express = require('express'); 8 const express = require('express');
9 const moment = require('moment'); 9 const moment = require('moment');
10 10
11 const messagingService = require('komodo-center-messaging-client-lib'); 11 const messagingService = require('komodo-center-messaging-client-lib');
12 12
13 const config = require('komodo-sdk/config'); 13 const config = require('komodo-sdk/config');
14 const logger = require('komodo-sdk/logger'); 14 const logger = require('komodo-sdk/logger');
15 15
16 const transport = require('../transport'); 16 const transport = require('../transport');
17 const partnerLastSeen = require('../partner-last-seen'); 17 const partnerLastSeen = require('../partner-last-seen');
18 const history = require('../history'); 18 const history = require('../history');
19 // const modems = require('../modems2'); 19 // const modems = require('../modems2');
20 20
21 const routerModems = require('./router-modems'); 21 const routerModems = require('./router-modems');
22 22
23 const app = express(); 23 const app = express();
24 messagingService.setTransport(transport); 24 messagingService.setTransport(transport);
25 25
26 function apikeyChecker(req, res, next) { 26 function apikeyChecker(req, res, next) {
27 res.locals.has_valid_apikey = req.params.apikey === config.handler_callback_server.apikey; 27 res.locals.has_valid_apikey = req.params.apikey === config.handler_callback_server.apikey;
28 if (res.locals.has_valid_apikey) { 28 if (res.locals.has_valid_apikey) {
29 next(); 29 next();
30 } 30 }
31 else { 31 else {
32 res.end('APISERVER: Invalid apikey'); 32 res.end('APISERVER: Invalid apikey');
33 } 33 }
34 } 34 }
35 35
36 function onIncomingSms(req, res) { 36 function onIncomingSms(req, res) {
37 res.end('OK'); 37 res.end('OK');
38 38
39 if (!req.query.number) return; 39 if (!req.query.number) return;
40 const numberWithSuffix = req.query.number.replace(/^\+/, '') + (config.number_suffix || ''); 40 const numberWithSuffix = req.query.number.replace(/^\+/, '') + (config.number_suffix || '');
41 41
42 partnerLastSeen.set(req.query.number, req.query.modem_imsi); 42 partnerLastSeen.set(req.query.number, req.query.modem_imsi);
43 43
44 history.push({ 44 history.push({
45 ts: req.query.ts || moment().format('YYYY-MM-DD HH:mm:ss'), 45 ts: req.query.ts || moment().format('YYYY-MM-DD HH:mm:ss'),
46 modem: { 46 modem: {
47 name: req.query.modem, 47 name: req.query.modem,
48 imsi: req.query.modem_imsi, 48 imsi: req.query.modem_imsi,
49 msisdn: req.query.modem_msisdn, 49 msisdn: req.query.modem_msisdn,
50 }, 50 },
51 direction: 'INCOMING', 51 direction: 'INCOMING',
52 partner: req.query.number, 52 partner: req.query.number,
53 message: req.query.msg, 53 message: req.query.msg,
54 }); 54 });
55 55
56 /* 56 /*
57 modems.set({ 57 modems.set({
58 name: req.query.modem, 58 name: req.query.modem,
59 device: req.query.modem_device, 59 device: req.query.modem_device,
60 imsi: req.query.modem_imsi, 60 imsi: req.query.modem_imsi,
61 msisdn: req.query.modem_msisdn, 61 msisdn: req.query.modem_msisdn,
62 networkId: req.query.modem.network_id, 62 networkId: req.query.modem.network_id,
63 networkName: req.query.modem_network_name, 63 networkName: req.query.modem_network_name,
64 signalStrength: req.query.modem_signal_strength, 64 signalStrength: req.query.modem_signal_strength,
65 uptime: req.query.uptime, 65 uptime: req.query.uptime,
66 reportIp: req.query.report_ip || req.ip, 66 reportIp: req.query.report_ip || req.ip,
67 reportPort: req.query.report_port, 67 reportPort: req.query.report_port,
68 reportApikey: req.query.report_apikey, 68 reportApikey: req.query.report_apikey,
69 reportPathSms: req.query.report_path_sms || '/sms', 69 reportPathSms: req.query.report_path_sms || '/sms',
70 }); 70 });
71 */ 71 */
72 72
73 logger.info('APISERVER: Incoming SMS', { modem: req.query.modem, from: req.query.number, from_with_suffix: numberWithSuffix, msg: req.query.msg }); 73 logger.info('APISERVER: Incoming SMS', { modem: req.query.modem, from: req.query.number, from_with_suffix: numberWithSuffix, msg: req.query.msg });
74 messagingService.onIncomingMessage({ 74 messagingService.onIncomingMessage({
75 me: req.query.modem, 75 me: req.query.modem,
76 partner: numberWithSuffix, 76 partner: numberWithSuffix,
77 partner_raw: req.query.number, 77 partner_raw: req.query.number,
78 msg: req.query.msg, 78 msg: req.query.msg,
79 origin_label: `IMSI_${req.query.modem_imsi || 'UNKNOWN'}`, 79 origin_label: `IMSI_${req.query.modem_imsi || 'UNKNOWN'}`,
80 origin_transport: 'SMS', 80 origin_transport: 'SMS',
81 origin_partner: req.query.number, 81 origin_partner: req.query.number,
82 do_not_forward_to_core: req.query.number.indexOf('+') !== 0, 82 do_not_forward_to_core: req.query.number.indexOf('+') !== 0,
83 }) 83 })
84 } 84 }
85 85
86 async function pageHistory(req, res) { 86 async function pageHistory(req, res) {
87 res.json(await history.dump()); 87 res.json(await history.dump());
88 } 88 }
89 89
90 app.use(function(req, res, next) { 90 app.use(function(req, res, next) {
91 if ( req && req.path && typeof req.path === 'string' && req.path.search(/\/modems\/set$/) >= 0 ) {
92 next();
93 return;
94 }
95
91 logger.verbose('APISERVER: Incoming http request', { ip: req.ip, path: req.path, url: req.url }); 96 logger.verbose('APISERVER: Incoming http request', { ip: req.ip, path: req.path, url: req.url });
92 next(); 97 next();
93 }) 98 })
94 99
95 app.use('/apikey/:apikey', apikeyChecker); 100 app.use('/apikey/:apikey', apikeyChecker);
96 app.get('/apikey/:apikey/on-sms', onIncomingSms); 101 app.get('/apikey/:apikey/on-sms', onIncomingSms);
97 app.get('/apikey/:apikey/inbox', onIncomingSms); 102 app.get('/apikey/:apikey/inbox', onIncomingSms);
98 app.get('/apikey/:apikey/on-sms/inbox', onIncomingSms); 103 app.get('/apikey/:apikey/on-sms/inbox', onIncomingSms);
99 app.get('/apikey/:apikey/history', pageHistory); 104 app.get('/apikey/:apikey/history', pageHistory);
100 app.use('/apikey/:apikey/modems', routerModems); 105 app.use('/apikey/:apikey/modems', routerModems);
101 106
102 const listenPort = config && config.handler_callback_server ? config.handler_callback_server.listen_port : null; 107 const listenPort = config && config.handler_callback_server ? config.handler_callback_server.listen_port : null;
103 listenPort && app.listen(listenPort, () => { 108 listenPort && app.listen(listenPort, () => {
104 logger.info('HTTP Handler Callback server listening on port ' + listenPort); 109 logger.info('HTTP Handler Callback server listening on port ' + listenPort);
105 }) 110 })