diff --git a/copy-to.js b/copy-to.js index ad66b45..5947bdd 100644 --- a/copy-to.js +++ b/copy-to.js @@ -1,3 +1,5 @@ +'use strict'; + module.exports = function(txt, options) { return new CopyStreamQuery(txt, options) } @@ -77,7 +79,7 @@ CopyStreamQuery.prototype._transform = function(chunk, enc, cb) { case code.NoticeResponse: case code.NotificationResponse: break; - + case code.ErrorResponse: case code.CopyDone: this.pushBufferIfneeded(); diff --git a/index.js b/index.js index ccac224..c1b23f1 100644 --- a/index.js +++ b/index.js @@ -1,3 +1,5 @@ +'use strict'; + var CopyToQueryStream = require('./copy-to') module.exports = { to: function(txt, options) { diff --git a/test/binary.js b/test/binary.js index a20366e..700c11d 100644 --- a/test/binary.js +++ b/test/binary.js @@ -1,3 +1,5 @@ +'use strict'; + var assert = require('assert') var gonna = require('gonna') @@ -19,7 +21,7 @@ var testBinaryCopy = function() { var fromClient = client() var toClient = client() - queries = [ + var queries = [ 'DROP TABLE IF EXISTS data', 'CREATE TABLE IF NOT EXISTS data (num BIGINT, word TEXT)', 'INSERT INTO data (num, word) VALUES (1, \'hello\'), (2, \'other thing\'), (3, \'goodbye\')', @@ -33,7 +35,7 @@ var testBinaryCopy = function() { var fromStream = fromClient.query(to('COPY (SELECT * FROM data) TO STDOUT BINARY')) var toStream = toClient.query(from('COPY data_copy FROM STDIN BINARY')) - runStream = function(callback) { + var runStream = function(callback) { fromStream.on('error', callback) toStream.on('error', callback) toStream.on('finish', callback) diff --git a/test/copy-from.js b/test/copy-from.js index 1765ca5..ee98a11 100644 --- a/test/copy-from.js +++ b/test/copy-from.js @@ -1,3 +1,5 @@ +'use strict'; + var assert = require('assert') var gonna = require('gonna') @@ -68,6 +70,6 @@ var testSingleEnd = function() { if (count == 1) fromClient.end(); }) stream.end(Buffer('1\n')) - + } testSingleEnd() diff --git a/test/copy-to.js b/test/copy-to.js index 50bd7c8..9e88e71 100644 --- a/test/copy-to.js +++ b/test/copy-to.js @@ -1,3 +1,5 @@ +'use strict'; + var assert = require('assert') var gonna = require('gonna') @@ -29,7 +31,7 @@ var testComparators = function() { assert(copy1._gotCopyOutResponse, 'should have received CopyOutResponse') assert(!copy1._remainder, 'Message with no additional data (len=Int4Len+0) should not leave a remainder') })) - copy1.end(new Buffer([code.CopyOutResponse, 0x00, 0x00, 0x00, 0x04])); + copy1.end(new Buffer([code.CopyOutResponse, 0x00, 0x00, 0x00, 0x04])); } @@ -104,8 +106,8 @@ var testNoticeResponse = function() { stream.on('data', function(data) { }) stream.on('error', callback) - - // make sure stream is pulled from + + // make sure stream is pulled from stream.pipe(concat(callback.bind(null,null))) } @@ -118,5 +120,3 @@ var testNoticeResponse = function() { } testNoticeResponse(); - - diff --git a/test/index.js b/test/index.js index 0985e40..a2324ff 100644 --- a/test/index.js +++ b/test/index.js @@ -1,3 +1,5 @@ +'use strict'; + require('./copy-from') require('./copy-to') require('./binary')