sendRequest.js

/*
 * mockserver
 * http://mock-server.com
 *
 * Copyright (c) 2014 James Bloom
 * Licensed under the Apache License, Version 2.0
 */
(function () {
    "use strict";

    if (module && require) {
        var Q = require('q');
        var http = require('http');

        var defer = function() {
            var promise = (global.protractor ? protractor.promise : Q);
            var deferred = promise.defer();

            if (deferred.fulfill && !deferred.resolve) {
                deferred.resolve = deferred.fulfill;
            }
            return deferred;
        };

        var sendRequest = function (host, port, path, jsonBody, resolveCallback) {
            var deferred = defer();

            var body = (typeof jsonBody === "string" ? jsonBody : JSON.stringify(jsonBody || ""));
            var options = {
                method: 'PUT',
                host: host,
                path: path,
                port: port,
                headers: {
                    'Content-Type': "application/json; charset=utf-8"
                }
            };

            var req = http.request(options);

            req.once('response', function (response) {
                var data = '';

                if (response.statusCode === 400 || response.statusCode === 404) {
                    deferred.reject(response.statusCode);
                }

                response.on('data', function (chunk) {
                    data += chunk;
                });

                response.on('end', function () {
                    if (resolveCallback) {
                        deferred.resolve(resolveCallback(data));
                    } else {
                        deferred.resolve({
                            statusCode: response.statusCode,
                            body: data
                        });
                    }
                });
            });

            req.once('error', function (error) {
                deferred.reject(error);
            });

            req.write(body);
            req.end();

            return deferred.promise;
        };

        module.exports = {
            sendRequest: sendRequest
        };
    }
})();