nodejsHttpClient/request.js at master · Mojicode/nodejsHttpClient · GitHub

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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
"use strict";

// const request = require('request');
// const async = require('async');
const request = require('sync-request');

function sendPost(url, requestData){
	//sync get request result
	const response = request('POST', url, {
		json: requestData,
		timeout:3000
	});
	// console.log(response);
	const bodyRet = response.getBody('utf8');
	const bodyRetJson = JSON.parse(bodyRet);
	return bodyRetJson;
	/////////////////////////////////////////////////
	//////            can not use          //////////
	// let isResponse = false;
	// let isFirst = true;
	// let errorOut, bodyOut;
	// while(!isResponse){
	// 	if(isFirst){
	// 		isFirst = false;
	// 		request({
	// 			url: url,
	// 			method: "POST",
	// 			json: true,
	// 			headers: {
	// 				"content-type": "application/json",
	// 			},
	// 			body: requestData
	// 		}, function (error, response, body) {
	// 			if (!error && response.statusCode == 200) {
	// 				console.log(body);
	// 				bodyOut = body;
	// 				if (!body.retCode) {
	// 					// resolve(body);
	// 				} else {
	// 					// reject(body);
	// 				}
	// 			} else {
	// 				errorOut = error;
	// 				// reject(error);
	// 			}
	// 			isResponse = true;
	// 		});
	// 	}
	// }
	// if(isResponse){
	// 	console.log("have response");
	// 	if(errorOut === undefined){
	// 		return bodyOut;
	// 	} else {
	// 		throw new Error(errorOut);
	// 	}
	// }
	// console.log("skip while");
	/////////////////////////////////////////////////
	//////            can not use          //////////
	// async.waterfall([
	// 	function(callback){
	// 		request({
	// 			url: url,
	// 			method: "POST",
	// 			json: true,
	// 			headers: {
	// 				"content-type": "application/json",
	// 			},
	// 			// body: JSON.stringify(requestData)
	// 			body: requestData
	// 		}, function(error, response, body) {
	// 			if (!error && response.statusCode == 200) {
	// 				console.log(body);
	// 				callback(null, body);
	// 				// if(!body.retCode){
	// 				// 	resolve(body);
	// 				// } else {
	// 				// 	reject(body);
	// 				// }
	// 			} else {
	// 				// reject(error);
	// 				callback(error, null);
	// 			}
	// 		});
	// 	}

	// ], function(err, result){
	// 	console.log("in async.waterfall callback");
	// 	if(err){
	// 		throw new Error(err)
	// 	} else {
	// 		return result
	// 	}
	// })
	// console.log("after async.waterfall");
	/////////////////////////////////////////////////
	////use request module rather than sync-request//
	// return new Promise( function(resolve, reject) {
	// 	request({
	// 		url: url,
	// 		method: "POST",
	// 		json: true,
	// 		headers: {
	// 			"content-type": "application/json",
	// 		},
	// 		// body: JSON.stringify(requestData)
	// 		body: requestData
	// 	}, function(error, response, body) {
	// 		if (!error && response.statusCode == 200) {
	// 			console.log(body);
	// 			if(!body.retCode){
	// 				resolve(body);
	// 			} else {
	// 				reject(body);
	// 			}
	// 		} else {
	// 			reject(error);
	// 		}
	// 	});
	// })
}

module.exports = sendPost;