Komodo / komodo-center-sms

Download as
Browse Code ยป

Commit a40e6288deeb22c1ec1f532aad9919df21bfeda2

Authored by Adhidarma Hadiwinoto
1 parent 005696bb33
Exists in master

perbaikan path router-modems

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

lib/apiserver/index.js
Diff comments   View file @ a40e628
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 if (req.query.number.indexOf('+') !== 0) return; 40 if (req.query.number.indexOf('+') !== 0) return;
41 41
42 const numberWithSuffix = req.query.number.replace(/^\+/, '') + (config.number_suffix || ''); 42 const numberWithSuffix = req.query.number.replace(/^\+/, '') + (config.number_suffix || '');
43 43
44 partnerLastSeen.set(req.query.number, req.query.modem_imsi); 44 partnerLastSeen.set(req.query.number, req.query.modem_imsi);
45 45
46 history.push({ 46 history.push({
47 ts: req.query.ts || moment().format('YYYY-MM-DD HH:mm:ss'), 47 ts: req.query.ts || moment().format('YYYY-MM-DD HH:mm:ss'),
48 modem: { 48 modem: {
49 name: req.query.modem, 49 name: req.query.modem,
50 imsi: req.query.modem_imsi, 50 imsi: req.query.modem_imsi,
51 msisdn: req.query.modem_msisdn, 51 msisdn: req.query.modem_msisdn,
52 }, 52 },
53 direction: 'INCOMING', 53 direction: 'INCOMING',
54 partner: req.query.number, 54 partner: req.query.number,
55 message: req.query.msg, 55 message: req.query.msg,
56 }); 56 });
57 57
58 modems.set({ 58 modems.set({
59 name: req.query.modem, 59 name: req.query.modem,
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 device: req.query.modem_device, 62 device: req.query.modem_device,
63 uptime: req.query.uptime, 63 uptime: req.query.uptime,
64 reportIp: req.query.report_ip || req.ip, 64 reportIp: req.query.report_ip || req.ip,
65 reportPort: req.query.report_port, 65 reportPort: req.query.report_port,
66 reportApikey: req.query.report_apikey, 66 reportApikey: req.query.report_apikey,
67 reportPathSms: req.query.report_path_sms || '/sms', 67 reportPathSms: req.query.report_path_sms || '/sms',
68 }); 68 });
69 69
70 logger.info('APISERVER: Incoming SMS', { modem: req.query.modem, from: req.query.number, from_with_suffix: numberWithSuffix, msg: req.query.msg }); 70 logger.info('APISERVER: Incoming SMS', { modem: req.query.modem, from: req.query.number, from_with_suffix: numberWithSuffix, msg: req.query.msg });
71 messagingService.onIncomingMessage({ 71 messagingService.onIncomingMessage({
72 me: req.query.modem, 72 me: req.query.modem,
73 partner: numberWithSuffix, 73 partner: numberWithSuffix,
74 msg: req.query.msg 74 msg: req.query.msg
75 }) 75 })
76 } 76 }
77 77
78 async function pageHistory(req, res) { 78 async function pageHistory(req, res) {
79 res.json(await history.dump()); 79 res.json(await history.dump());
80 } 80 }
81 81
82 app.use(function(req, res, next) { 82 app.use(function(req, res, next) {
83 logger.verbose('APISERVER: Incoming http request', { ip: req.ip, url: req.url }); 83 logger.verbose('APISERVER: Incoming http request', { ip: req.ip, url: req.url });
84 next(); 84 next();
85 }) 85 })
86 86
87 app.use('/apikey/:apikey', apikeyChecker); 87 app.use('/apikey/:apikey', apikeyChecker);
88 app.get('/apikey/:apikey/on-sms', onIncomingSms); 88 app.get('/apikey/:apikey/on-sms', onIncomingSms);
89 app.get('/apikey/:apikey/inbox', onIncomingSms); 89 app.get('/apikey/:apikey/inbox', onIncomingSms);
90 app.get('/apikey/:apikey/on-sms/inbox', onIncomingSms); 90 app.get('/apikey/:apikey/on-sms/inbox', onIncomingSms);
91 app.get('/apikey/:apikey/history', pageHistory); 91 app.get('/apikey/:apikey/history', pageHistory);
92 app.use('/modems', routerModems); 92 app.use('/apikey/:apikey/modems', routerModems);
93 93
94 const listenPort = config && config.handler_callback_server ? config.handler_callback_server.listen_port : null; 94 const listenPort = config && config.handler_callback_server ? config.handler_callback_server.listen_port : null;
95 listenPort && app.listen(listenPort, () => { 95 listenPort && app.listen(listenPort, () => {
96 logger.info('HTTP Handler Callback server listening on port ' + listenPort); 96 logger.info('HTTP Handler Callback server listening on port ' + listenPort);
97 }) 97 })