private-cloud/console/mini_poem/http/request.js

/**
 * Created by Strawmanbobi
 * 2014-08-30
 */

// system inclusion
var queryString = require('querystring');
var http = require('http');
var request = require('request');

// local inclusion
var Map = require('../mem/map.js');
var ErrorCode = require('../configuration/error_code.js');

var errorCode = new ErrorCode();

var logger = require('../logging/logger4js').helper;

/**
 *
 * @param _host : host of service server
 * @param _port : port of service server
 * @param _service : service URL parameter
 * @param _queryParams : map of query parameters
 * @constructor
 */
var Request = function(_host, _port, _service, _queryParams) {
    this.host = _host;
    this.port = _port;
    this.service = _service;
    this.queryParams = _queryParams;
};

Request.prototype.urlizeQueryParams = function() {
    var i = 0;
    var urlParams = '';
    var paramElement = null;
    if(undefined == this.queryParams || null == this.queryParams) {
        return  '';
    }
    if(this.queryParams instanceof Map) {
        for(i = 0; i < this.queryParams.size(); i++) {
            paramElement = this.queryParams.element(i);
            if(0 == i) {
                urlParams += '?';
            } else {
                urlParams += '&';
            }
            urlParams += paramElement.key + '=' + paramElement.value;
        }
        return urlParams;
    }
    return '';
};

Request.prototype.sendGetRequest = function(options, callback) {
    var data = '';
    var httpTag = options.https ? 'https://' : 'http://';
    var url = httpTag + this.host + ':' + this.port + this.service +
        this.urlizeQueryParams();

    if(options.https) {
        request(
            {
                method: 'GET',
                uri: url
            }, function (error, response, body) {
                if(!error && response.statusCode == '200') {
                    callback(errorCode.SUCCESS, JSON.parse(body));
                } else {
                    callback(errorCode.FAILED, null);
                }
            }
        )
    } else {
        http.get(url, function(res) {
            res.on('data', function (chunk) {
                data += chunk;
            });
            res.on('end', function() {
                if('200' == res.statusCode) {
                    callback(errorCode.SUCCESS, data);
                } else {
                    console.error('HTTP request fault !!');
                    callback(errorCode.FAILED, null);
                }
            });
            res.on('error', function(e) {
                console.error('error occurred when handling response : ' + e);
                callback(errorCode.FAILED, null);
            });
        });
    }
};

Request.prototype.sendPostRequest = function(bodyData, callback) {
    var requestData = JSON.stringify(bodyData);
    var url = this.service +
        this.urlizeQueryParams();
    var options = {
        host: this.host,
        port: this.port,
        path: url,
        method: 'POST',
        headers: {
            'Content-Type': 'application/json'
        }
    };

    var req = http.request(options, function(res) {
        var data = '';
        res.setEncoding('utf8');
        res.on('data', function (chunk) {
            data += chunk;
        });
        res.on('end', function() {
            if('200' == res.statusCode) {
                callback(errorCode.SUCCESS, data);
            } else {
                callback(errorCode.FAILED, null);
            }
        });
    });
    try {
        req.write(requestData);
        req.end();
    } catch(e) {
        console.error('exception occurred in http request : ' + e);
    }
};

Request.prototype.postMultipartForm = function(formData, callback) {
    var url = this.service +
        this.urlizeQueryParams();
    var req = request.post({url: url, formData: formData}, function optionalCallback(err, res, body) {
        if (err) {
            console.error('exception occured in http request : ' + e);
            callback(errorCode.FAILED, null);
        } else {
            if ('200' == res.statusCode) {
                callback(errorCode.SUCCESS, body);
            } else {
                callback(errorCode.FAILED, null);
            }
        }
    });
};

// post simple file to HTTP server
Request.prototype.postSimpleFile = function(fileName, fileContent, contentType, options, callback) {
    var httpTag = options.https ? 'https://' : 'http://';
    var url = httpTag + this.host + ':' + this.port + this.service +
        this.urlizeQueryParams();

    var req = request.post(url, function (err, resp, body) {
        if (err) {
            callback(errorCode.FAILED, resp);
        } else {
            callback(errorCode.SUCCESS, resp);
        }
    });
    var form = req.form();
    form.append('file', fileContent, {
        filename: fileName,
        contentType: contentType
    });
};

module.exports = Request;