summaryrefslogtreecommitdiffstats
path: root/common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js
diff options
context:
space:
mode:
Diffstat (limited to 'common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js')
-rw-r--r--common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js511
1 files changed, 0 insertions, 511 deletions
diff --git a/common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js b/common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js
deleted file mode 100644
index 2fc17da..0000000
--- a/common/src/main/webapp/usageguide/appserver/node_modules/mongodb/lib/server.js
+++ /dev/null
@@ -1,511 +0,0 @@
-"use strict";
-
-var EventEmitter = require('events').EventEmitter
- , inherits = require('util').inherits
- , CServer = require('mongodb-core').Server
- , Cursor = require('./cursor')
- , AggregationCursor = require('./aggregation_cursor')
- , CommandCursor = require('./command_cursor')
- , f = require('util').format
- , ServerCapabilities = require('./topology_base').ServerCapabilities
- , Store = require('./topology_base').Store
- , Define = require('./metadata')
- , MongoError = require('mongodb-core').MongoError
- , MAX_JS_INT = require('./utils').MAX_JS_INT
- , translateOptions = require('./utils').translateOptions
- , filterOptions = require('./utils').filterOptions
- , mergeOptions = require('./utils').mergeOptions
- , os = require('os');
-
-// Get package.json variable
-var driverVersion = require(__dirname + '/../package.json').version;
-var nodejsversion = f('Node.js %s, %s', process.version, os.endianness());
-var type = os.type();
-var name = process.platform;
-var architecture = process.arch;
-var release = os.release();
-
-/**
- * @fileOverview The **Server** class is a class that represents a single server topology and is
- * used to construct connections.
- *
- * **Server Should not be used, use MongoClient.connect**
- * @example
- * var Db = require('mongodb').Db,
- * Server = require('mongodb').Server,
- * test = require('assert');
- * // Connect using single Server
- * var db = new Db('test', new Server('localhost', 27017););
- * db.open(function(err, db) {
- * // Get an additional db
- * db.close();
- * });
- */
-
- // Allowed parameters
- var legalOptionNames = ['ha', 'haInterval', 'acceptableLatencyMS'
- , 'poolSize', 'ssl', 'checkServerIdentity', 'sslValidate'
- , 'sslCA', 'sslCert', 'sslKey', 'sslPass', 'socketOptions', 'bufferMaxEntries'
- , 'store', 'auto_reconnect', 'autoReconnect', 'emitError'
- , 'keepAlive', 'noDelay', 'connectTimeoutMS', 'socketTimeoutMS'
- , 'loggerLevel', 'logger', 'reconnectTries', 'reconnectInterval', 'monitoring'
- , 'appname', 'domainsEnabled'
- , 'servername', 'promoteLongs', 'promoteValues', 'promoteBuffers'];
-
-/**
- * Creates a new Server instance
- * @class
- * @deprecated
- * @param {string} host The host for the server, can be either an IP4, IP6 or domain socket style host.
- * @param {number} [port] The server port if IP4.
- * @param {object} [options=null] Optional settings.
- * @param {number} [options.poolSize=5] Number of connections in the connection pool for each server instance, set to 5 as default for legacy reasons.
- * @param {boolean} [options.ssl=false] Use ssl connection (needs to have a mongod server with ssl support)
- * @param {object} [options.sslValidate=true] Validate mongod server certificate against ca (needs to have a mongod server with ssl support, 2.4 or higher)
- * @param {boolean|function} [options.checkServerIdentity=true] Ensure we check server identify during SSL, set to false to disable checking. Only works for Node 0.12.x or higher. You can pass in a boolean or your own checkServerIdentity override function.
- * @param {array} [options.sslCA=null] Array of valid certificates either as Buffers or Strings (needs to have a mongod server with ssl support, 2.4 or higher)
- * @param {(Buffer|string)} [options.sslCert=null] String or buffer containing the certificate we wish to present (needs to have a mongod server with ssl support, 2.4 or higher)
- * @param {(Buffer|string)} [options.sslKey=null] String or buffer containing the certificate private key we wish to present (needs to have a mongod server with ssl support, 2.4 or higher)
- * @param {(Buffer|string)} [options.sslPass=null] String or buffer containing the certificate password (needs to have a mongod server with ssl support, 2.4 or higher)
- * @param {string} [options.servername=null] String containing the server name requested via TLS SNI.
- * @param {object} [options.socketOptions=null] Socket options
- * @param {boolean} [options.socketOptions.autoReconnect=true] Reconnect on error.
- * @param {boolean} [options.socketOptions.noDelay=true] TCP Socket NoDelay option.
- * @param {number} [options.socketOptions.keepAlive=0] TCP KeepAlive on the socket with a X ms delay before start.
- * @param {number} [options.socketOptions.connectTimeoutMS=0] TCP Connection timeout setting
- * @param {number} [options.socketOptions.socketTimeoutMS=0] TCP Socket timeout setting
- * @param {number} [options.reconnectTries=30] Server attempt to reconnect #times
- * @param {number} [options.reconnectInterval=1000] Server will wait # milliseconds between retries
- * @param {number} [options.monitoring=true] Triggers the server instance to call ismaster
- * @param {number} [options.haInterval=10000] The interval of calling ismaster when monitoring is enabled.
- * @param {boolean} [options.domainsEnabled=false] Enable the wrapping of the callback in the current domain, disabled by default to avoid perf hit.
- * @fires Server#connect
- * @fires Server#close
- * @fires Server#error
- * @fires Server#timeout
- * @fires Server#parseError
- * @fires Server#reconnect
- * @property {string} parserType the parser type used (c++ or js).
- * @return {Server} a Server instance.
- */
-var Server = function(host, port, options) {
- options = options || {};
- if(!(this instanceof Server)) return new Server(host, port, options);
- EventEmitter.call(this);
- var self = this;
-
- // Filter the options
- options = filterOptions(options, legalOptionNames);
-
- // Stored options
- var storeOptions = {
- force: false
- , bufferMaxEntries: typeof options.bufferMaxEntries == 'number' ? options.bufferMaxEntries : MAX_JS_INT
- }
-
- // Shared global store
- var store = options.store || new Store(self, storeOptions);
-
- // Detect if we have a socket connection
- if(host.indexOf('\/') != -1) {
- if(port != null && typeof port == 'object') {
- options = port;
- port = null;
- }
- } else if(port == null) {
- throw MongoError.create({message: 'port must be specified', driver:true});
- }
-
- // Get the reconnect option
- var reconnect = typeof options.auto_reconnect == 'boolean' ? options.auto_reconnect : true;
- reconnect = typeof options.autoReconnect == 'boolean' ? options.autoReconnect : reconnect;
-
- // Clone options
- var clonedOptions = mergeOptions({}, {
- host: host, port: port, disconnectHandler: store,
- cursorFactory: Cursor,
- reconnect: reconnect,
- emitError: typeof options.emitError == 'boolean' ? options.emitError : true,
- size: typeof options.poolSize == 'number' ? options.poolSize : 5
- });
-
- // Translate any SSL options and other connectivity options
- clonedOptions = translateOptions(clonedOptions, options);
-
- // Socket options
- var socketOptions = options.socketOptions && Object.keys(options.socketOptions).length > 0
- ? options.socketOptions : options;
-
- // Translate all the options to the mongodb-core ones
- clonedOptions = translateOptions(clonedOptions, socketOptions);
- if(typeof clonedOptions.keepAlive == 'number') {
- clonedOptions.keepAliveInitialDelay = clonedOptions.keepAlive;
- clonedOptions.keepAlive = clonedOptions.keepAlive > 0;
- }
-
- // Build default client information
- this.clientInfo = {
- driver: {
- name: "nodejs",
- version: driverVersion
- },
- os: {
- type: type,
- name: name,
- architecture: architecture,
- version: release
- },
- platform: nodejsversion
- }
-
- // Build default client information
- clonedOptions.clientInfo = this.clientInfo;
- // Do we have an application specific string
- if(options.appname) {
- clonedOptions.clientInfo.application = { name: options.appname };
- }
-
- // Create an instance of a server instance from mongodb-core
- var server = new CServer(clonedOptions);
-
- // Define the internal properties
- this.s = {
- // Create an instance of a server instance from mongodb-core
- server: server
- // Server capabilities
- , sCapabilities: null
- // Cloned options
- , clonedOptions: clonedOptions
- // Reconnect
- , reconnect: clonedOptions.reconnect
- // Emit error
- , emitError: clonedOptions.emitError
- // Pool size
- , poolSize: clonedOptions.size
- // Store Options
- , storeOptions: storeOptions
- // Store
- , store: store
- // Host
- , host: host
- // Port
- , port: port
- // Options
- , options: options
- }
-}
-
-inherits(Server, EventEmitter);
-
-var define = Server.define = new Define('Server', Server, false);
-
-// BSON property
-Object.defineProperty(Server.prototype, 'bson', {
- enumerable: true, get: function() {
- return this.s.server.s.bson;
- }
-});
-
-// Last ismaster
-Object.defineProperty(Server.prototype, 'isMasterDoc', {
- enumerable:true, get: function() {
- return this.s.server.lastIsMaster();
- }
-});
-
-Object.defineProperty(Server.prototype, 'parserType', {
- enumerable:true, get: function() {
- return this.s.server.parserType;
- }
-});
-
-// Last ismaster
-Object.defineProperty(Server.prototype, 'poolSize', {
- enumerable:true, get: function() { return this.s.server.connections().length; }
-});
-
-Object.defineProperty(Server.prototype, 'autoReconnect', {
- enumerable:true, get: function() { return this.s.reconnect; }
-});
-
-Object.defineProperty(Server.prototype, 'host', {
- enumerable:true, get: function() { return this.s.host; }
-});
-
-Object.defineProperty(Server.prototype, 'port', {
- enumerable:true, get: function() { return this.s.port; }
-});
-
-// Connect
-Server.prototype.connect = function(db, _options, callback) {
- var self = this;
- if('function' === typeof _options) callback = _options, _options = {};
- if(_options == null) _options = {};
- if(!('function' === typeof callback)) callback = null;
- self.s.options = _options;
-
- // Update bufferMaxEntries
- self.s.storeOptions.bufferMaxEntries = db.bufferMaxEntries;
-
- // Error handler
- var connectErrorHandler = function() {
- return function(err) {
- // Remove all event handlers
- var events = ['timeout', 'error', 'close'];
- events.forEach(function(e) {
- self.s.server.removeListener(e, connectHandlers[e]);
- });
-
- self.s.server.removeListener('connect', connectErrorHandler);
-
- // Try to callback
- try {
- callback(err);
- } catch(err) {
- process.nextTick(function() { throw err; })
- }
- }
- }
-
- // Actual handler
- var errorHandler = function(event) {
- return function(err) {
- if(event != 'error') {
- self.emit(event, err);
- }
- }
- }
-
- // Error handler
- var reconnectHandler = function() {
- self.emit('reconnect', self);
- self.s.store.execute();
- }
-
- // Reconnect failed
- var reconnectFailedHandler = function(err) {
- self.emit('reconnectFailed', err);
- self.s.store.flush(err);
- }
-
- // Destroy called on topology, perform cleanup
- var destroyHandler = function() {
- self.s.store.flush();
- }
-
- // Connect handler
- var connectHandler = function() {
- // Clear out all the current handlers left over
- ["timeout", "error", "close", 'serverOpening', 'serverDescriptionChanged', 'serverHeartbeatStarted',
- 'serverHeartbeatSucceeded', 'serverHeartbeatFailed', 'serverClosed', 'topologyOpening',
- 'topologyClosed', 'topologyDescriptionChanged'].forEach(function(e) {
- self.s.server.removeAllListeners(e);
- });
-
- // Set up listeners
- self.s.server.on('timeout', errorHandler('timeout'));
- self.s.server.once('error', errorHandler('error'));
- self.s.server.on('close', errorHandler('close'));
- // Only called on destroy
- self.s.server.on('destroy', destroyHandler);
-
- // relay the event
- var relay = function(event) {
- return function(t, server) {
- self.emit(event, t, server);
- }
- }
-
- // Set up SDAM listeners
- self.s.server.on('serverDescriptionChanged', relay('serverDescriptionChanged'));
- self.s.server.on('serverHeartbeatStarted', relay('serverHeartbeatStarted'));
- self.s.server.on('serverHeartbeatSucceeded', relay('serverHeartbeatSucceeded'));
- self.s.server.on('serverHeartbeatFailed', relay('serverHeartbeatFailed'));
- self.s.server.on('serverOpening', relay('serverOpening'));
- self.s.server.on('serverClosed', relay('serverClosed'));
- self.s.server.on('topologyOpening', relay('topologyOpening'));
- self.s.server.on('topologyClosed', relay('topologyClosed'));
- self.s.server.on('topologyDescriptionChanged', relay('topologyDescriptionChanged'));
- self.s.server.on('attemptReconnect', relay('attemptReconnect'));
- self.s.server.on('monitoring', relay('monitoring'));
-
- // Emit open event
- self.emit('open', null, self);
-
- // Return correctly
- try {
- callback(null, self);
- } catch(err) {
- console.log(err.stack)
- process.nextTick(function() { throw err; })
- }
- }
-
- // Set up listeners
- var connectHandlers = {
- timeout: connectErrorHandler('timeout'),
- error: connectErrorHandler('error'),
- close: connectErrorHandler('close')
- };
-
- // Add the event handlers
- self.s.server.once('timeout', connectHandlers.timeout);
- self.s.server.once('error', connectHandlers.error);
- self.s.server.once('close', connectHandlers.close);
- self.s.server.once('connect', connectHandler);
- // Reconnect server
- self.s.server.on('reconnect', reconnectHandler);
- self.s.server.on('reconnectFailed', reconnectFailedHandler);
-
- // Start connection
- self.s.server.connect(_options);
-}
-
-// Server capabilities
-Server.prototype.capabilities = function() {
- if(this.s.sCapabilities) return this.s.sCapabilities;
- if(this.s.server.lastIsMaster() == null) return null;
- this.s.sCapabilities = new ServerCapabilities(this.s.server.lastIsMaster());
- return this.s.sCapabilities;
-}
-
-define.classMethod('capabilities', {callback: false, promise:false, returns: [ServerCapabilities]});
-
-// Command
-Server.prototype.command = function(ns, cmd, options, callback) {
- this.s.server.command(ns, cmd, options, callback);
-}
-
-define.classMethod('command', {callback: true, promise:false});
-
-// Insert
-Server.prototype.insert = function(ns, ops, options, callback) {
- this.s.server.insert(ns, ops, options, callback);
-}
-
-define.classMethod('insert', {callback: true, promise:false});
-
-// Update
-Server.prototype.update = function(ns, ops, options, callback) {
- this.s.server.update(ns, ops, options, callback);
-}
-
-define.classMethod('update', {callback: true, promise:false});
-
-// Remove
-Server.prototype.remove = function(ns, ops, options, callback) {
- this.s.server.remove(ns, ops, options, callback);
-}
-
-define.classMethod('remove', {callback: true, promise:false});
-
-// IsConnected
-Server.prototype.isConnected = function() {
- return this.s.server.isConnected();
-}
-
-Server.prototype.isDestroyed = function() {
- return this.s.server.isDestroyed();
-}
-
-define.classMethod('isConnected', {callback: false, promise:false, returns: [Boolean]});
-
-// Insert
-Server.prototype.cursor = function(ns, cmd, options) {
- options.disconnectHandler = this.s.store;
- return this.s.server.cursor(ns, cmd, options);
-}
-
-define.classMethod('cursor', {callback: false, promise:false, returns: [Cursor, AggregationCursor, CommandCursor]});
-
-Server.prototype.lastIsMaster = function() {
- return this.s.server.lastIsMaster();
-}
-
-/**
- * Unref all sockets
- * @method
- */
-Server.prototype.unref = function() {
- this.s.server.unref();
-}
-
-Server.prototype.close = function(forceClosed) {
- this.s.server.destroy();
- // We need to wash out all stored processes
- if(forceClosed == true) {
- this.s.storeOptions.force = forceClosed;
- this.s.store.flush();
- }
-}
-
-define.classMethod('close', {callback: false, promise:false});
-
-Server.prototype.auth = function() {
- var args = Array.prototype.slice.call(arguments, 0);
- this.s.server.auth.apply(this.s.server, args);
-}
-
-define.classMethod('auth', {callback: true, promise:false});
-
-Server.prototype.logout = function() {
- var args = Array.prototype.slice.call(arguments, 0);
- this.s.server.logout.apply(this.s.server, args);
-}
-
-define.classMethod('logout', {callback: true, promise:false});
-
-/**
- * All raw connections
- * @method
- * @return {array}
- */
-Server.prototype.connections = function() {
- return this.s.server.connections();
-}
-
-define.classMethod('connections', {callback: false, promise:false, returns:[Array]});
-
-/**
- * Server connect event
- *
- * @event Server#connect
- * @type {object}
- */
-
-/**
- * Server close event
- *
- * @event Server#close
- * @type {object}
- */
-
-/**
- * Server reconnect event
- *
- * @event Server#reconnect
- * @type {object}
- */
-
-/**
- * Server error event
- *
- * @event Server#error
- * @type {MongoError}
- */
-
-/**
- * Server timeout event
- *
- * @event Server#timeout
- * @type {object}
- */
-
-/**
- * Server parseError event
- *
- * @event Server#parseError
- * @type {object}
- */
-
-module.exports = Server;