277d33715c
* [ping()] determine ping timeout at runtime * generate * single line * remove pingTimeout param * [docs] Add note about pingTimeout priority * remove default ping requestTimeout test * add test
85 lines
2.6 KiB
JavaScript
85 lines
2.6 KiB
JavaScript
describe('Client instances creation', function () {
|
|
var stream = require('stream');
|
|
var util = require('util');
|
|
|
|
var es = require('../../../src/elasticsearch');
|
|
var apis = require('../../../src/lib/apis');
|
|
var expect = require('expect.js');
|
|
var stub = require('../../utils/auto_release_stub').make();
|
|
var client;
|
|
|
|
describe('', function () {
|
|
beforeEach(function () {
|
|
client = new es.Client();
|
|
});
|
|
|
|
afterEach(function () {
|
|
client.close();
|
|
});
|
|
|
|
it('throws an error linking to the es module when you try to instanciate the exports', function () {
|
|
var Es = es;
|
|
expect(function () {
|
|
var c = new Es();
|
|
return c
|
|
}).to.throwError(/previous "elasticsearch" module/);
|
|
});
|
|
|
|
var pkg = require('../../../package.json');
|
|
var def = pkg.config.default_api_branch;
|
|
var prev = pkg.config.supported_es_branches[pkg.config.supported_es_branches.indexOf(def) + 1];
|
|
|
|
it('inherits the ' + def + ' API by default', function () {
|
|
expect(client.bulk).to.be(apis[def].bulk);
|
|
expect(client.nodes.stats).to.be(apis[def].nodes.prototype.stats);
|
|
});
|
|
|
|
it('inherits the ' + prev + ' API when specified', function () {
|
|
client.close();
|
|
client = es.Client({
|
|
apiVersion: prev
|
|
});
|
|
expect(client.bulk).to.be(apis[prev].bulk);
|
|
expect(client.cluster.nodeStats).to.be(apis[prev].cluster.prototype.nodeStats);
|
|
});
|
|
|
|
it('closing the client causes it\'s transport to be closed', function () {
|
|
var called = false;
|
|
client.transport.close = function () {
|
|
called = true;
|
|
};
|
|
client.close();
|
|
expect(called).to.be(true);
|
|
});
|
|
|
|
it('creates a warning level logger by default', function () {
|
|
expect(client.transport.log.listenerCount('error')).to.eql(1);
|
|
expect(client.transport.log.listenerCount('warning')).to.eql(1);
|
|
expect(client.transport.log.listenerCount('info')).to.eql(0);
|
|
expect(client.transport.log.listenerCount('debug')).to.eql(0);
|
|
expect(client.transport.log.listenerCount('trace')).to.eql(0);
|
|
});
|
|
});
|
|
|
|
describe('config', function () {
|
|
it('accepts a stream type logger', function (done) {
|
|
function NullStream() {
|
|
stream.Writable.call(this);
|
|
}
|
|
util.inherits(NullStream, stream.Writable);
|
|
|
|
NullStream.prototype._write = function (/* chunk, encoding, next */) {
|
|
done();
|
|
};
|
|
|
|
client = new es.Client({
|
|
log: [
|
|
{ type: 'stream', stream: new NullStream() }
|
|
]
|
|
});
|
|
|
|
client.transport.log.error(new Error());
|
|
});
|
|
});
|
|
});
|