index.js
1.9 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
"use strict";
const request = require('request');
const config = require('komodo-sdk/config');
const logger = require('komodo-sdk/logger');
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() ) {
return;
}
const partner = params.partner.trim();
const msg = params.msg.trim();
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,
from: partner,
from_raw: params.from_raw,
msg: msg,
do_not_forward_to_core: params.do_not_forward_to_core,
}
}
request(requestOptions, function(err, res, body) {
if (err) {
logger.warn('MESSAGING-CLIENT-LIB: error on request to CORE', {err: err});
return;
}
try {
var data = JSON.parse(body);
}
catch(e) {
//logger.verbose('Direct response is not on JSON format, forwarding raw response');
sendToPartner(partner, body);
return;
}
//logger.verbose('DEBUG', {msg: data.message, err: data.error});
const responseMessage = data.message || data.error;
sendToPartner(partner, responseMessage);
})
}
function sendToPartner(partner, msg) {
if (transport && transport.send) {
transport.send(partner, msg);
}
}
exports.setTransport = setTransport;
exports.onIncomingMessage = onIncomingMessage;
exports.sendToPartner = sendToPartner;