Windshaft-cartodb/test/acceptance/cache_validator.js

var assert      = require('../support/assert');
var net = require('net');
require(__dirname + '/../support/test_helper');
var CacheValidator = require(__dirname + '/../../lib/cartodb/cache_validator');
var tests = module.exports = {};

function VarnishEmu(on_cmd_recieved, test_callback) {
    var self = this;
    var welcome_msg = 'hi, im a varnish emu, right?';

    self.commands_recieved = [];

    var server = net.createServer(function (socket) {
      var command = '';
      socket.write("200 " + welcome_msg.length + "\n");
      socket.write(welcome_msg);
      socket.on('data', function(data) {        
        self.commands_recieved.push(data);
        on_cmd_recieved && on_cmd_recieved(self.commands_recieved);
        socket.write('200 0\n');
      });
    });
    server.listen(1337, "127.0.0.1");
    
    server.on('listening', function(){
      test_callback();
    });    
}

suite('cache_validator', function() {

    test('should call purge on varnish when invalidate database', function(done) {
        var varnish = new VarnishEmu(function(cmds) {
            assert.ok(cmds.length == 1);        
            assert.equal('purge obj.http.X-Cache-Channel ~ \"^test_db:(.*test_cache.*)|(table)$\"\n', cmds[0].toString('utf8'));
            done();
        },
        function() {
            CacheValidator.init('localhost', 1337);
            CacheValidator.invalidate_db('test_db', 'test_cache');
        });
    });

});