index.js
1.63 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
"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,
report_port: originData.report_port,
from: partner,
msg: msg
}
}
request(requestOptions, function(err, res, body) {
if (err) {
logger.warn(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;