All files / Nodejs/lib/apis 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
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
80
81
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
'use strict';
 
var http = require("http");
var https = require("https");
var URL = require("url");
var extend = require("extend");
 
module.exports = {
	post: function (url, data, opts) {
		var api = http;
		if (url.match(/^https/)) {
			api = https;
		}
 
		opts = Object.assign(URL.parse(url), extend(true, {
			method: "POST",
			headers: {
				'Content-Type': 'application/json',
			},
			timeout: 1000 * 10
		}, opts));
 
		return new Promise((resolve, reject) => {
			console.log(opts.method.toUpperCase(), ":", url);
			var req = api.request(opts, (res) => {
				var result = "";
				res.on("data", (chunk) => result += chunk);
				res.on("end", () => {
					try {
						var r = result === "" ? undefined : JSON.parse(result);
						resolve(r)
					} catch (err) {
						reject({
							response: result,
							message: err.message
						});
					}
				});
			}).on("error", (err) => {
				reject({
					message: err.message
				});
			});
 
			if (data != undefined) {
				req.write(JSON.stringify(data));
			}
			req.end();
		});
	},
 
	get: function (url, data, opts) {
		var api = http;
		if (url.match(/^https/)) {
			api = https;
		}
 
		return new Promise((resolve, reject) => {
			console.log("GET:", url);
			var req = api.get(url, (res) => {
				var result = "";
				res.on("data", (chunk) => result += chunk);
				res.on("end", () => {
					try {
						var r = result === "" ? undefined : JSON.parse(result);
						resolve(r)
					} catch (err) {
						reject({
							response: result,
							message: err.message
						});
					}
				});
			}).on("error", (err) => {
				reject({
					message: err.message
				});
			});
		});
	}
}