-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
376 additions
and
184 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,110 @@ | ||
| 'use strict'; | ||
| /** | ||
| * @module lib/common/httpreq | ||
| * @summary Whiteflag WHL common http requests module | ||
| * @description Module that handles http requests | ||
| */ | ||
| module.exports = { | ||
| // http functions | ||
| get: httpGET, | ||
| post: httpPOST | ||
| }; | ||
|
|
||
| // Node.js core and external modules // | ||
| const http = require('http'); | ||
| const https = require('https'); | ||
|
|
||
| /** | ||
| * Performs an HTTP GET request | ||
| * @function httpGET | ||
| * @alias module:lib/common/httpreq.get | ||
| * @param {URL} url the URL of the request | ||
| * @param {function} callback function to be called upon completion | ||
| */ | ||
| function httpGET(url, callback) { | ||
| const options = { | ||
| method: 'GET' | ||
| }; | ||
| httpRequest(url, options, null, function httpGetCb(err, statusCode, data = null) { | ||
| if (!err && statusCode !== 200) { | ||
| err = new Error(`Request failed (status code ${statusCode})`); | ||
| } | ||
| return callback(err, data); | ||
| }); | ||
| } | ||
|
|
||
| /** | ||
| * Performs an HTTP GET request | ||
| * @function httpPOST | ||
| * @alias module:lib/common/httpreq.post | ||
| * @param {URL} url the URL of the request | ||
| * @param {data} data the data to be in the request body | ||
| * @param {function} callback function to be called upon completion | ||
| */ | ||
| function httpPOST(url, data, callback) { | ||
| const body = JSON.stringify(data); | ||
| const options = { | ||
| method: 'POST', | ||
| headers: { | ||
| 'Content-Type': 'application/json' | ||
| } | ||
| }; | ||
| httpRequest(url, options, body, function httpPostCb(err, statusCode, data = null) { | ||
| if (!err) { | ||
| if (statusCode < 200 || statusCode > 202) { | ||
| err = new Error(`Request failed (status code ${statusCode})`); | ||
| } | ||
| } | ||
| return callback(err, data); | ||
| }); | ||
| } | ||
|
|
||
| // PRIVATE FUNCTIONS // | ||
| /** | ||
| * Performs an HTTP request | ||
| * @private | ||
| * @param {URL} url the URL of the request | ||
| * @param {object} data the data to be in the request body | ||
| * @param {function} callback function to be called upon completion | ||
| */ | ||
| function httpRequest(url, options, body, callback) { | ||
| // Create request with protocol specified in url | ||
| let req; | ||
| const protocol = url.protocol.slice(0, -1); | ||
| switch (protocol) { | ||
| case 'http': { | ||
| req = http.request(url, options, resCb); | ||
| break; | ||
| } | ||
| case 'https': { | ||
| req = https.request(url, options, resCb); | ||
| break; | ||
| } | ||
| default: { | ||
| // Method does not exist | ||
| return callback(new Error(`Unsupported protocol for request: ${protocol}`)); | ||
| } | ||
| } | ||
| // Handle reqest errors | ||
| req.on('error', function httpErrCb(err) { | ||
| return callback(err); | ||
| }); | ||
| req.on('timeout', function httpTimeoutCb(err) { | ||
| req.abort(); | ||
| return callback(new Error(`Aborted request after timeout: ${err.message}`)); | ||
| }); | ||
| // Send request data | ||
| if (body) req.write(body); | ||
| req.end(); | ||
|
|
||
| // Callback functions | ||
| function resCb(res) { | ||
| let data = ''; | ||
| res.on('data', function(chunk) { | ||
| data += chunk; | ||
| }); | ||
| res.on('end', function httpProcessCb() { | ||
| return callback(null, res.statusCode, data); | ||
| }); | ||
| } | ||
| } |
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.