test tweaks

This commit is contained in:
brianc 2010-10-06 21:34:51 -05:00
parent 25fe2be510
commit 9c55891521
3 changed files with 19 additions and 5 deletions

View File

@ -1,4 +1,5 @@
require(__dirname+'/test-helper');
var buffers = require(__dirname+'/test-buffers');
test('client can take existing stream', function() {
var stream = new MemoryStream();
@ -44,3 +45,14 @@ test('using opened stream', function() {
client.connect();
});
});
test('query queue', function() {
var stream = new MemoryStream();
stream.readyState = 'open';
var client = new Client({stream: stream});
client.query('select * from bang');
assert.empty(stream.packets);
stream.emit('data', buffers.ReadyForQuery);
assert.equal(stream.packets.length, 1);
});

View File

@ -1,5 +1,5 @@
require(__dirname+'/test-helper');
var buffers = require(__dirname+'/test-buffers');
var PARSE = function(buffer) {
return new Parser(buffer).parse();
};
@ -18,9 +18,7 @@ var backendKeyDataBuffer = new BufferList()
.addInt32(2)
.join(true,'K');
var readyForQueryBuffer = new BufferList()
.add(Buffer('I'))
.join(true,'Z');
var readyForQueryBuffer = buffers.readyForQuery;
var commandCompleteBuffer = new BufferList()
.addCString("SELECT 3")

View File

@ -10,6 +10,10 @@ assert.same = function(actual, expected) {
}
};
assert.empty = function(actual) {
assert.equal(actual.length, 0);
};
test = function(name, action) {
for(var i = 0; i < test.tabout; i++) {
@ -97,9 +101,9 @@ BufferList.concat = function() {
MemoryStream = function() {
EventEmitter.call(this);
this.packets = [];
};
sys.inherits(MemoryStream, EventEmitter);
var p = MemoryStream.prototype;