Plato - src/http/nodejs.js

/**
 * @file NodeJS specific HTTP implementation
 * @since 0.2.1
 */
/*#ifndef(UMD)*/
"use strict";
/*global _GPF_HOST*/ // Host types
/*global _GpfNodeReadableStream*/ // gpf.node.ReadableStream
/*global _gpfHttpSetRequestImplIf*/ // Set the http request implementation if the host matches
/*global _gpfNodeHttp*/ // Node require("http")
/*global _gpfNodeHttps*/ // Node require("https")
/*global _gpfNodeUrl*/ // Node require("url")
/*global _gpfStringFromStream*/ // Read the stream
/*#endif*/

/*jshint node: true*/
/*eslint-env node*/

function _gpfHttpNodeAdjustSettingsForSend (settings, data) {
    if (data) {
        settings.headers = Object.assign({
            "Content-Type": "application/x-www-form-urlencoded",
            "Content-Length": Buffer.byteLength(data)
        }, settings.headers);
    }
}

function _gpfHttpNodeBuildRequestSettings (request) {
    var settings = Object.assign(_gpfNodeUrl.parse(request.url), request);
    _gpfHttpNodeAdjustSettingsForSend(settings, request.data);
    return settings;
}

function _gpfHttpNodeGetMessageHandler (settings) {
    if (settings.protocol === "https:") {
        return _gpfNodeHttps;
    }
    return _gpfNodeHttp;
}

function _gpfHttpNodeAllocate (request, resolve) {
    var settings = _gpfHttpNodeBuildRequestSettings(request),
        messageHandler = _gpfHttpNodeGetMessageHandler(settings);
    return messageHandler.request(settings, function (nodeResponse) {
        _gpfHttpNodeProcessResponse(nodeResponse, resolve);
    });
}

function _gpfHttpNodeRequestImpl (request, resolve, reject) {
    var clientRequest = _gpfHttpNodeAllocate(request, resolve);
    clientRequest.on("error", reject);
    _gpfHttpNodeSend(clientRequest, request.data);
}

_gpfHttpSetRequestImplIf(_GPF_HOST.NODEJS, _gpfHttpNodeRequestImpl);

src/http/nodejs.js

Maintainability

Lines of code

Difficulty

Estimated Errors

Function weight

By Complexity

By SLOC