milojs/milo

'use strict';

/* eslint-env browser, commonjs, node, mocha */

var assert = require('assert')
    , request = milo.util.request
    , uniqueId = milo.util.uniqueId;


require('../../mocks/xmlhttprequest');


var currentTestResponse;
function testResponse(data) {
    return currentTestResponse(data);
}


var requests = {
    GET: {
        'http://example.com/test1': 'test1',
        'http://example.com/test3': '{"data": "test3"}'
    },
    POST: {
        'http://example.com/test2': testResponse,
        'http://example.com/test4': testResponse
    }
};


describe('request', function() {
    this.timeout(10000);

    var requestMessageDispatched, requestMessages;

    before(function() {
        window.XMLHttpRequest.setMockRoutes(requests);
        request.useMessenger();
        request.on(/.*/, function(msg, data) {
            requestMessages.push(msg);
            requestMessageDispatched();
        });
    });


    beforeEach(function() {
        requestMessages = [];
    });


    it('should send request', function(done) {
        var completed = requestMessageDispatched = doneTimes(5, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        var promise = request('http://example.com/test1', { method: 'GET' }, function(err, resp) {
            assert.equal(resp, 'test1');
            completed();
        });

        promise.then(function(data) {
            assert.equal(data, 'test1');
            completed();
        });
    });


    it('should define request.get', function(done) {
        var completed = requestMessageDispatched = doneTimes(4, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        request.get('http://example.com/test1', function(err, resp) {
            assert.equal(resp, 'test1');
            completed();
        });
    });


    it('should define request.post', function(done) {
        var completed = requestMessageDispatched = doneTimes(4, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        var testData = { data: 'test2' };
        currentTestResponse = function(data) {
            assert.deepEqual(JSON.parse(data), testData);
            return 'test2 response';
        };

        request.post('http://example.com/test2', testData, function(err, resp) {
            assert.equal(resp, 'test2 response');
            completed();
        });
    });


    it('should define request.json', function(done) {
        var completed = requestMessageDispatched = doneTimes(5, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        var promise = request.json('http://example.com/test3', function(err, resp) {
            assert.deepEqual(resp, {"data": "test3"});
            completed();
        });

        promise.then(function(data) {
            assert.deepEqual(data, {"data": "test3"});
            completed();
        });
    });


    it('should define request.jsonp', function(done) {
        var completed = requestMessageDispatched = doneTimes(5, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        var promise = request.jsonp('http://example.com/test3', function(err, resp) {
            assert.deepEqual(resp, {"data": "test3"});
            completed();
        });

        window['___milo_callback_' + uniqueId.get()]({"data": "test3"});

        promise.then(function(data) {
            assert.deepEqual(data, {"data": "test3"});
            completed();
        });
    });


    it('should define request.file', function(done) {
        var completed = requestMessageDispatched = doneTimes(5, function() {
            assert.deepEqual(requestMessages, ['request', 'success', 'requestscompleted']);
            done();
        });

        currentTestResponse = function(data) {
            return 'test4 uploaded';
        };

        var promise = request.file('http://example.com/test4', 'file data', function(err, resp) {
            assert.equal(resp, 'test4 uploaded');
            completed();
        });

        promise.then(function(data) {
            assert.equal(data, 'test4 uploaded');
            completed();
        });
    });


    it('should define request.whenRequestsCompleted', function(done) {
        requestMessageDispatched = doneTimes(9, function() {
            assert.deepEqual(requestMessages, [
                'request', 'test_whenRequestsCompleted_none',
                'request', 'success', 'request',
                'success', 'success', 'requestscompleted',
                'test_whenRequestsCompleted_all'
            ]);
            done();
        });

        request.whenRequestsCompleted(function() {
            request.postMessageSync('test_whenRequestsCompleted_none');
        });

        request.get('http://example.com/test3', function() {
            request.get('http://example.com/test1', function () {
                request.get('http://example.com/test1');
            });
        });        

        request.whenRequestsCompleted(function() {
            request.postMessage('test_whenRequestsCompleted_all');
        });
    });


    function doneTimes(counter, done) {
        return function () {
            if (!--counter) done();
        };
    }
});