var helper = require(__dirname + '/test-helper');
var Connection = require('connection');
var con = new Connection({stream: "NO"});
var client = new Client({connection:con});


con.connect = function() {
  con.emit('connect');
};
con.query = function() {
};
client.connect();

var raisedDrain = false;
client.on('drain', function() {
  raisedDrain = true;
});

client.query("hello");
client.query("sup");
client.query('boom');

test("with pending queries", function() {
  test("does not emit drain", function() {
    assert.equal(raisedDrain, false);
  });
});

test("after some queries executed", function() {
  con.emit('readyForQuery');
  test("does not emit drain", function() {
    assert.equal(raisedDrain, false);
  });
});

test("when all queries are sent", function() {
  con.emit('readyForQuery');
  con.emit('readyForQuery');
  test("does not emit drain", function() {
    assert.equal(raisedDrain, false);
  });
});

test("after last query finishes", function() {
  con.emit('readyForQuery');
  test("emits drain", function() {
    process.nextTick(function() {
      assert.ok(raisedDrain);
    })
  });
});