request.js

const url = require("url");

/**
 * Does a http request
 * @param {*} uri 
 * @param {*} options 
 * @param {*} cb 
 * 
 * @ignore
 * 
 * @returns {http.ClientRequest} https://nodejs.org/dist/latest-v16.x/docs/api/http.html#class-httpclientrequest
 */
function perform(uri, options, cb) {

    let { protocol } = new url.URL(uri);

    if (!["http:", "https:"].includes(protocol)) {
        throw new Error(`Unspported protocol "${protocol.slice(0, -1)}`);
    }

    if (process.env.AUTH_TOKEN) {

        if (!options.headers) {
            options.headers = {};
        }

        options.headers["x-auth-token"] = process.env.AUTH_TOKEN;

    }

    let request = require(protocol.slice(0, -1)).request(uri, options, (res) => {

        let chunks = [];

        res.on("data", (chunk) => {
            chunks.push(chunk);
        });

        res.on("error", cb);

        res.on("end", () => {

            let body = Buffer.concat(chunks);

            if (res.headers["content-type"] && res.headers["content-type"].includes("application/json")) {
                body = JSON.parse(body);
            }

            cb(null, {
                headers: res.headers,
                status: res.statusCode,
                body
            });

        });

    });


    request.on("error", (err) => {
        cb(err);
    });


    if (options.callEnd) {
        request.end(options.body);
    }
    //request.write(options.body + "\r\n");

    return request;

}


/**
 *  @function request
 * Does a http/https request
 *
 * @param {String} uri 
 * @param {Object} options 
 * @param {Function} cb Callback

 * @returns {http.ClientRequest} https://nodejs.org/dist/latest-v16.x/docs/api/http.html#class-httpclientrequest
 */
module.exports = function request(uri, options, cb) {

    if (!cb && options instanceof Function) {
        cb = options;
        options = {};
    }

    if (!cb) {
        cb = () => { };
    }

    options = Object.assign({
        method: "GET",
        body: "",
        followRedirects: true,
        callEnd: true,
    }, options);


    return perform(uri, options, (err, result) => {
        if (err) {

            cb(err);

        } else {

            if (options.followRedirects && result.status >= 300 && result.status < 400) {

                perform(result.headers.location, options, cb);

            } else {

                cb(null, result);

            }

        }
    });

};