-
Notifications
You must be signed in to change notification settings - Fork 14
/
Copy pathHttp.js
47 lines (47 loc) · 1.66 KB
/
Http.js
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
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const Http = require("http");
const Https = require("https");
const Url = require("url");
function httpFetch(url, content, contentType = "application/json; charset=utf-8", secured = true, timeoutMS = 10000) {
let temp = Url.parse(url), options = {
hostname: temp.hostname,
port: Number.parseInt(temp.port),
path: temp.path,
protocol: temp.protocol,
method: "GET",
timeout: timeoutMS,
headers: {}
};
if (content) {
options.method = "POST";
options.headers["Content-Type"] = contentType;
options.headers["Content-Length"] = Buffer.byteLength(content, "utf8");
}
options.rejectUnauthorized = secured;
let requestFn = temp.protocol === "http:" ? Http.request : Https.request;
return new Promise((resolve, reject) => {
let request = requestFn(options, (response) => {
if (response.statusCode < 200 || response.statusCode > 299)
reject(new Error(`Http fetch failed, status = ${response.statusCode}, ${response.statusMessage}`));
else {
response.setEncoding("utf8");
let data = "";
response.on("data", (chunk) => {
data += chunk;
});
response.on("end", () => {
resolve(data);
});
}
});
request.on("error", (ex) => {
reject(ex);
});
if (content != null)
request.write(content);
request.end();
});
}
exports.httpFetch = httpFetch;
//# sourceMappingURL=Http.js.map