1 files changed, 114 insertions, 0 deletions
diff --git a/lib/promise_request.js b/lib/promise_request.js
new file mode 100644
index 0000000..ca09eee
--- /dev/null
+++ b/lib/promise_request.js
@@ -0,0 +1,114 @@
+/*
+Copyright(c) 2017 AT&T Intellectual Property. All rights reserved. 
+
+Licensed under the Apache License, Version 2.0 (the "License"); 
+you may not use this file except in compliance with the License.
+
+You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, 
+software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
+CONDITIONS OF ANY KIND, either express or implied. 
+See the License for the specific language governing permissions and limitations under the License.
+*/
+ 
+ /* Promise-based HTTP request client */
+ 
+ "use strict";
+ 
+/*
+ * Make an HTTP request using a string for the body 
+ * of the request.
+ * Return a promise for result in the form 
+ * {status: <http status code>, body: <response body>}
+ */
+ 
+const http = require('http');
+const https = require('https');
+const url = require('url');
+const querystring = require('querystring');
+
+exports.doRequest = function(options, body) {
+	
+	return new Promise(function(resolve, reject) {
+	
+		var reqBody = null;
+		if (options.json) {
+			reqBody = JSON.stringify(options.json);
+			options.headers = options.headers || {};
+			options.headers['Content-Type'] = 'application/json';
+		}
+		else if (body) {
+			reqBody = body;
+		}
+		
+		if (options.uri) {
+			var parsed = url.parse(options.uri);
+			options.protocol = parsed.protocol;
+			options.hostname = parsed.hostname;
+			options.port = parsed.port;
+			options.path = parsed.path;
+			if (options.qs) {
+				options.path += ('?' + querystring.stringify(options.qs));
+			}
+		}
+			
+		try {
+			var req = (options.protocol === 'https:' ? https.request(options) : http.request(options));
+		}
+		catch (e) {
+			reject(e);
+		}
+
+		// Reject promise if there's an error
+		req.on('error',  function(error) { 
+			reject(error);	
+		});
+
+		// Capture the response
+		req.on('response', function(resp) {
+
+			// Collect the body of the response
+			var rbody = '';
+			resp.on('data', function(d) {
+				rbody += d;
+			});
+
+			// resolve or reject when finished
+			resp.on('end', function() {
+
+				var result = {
+					status : resp.statusCode,
+					body : rbody
+				};
+
+				// Add a JSON version of the body if appropriate
+				if (rbody.length > 0) {
+					try {
+						var jbody = JSON.parse(rbody);
+						result.json = jbody;
+					} 
+					catch (pe) {
+						// Do nothing, no json property added to the result object
+					}
+				}
+						
+				if (resp.statusCode > 199 && resp.statusCode < 300) {
+					// HTTP status code indicates success - resolve the promise
+					resolve(result);
+				} 
+				else {
+					// Reject the promise
+					reject(result);
+				}
+			});
+		});
+		
+		if (reqBody) {
+				req.write(reqBody, 'utf8');
+		}
+		req.end();
+	});		
+};