index.js
2.47 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
const MODULE_NAME = 'KOMODO-SDK.COREAPI';
const request = require('request');
const logger = require('tektrans-logger');
const coreUrl = require('../core-url');
function isLogDisabled() {
return global.KOMODO_SDK_NO_LOG_ON_COREAPI;
}
if (!isLogDisabled()) {
logger.verbose(`${MODULE_NAME} 229BAC11: Initialized`, {
coreUrl,
});
}
function doRequest(params, cb) {
return new Promise((resolve) => {
const options = {
url: `${coreUrl}/${params.path.replace(/^\/+/, '')}`,
method: params.method || 'GET',
qs: params.qs || null,
};
if (!isLogDisabled()) {
logger.verbose(`${MODULE_NAME} 73C28396: Requesting to CORE`, {
xid: params.xid, method: options.method, fullpath: options.url, qs: options.qs,
});
}
request(options, (err, res, body) => {
if (err) {
if (!isLogDisabled()) {
logger.warn(`${MODULE_NAME} 01738CB9: Error doing HTTP ${options.method} to CORE`, {
xid: params.xid,
eCode: err.code,
eMessage: err.message || err.toString(),
});
}
resolve([err]);
if (typeof cb === 'function') cb(err);
return;
}
if (res.statusCode !== 200) {
const errStatusCode = new Error(`${MODULE_NAME} 39685CF2: CORE responded with non HTTP STATUS CODE 200`);
if (!isLogDisabled()) {
logger.warn(errStatusCode, {
xid: params.xid,
httpStatus: res.statusCode,
body,
});
}
resolve([errStatusCode]);
if (typeof cb === 'function') cb(errStatusCode);
return;
}
let bodyObject;
try {
bodyObject = JSON.parse(body);
} catch (e) {
const errNoJson = new Error('COREAPI: CORE responded with non JSON body');
if (!isLogDisabled()) logger.verbose(errNoJson, { body });
resolve([errNoJson, body]);
if (typeof cb === 'function') cb(errNoJson, body);
return;
}
resolve([null, bodyObject]);
if (typeof cb === 'function') cb(null, bodyObject);
});
});
}
module.exports = doRequest;