http-listener.js
5.46 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
const MODULE_NAME = 'HTTP-LISTENER';
const express = require('express');
const ipfilter = require('express-ipfilter').IpFilter;
const removeAccents = require('remove-accents');
const uniqid = require('uniqid');
const config = require('komodo-sdk/config');
const logger = require('tektrans-logger');
const commandHandler = require('./command-handler');
const messagesArchive = require('./messages-archive');
const app = express();
const port = (config && config.listener && config.listener.http
&& config.listener.http.port && config.listener.http.port
) || 32979;
/**
* Handler utama.
*
* @param {object} req - Express request object
* @param {object} req.query - Express query string object
* @param {string} [req.query.partner] - Partner (pengirim atau penerima)
* @param {string} [req.query.from] - Pengirim, OBSOLETED: gunakan parameter partner
* @param {string} [req.query.from_raw] - Pengirim tanpa suffix (raw), OBSOLETED by partner_raw
* @param {string} [req.query.to] - Tujuan, jika is_outgoing, OBSOLETED: gunakan parameter partner
* @param {string} req.query.msg - Isi pesan
* @param {string} req.query.origin - Nama origin
* @param {string} [req.query.origin_label] - Nama origin untuk ditulis di histori pesan
* @param {string} [req.query.do_not_forward_to_core] - Apakah teruskan pesan ke CORE
* @param {string} [req.query.is_outgoing] - Apakah pesan keluar
* @param {object} res - Express response object
*/
function mainHandler(req, res) {
if (!req.body) req.body = {};
const xid = uniqid();
logger.verbose(`${MODULE_NAME} 72AFD326: Got a request`, {
xid,
query: req.query,
body: req.body,
});
if (
(!req.body.partner && !req.query.partner)
&& (
(!req.query.is_outgoing && !req.body.is_outgoing && !req.query.from && !req.body.from)
|| ((req.query.is_outgoing || req.body.is_outgoing) && !req.query.to && !req.body.to)
)
) {
logger.warn(`${MODULE_NAME} D254B7B454DB: Undefined parameter partner or from or to`, {
xid,
partner: req.body.partner || req.query.partner,
is_outgoing: req.body.is_outgoing || req.query.is_outgoing,
from: req.body.from || req.query.from,
to: req.body.to || req.query.to,
});
res.end('ERROR. Undefined parameter: partner or from or to');
return;
}
// message cleansing
const msg = removeAccents(req.query.msg || req.body.msg || '')
.replace(/[\u{0080}-\u{FFFF}]/gu, '')
.trim();
if (!msg) {
logger.warn(`${MODULE_NAME} #92996A497D12: Undefined parameter msg`, {
xid,
});
res.end(`ERROR. Undefined parameter: msg. XID: ${xid}`);
return;
}
logger.verbose(
`Saving ${req.body.is_outgoing || req.query.is_outgoing ? 'outgoing' : 'incoming'} message history`,
{
xid,
transport: req.body.origin_transport || req.query.origin_transport,
partner: req.body.partner || req.query.partner || req.body.from || req.query.from
|| req.body.to || req.query.to,
msg,
},
);
messagesArchive.insert(
{
origin_label: req.body.origin_label || req.query.origin_label
|| req.body.origin || req.query.origin,
origin_transport: req.body.origin_transport || req.query.origin_transport,
partner: req.body.partner_raw || req.query.partner_raw
|| req.body.from_raw || req.query.from_raw
|| req.body.from || req.query.from
|| req.body.to || req.query.to || req.body.partner || req.query.partner,
msg,
},
(req.body.is_outgoing || req.query.is_outgoing) ? messagesArchive.DIRECTION_OUTGOING
: messagesArchive.DIRECTION_INCOMING,
);
if (
req.body.do_not_forward_to_core || req.query.do_not_forward_to_core
|| req.body.is_outgoing || req.query.is_outgoing
) {
logger.verbose('Ignoring message', {
xid,
from: req.body.from || req.query.from,
msg,
do_not_forward_to_core: req.body.do_not_forward_to_core
|| req.query.do_not_forward_to_core,
});
res.end('OK');
return;
}
if (!req.query.report_port && !req.body.report_port) {
res.end('ERROR. Undefined parameter: report_port');
return;
}
const params = {
origin: req.body.origin || req.query.origin || 'MESSAGING',
origin_transport: req.body.origin_transport || req.query.origin_transport,
report_ip: req.body.report_ip || req.query.report_ip || req.ip,
report_port: req.body.report_port || req.query.report_port,
from: req.body.partner || req.query.partner || req.body.from || req.query.from,
msg,
};
commandHandler(msg, params, (err, coreResponseObject, responseParams) => {
if (err) {
res.end(`ERROR. ${err.message || err}`);
} else if (coreResponseObject) {
res.json(coreResponseObject);
} else {
res.end(responseParams.body);
}
});
}
if (config.ip_whitelist && config.ip_whitelist.length) {
app.use(ipfilter(config.ip_whitelist, { mode: 'allow', log: false }));
}
app.get('/', mainHandler);
app.post('/', express.urlencoded({ extended: true }), mainHandler);
app.listen(port, () => {
logger.info('HTTP-LISTENER: started', {
port, app_env: app.get('env'),
});
});