varnish.js

var assert = require('assert');
var net = require('net');
var varnish = require(__dirname + '/../../lib/node-varnish');
var VarnishEmu = require('./varnish_emu');
var tests = module.exports = {};

suite('varnish', function() {

    test('should connect', function(done) {
        var ok = false;
        var server = new VarnishEmu();
        server.on('listening', function() {
            var client = new varnish.VarnishClient('127.0.0.1', server.address().port);
            client.on('connect', function() {
                ok = true;
            });
        });
        setTimeout(function() {
            assert.ok(ok); 
            server.close_connections();
            server.close(done);
        }, 200);
    });

    test('should send a command', function(done) {
        var ok = false;
        var server = new VarnishEmu(function() {
            ok = true;
        });
        server.on('listening', function() {
            var client = new varnish.VarnishClient('127.0.0.1', server.address().port);
            client.on('ready', function myReady() {
                client.run_cmd('purge obj.http.X == test', function(){});
            });
        });
        setTimeout(function() {
            assert.ok(ok); 
            server.close_connections();
            server.close(done);
        }, 100);
    });
    
    test('should emit close on server disconect', function(done) {
        var ok = false;
        var server = new VarnishEmu();
        server.on('listening', function() {
            var client = new varnish.VarnishClient('127.0.0.1', server.address().port);
            client.on('ready', function() {
                client.on('close', function() { ok = true; });
                server.close_connections();
                server.close();
            });
        });
        setTimeout(function() { 
            assert.ok(ok); 
            done(); 
        }, 500);
    });

    test('should emit response on command', function(done) {
        var ok = false;
        var server = new VarnishEmu();
        server.on('listening', function() {
            var client = new varnish.VarnishClient('127.0.0.1', server.address().port);
            client.on('ready', function() {
                client.run_cmd('purge obj.http.X == test', function(){});
                client.on('response', function(code, body) {
                    ok = true;
                    assert.equal(200, code);
                });
            });
        });
        setTimeout(function() { 
            assert.ok(ok); 
            server.close_connections();
            server.close();
            done(); 
        }, 100);
    });

    test('should emit error when the user tries to send when thereis a pending command', function(done) {
        var ok = false;
        var server = new VarnishEmu();
        server.on('listening', function() {
            var client = new varnish.VarnishClient('127.0.0.1', server.address().port);
            client.on('ready', function() {
                client.run_cmd('purge obj.http.X == test', function(){});
                client.on('error', function(e) {
                    ok = true;
                    assert.equal('RESPONSE_PENDING', e.code);
                });
                client.run_cmd('purge obj.http.X == test', function(){});
            });
        });
        setTimeout(function() { assert.ok(ok); done(); }, 100);
    });
    
    //
    // queue
    //
    
    test('should send command', function(done) {
        var server = new VarnishEmu();
        server.on('listening', function() {
            var queue = new varnish.VarnishQueue('127.0.0.1', server.address().port);
            for(var i = 0; i < 5; ++i) {
                queue.run_cmd('purge simon_is == the_best');
            }
            queue.on('empty', function() {
                assert.equal(5, server.commands);
                done();
            }); 
        });
    });

    test('should not send duplicate commands if asked', function(done) {
        var server = new VarnishEmu();
        server.on('listening', function() {
            var queue = new varnish.VarnishQueue('127.0.0.1', server.address().port);
            for(var i = 0; i < 5; ++i) {
                queue.run_cmd('purge ' + (i%2), true);
            }
            queue.on('empty', function() {
                assert.equal(2, server.commands);
                done();
            }); 
        });
    });
    
    test('should send commands on connect', function(done) {
        // first create queue
        var queue = new varnish.VarnishQueue('127.0.0.1', 1234);
        for(var i = 0; i < 10; ++i) {
            queue.run_cmd('purge simon_is == the_best');
        }

        // then server
        var server = new VarnishEmu(null, 1234);

        queue.on('empty', function() {
            assert.equal(10, server.commands); done();
        });
    });
    
    //
    // auth
    //
    
    test('should authenticate', function(done) {
        var ok = false;
        var server = new VarnishEmu(null, null, true);//requires auth
        
        server.on('listening', function() {
            var secret = 'foo',
                client = new varnish.VarnishClient('127.0.0.1', server.address().port, secret);
            //client.debug = true;
            client.on('connect', function() {
                ok = true;
            });
        });
        setTimeout(function() {
            assert.ok(ok); 
            server.close_connections();
            server.close(done);
        }, 200);
    });
});