From d20e47f644f3e5b700040240f5022c1ad8e52ddc Mon Sep 17 00:00:00 2001 From: brianc Date: Fri, 8 Oct 2010 23:17:09 -0500 Subject: [PATCH] writes simple query --- lib/index.js | 4 ++-- test/communication-tests.js | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/lib/index.js b/lib/index.js index 953bf4ae..cc8b3f0f 100644 --- a/lib/index.js +++ b/lib/index.js @@ -92,8 +92,8 @@ sys.inherits(Query, EventEmitter); Query.prototype.toBuffer = function() { var textBuffer = new Buffer(this.text,'utf8'); - var len = textBuffer.length; - var fullBuffer = new Buffer(textBuffer.length + 5); + var len = textBuffer.length + 4; + var fullBuffer = new Buffer(len + 1); fullBuffer[0] = 0x51; fullBuffer[1] = len >>> 24; fullBuffer[2] = len >>> 16; diff --git a/test/communication-tests.js b/test/communication-tests.js index 222c7531..dd4af00c 100644 --- a/test/communication-tests.js +++ b/test/communication-tests.js @@ -63,7 +63,7 @@ test('query queue', function() { }); test('calling query queues the query object', function() { - var query = client.query('select * from bang'); + var query = client.query('!'); assert.length(client.queryQueue, 1); }); @@ -72,6 +72,7 @@ test('query queue', function() { var handled = stream.emit('data', buffers.readyForQuery()); assert.ok(handled, "Stream should have had data handled"); assert.length(stream.packets, 1); + assert.equalBuffers(stream.packets[0], [0x51,0,0,0,5,33]) }); });