stream-and-query-error-interaction-tests.js

'use strict'
var helper = require(__dirname + '/test-helper')
var Connection = require(__dirname + '/../../../lib/connection')
var Client = require(__dirname + '/../../../lib/client')

test('emits end when not in query', function () {
  var stream = new (require('events').EventEmitter)()
  stream.write = function () {
    // NOOP
  }

  var client = new Client({connection: new Connection({stream: stream})})
  client.connect(assert.calls(function () {
    client.query('SELECT NOW()', assert.calls(function (err, result) {
      assert(err)
    }))
  }))
  assert.emits(client, 'error')
  assert.emits(client, 'end')
  client.connection.emit('connect')
  process.nextTick(function () {
    client.connection.emit('readyForQuery')
    assert.equal(client.queryQueue.length, 0)
    assert(client.activeQuery, 'client should have issued query')
    process.nextTick(function () {
      stream.emit('close')
    })
  })
})