index.js
2.81 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
const DEBUG_ON_NON_JSON_DIRECT_RESPONSE = !!(process.env.DEBUG_ON_NON_JSON_DIRECT_RESPONSE)
const request = require('request');
const config = require('komodo-sdk/config');
const logger = require('komodo-sdk/logger');
if (!process.env.KOMODO_MESSAGING_DO_NOT_LISTEN) {
require('./http-callback-handler');
}
let transport;
const originData = {
origin: config.origin,
report_port: config.listen_port
}
function setTransport(_transport) {
transport = _transport;
}
function onIncomingMessage(params) {
if ( typeof params.partner !== 'string' || typeof params.msg !== 'string' || !params.partner.trim() || !params.msg.trim() ) {
logger.verbose('Not reporting to messaging center because of invalid parameter. F68CCCD74E79');
return;
}
const requestOptions = {
url: config.messaging_url,
qs: {
origin: originData.origin,
origin_label: params.origin_label,
origin_transport: params.origin_transport,
report_port: originData.report_port,
partner: params.partner,
partner_raw: params.partner_raw || params.partner,
from: params.partner,
from_raw: params.partner_raw || params.partner,
msg: params.msg.trim(),
do_not_forward_to_core: params.do_not_forward_to_core || null,
is_outgoing: params.is_outgoing || null,
}
}
logger.verbose('MESSAGING-CLIENT-LIB: Sending report to messaging service', { qs: requestOptions.qs });
request(requestOptions, function(err, res, body) {
if (err) {
logger.warn('MESSAGING-CLIENT-LIB: error on request to messaging service', {err: err});
return;
}
logger.verbose('MESSAGING-CLIENT-LIB: Got resposnse', { body });
if (params.do_not_forward_to_core) return;
if (params.is_outgoing) return;
try {
var data = JSON.parse(body);
}
catch(e) {
if (DEBUG_ON_NON_JSON_DIRECT_RESPONSE) {
logger.verbose('MESSAGING-CLIENT-LIB: direct response from messaging service is not on JSON format, forwarding raw response', {
partner: params.partner,
msg: params.msg.trim(),
directResponse: body,
});
}
sendToPartner(params.partner, body);
return;
}
//logger.verbose('DEBUG', {msg: data.message, err: data.error});
const responseMessage = data.message || data.error;
sendToPartner(params.partner, responseMessage);
})
}
function sendToPartner(partner, msg) {
if (transport && transport.send) {
transport.send(partner, msg);
}
}
exports.setTransport = setTransport;
exports.onIncomingMessage = onIncomingMessage;
exports.sendToPartner = sendToPartner;