enigma-bbs/core/http_util.js

102 lines
2.5 KiB
JavaScript
Raw Normal View History

const { Errors } = require('./enig_error.js');
// deps
const { isString, isObject, truncate } = require('lodash');
const https = require('https');
const httpSignature = require('http-signature');
const crypto = require('crypto');
exports.getJson = getJson;
exports.postJson = postJson;
function getJson(url, options, cb) {
2023-01-14 06:55:05 +00:00
options = Object.assign({}, { method: 'GET' }, options);
2023-01-14 06:55:05 +00:00
return _makeRequest(url, options, (err, body, res) => {
if (err) {
return cb(err);
}
let parsed;
try {
parsed = JSON.parse(body);
} catch (e) {
return cb(e);
}
return cb(null, parsed, res);
});
}
function postJson(url, json, options, cb) {
if (!isString(json)) {
json = JSON.stringify(json);
}
2023-01-14 06:55:05 +00:00
options = Object.assign({}, { method: 'POST', body: json }, options);
if (
!options.headers ||
!Object.keys(options.headers).find(h => h.toLowerCase() === 'content-type')
) {
options.headers['Content-Type'] = 'application/json';
}
2023-01-14 06:55:05 +00:00
return _makeRequest(url, options, cb);
}
2023-01-14 06:55:05 +00:00
function _makeRequest(url, options, cb) {
if (options.body) {
options.headers['Content-Length'] = options.body.length;
if (options?.sign?.headers?.includes('digest')) {
2023-01-20 05:31:14 +00:00
options.headers['Digest'] =
'SHA-256=' +
crypto.createHash('sha256').update(options.body).digest('base64');
2023-01-14 06:55:05 +00:00
}
}
const req = https.request(url, options, res => {
let body = [];
res.on('data', d => {
body.push(d);
});
res.on('end', () => {
body = Buffer.concat(body).toString();
if (res.statusCode < 200 || res.statusCode > 299) {
return cb(
Errors.HttpError(
`HTTP error ${res.statusCode}: ${truncate(body, { length: 128 })}`
2023-01-14 06:55:05 +00:00
)
);
}
return cb(null, body, res);
});
});
if (isObject(options.sign)) {
try {
httpSignature.sign(req, options.sign);
} catch (e) {
req.destroy();
return cb(Errors.Invalid(`Invalid signing material: ${e}`));
}
}
req.on('error', err => {
return cb(err);
});
req.on('timeout', () => {
req.destroy();
return cb(Errors.Timeout('Timeout making HTTP request'));
});
2023-01-20 05:31:14 +00:00
if (options.body) {
req.write(options.body);
}
req.end();
}