Use connection.enqueue in fetchDbConnectInfo (#106)

Author: alexpenev-s

lib/protocol/Connection.js

@@ -531,7 +531,7 @@ Connection.prototype.rollback = function rollback(options, cb) {
 };
 
 Connection.prototype.fetchDbConnectInfo = function (options, cb) {
-  this.send(request.dbConnectInfo(options), function (err, reply) {
+  this.enqueue(request.dbConnectInfo(options), function(err, reply) {
     if (err) {
       return cb(err);
     }

test/lib.Connection.js

@@ -392,9 +392,11 @@ describe('Lib', function () {
       var DATA = require('./mock/data/dbConnectInfo');
 
       function prepareConnection(segmentData) {
-        var connection = createConnection();
-
-        connection.send = function (msg, cb) {
+          var connection = createConnection();
+          connection._socket = {
+            readyState: 'open'
+          };
+          connection.send = function (msg, cb) {
           var segment = new lib.reply.Segment(segmentData.kind, segmentData.functionCode);
           var part = segmentData.parts[0];
           segment.push(new lib.reply.Part(part.kind, part.attributes, part.argumentCount, part.buffer));
@@ -404,39 +406,26 @@ describe('Lib', function () {
         return connection;
       }
 
-      it('should fetch DB_CONNECT_INFO (not connected)', function (done) {
+      it('should fetch DB_CONNECT_INFO with an error', function (done) {
         var connection = prepareConnection(DATA.NOT_CONNECTED);
+        connection._socket = undefined;
 
         connection.fetchDbConnectInfo({}, function (err, info) {
-          info.isConnected.should.equal(false);
-          info.host.should.equal('12.34.56.123');
-          info.port.should.equal(31144);
+          err.code.should.equal('EHDBCLOSE')
           done();
         });
       });
 
       it('should fetch DB_CONNECT_INFO (connected)', function (done) {
         var connection = prepareConnection(DATA.CONNECTED);
-
+        connection._queue.resume();
         connection.fetchDbConnectInfo({}, function (err, info) {
           info.isConnected.should.equal(true);
           (!!info.host).should.be.not.ok;
           (!!info.port).should.be.not.ok;
           done();
         });
       });
-
-      it('fetch DB_CONNECT_INFO with an error', function (done) {
-        var connection = createConnection();
-        connection.send = function (msg, cb) {
-          cb(new Error('Request was not successful'));
-        };
-
-        connection.fetchDbConnectInfo({}, function (err) {
-          err.message.should.equal('Request was not successful');
-          done();
-        });
-      });
     });
 
     it('should connect to the database', function (done) {