test-change-user-eject.js

var assert = require('assert');
var common = require('../../common');
var pool   = common.createPool({
  connectionLimit : 2,
  user            : 'user_1',
  port            : common.fakeServerPort
});

var closed = 0;
var server = common.createFakeServer();
var thread = 0;

server.listen(common.fakeServerPort, function(err) {
  assert.ifError(err);

  var conn0;
  var threadId;
  pool.getConnection(function(err, conn) {
    assert.ifError(err);
    assert.ok(conn.threadId === 1 || conn.threadId === 2);
    conn0 = conn;
    threadId = conn.threadId;
  });

  pool.getConnection(function(err, conn) {
    assert.ifError(err);
    assert.ok(conn.threadId === 1 || conn.threadId === 2);

    var threadId = conn.threadId;

    conn.changeUser({user: 'user_2'}, function(err) {
      assert.ifError(err);
      assert.strictEqual(conn.threadId, threadId);
      conn.release();
      conn0.release();
    });
  });

  pool.getConnection(function(err, conn1) {
    assert.ifError(err);
    assert.strictEqual(conn1.threadId, 3);

    pool.getConnection(function(err, conn2) {
      assert.ifError(err);
      assert.strictEqual(conn2.threadId, threadId);
      conn1.release();
      conn2.release();

      pool.end(function(err) {
        assert.ifError(err);
        assert.strictEqual(closed, 3);
        server.destroy();
      });
    });
  });
});

server.on('connection', function(incomingConnection) {
  incomingConnection.handshake({
    threadId: ++thread
  });
  incomingConnection.on('quit', function() {
    closed++;
  });
});