Put VarnishEmu in its own module
This commit is contained in:
parent
dc9286b610
commit
61dbe15dee
@ -1,31 +1,8 @@
|
|||||||
var assert = require('../support/assert');
|
var assert = require('../support/assert');
|
||||||
var net = require('net');
|
|
||||||
require(__dirname + '/../support/test_helper');
|
require(__dirname + '/../support/test_helper');
|
||||||
var CacheValidator = require(__dirname + '/../../lib/cartodb/cache_validator');
|
var CacheValidator = require(__dirname + '/../../lib/cartodb/cache_validator');
|
||||||
var tests = module.exports = {};
|
|
||||||
|
|
||||||
function VarnishEmu(on_cmd_recieved, test_callback) {
|
var VarnishEmu = require('../support/VarnishEmu');
|
||||||
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() {
|
suite('cache_validator', function() {
|
||||||
|
|
||||||
|
25
test/support/VarnishEmu.js
Normal file
25
test/support/VarnishEmu.js
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
var net = require('net');
|
||||||
|
|
||||||
|
module.exports = function(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();
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
Loading…
Reference in New Issue
Block a user