summaryrefslogtreecommitdiffstats
path: root/common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js
diff options
context:
space:
mode:
Diffstat (limited to 'common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js')
-rw-r--r--common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js854
1 files changed, 0 insertions, 854 deletions
diff --git a/common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js b/common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js
deleted file mode 100644
index 69c470a..0000000
--- a/common/src/main/webapp/usageguide/appserver/node_modules/mongoose/lib/connection.js
+++ /dev/null
@@ -1,854 +0,0 @@
-/*!
- * Module dependencies.
- */
-
-var utils = require('./utils');
-var EventEmitter = require('events').EventEmitter;
-var driver = global.MONGOOSE_DRIVER_PATH || './drivers/node-mongodb-native';
-var Schema = require('./schema');
-var Collection = require(driver + '/collection');
-var STATES = require('./connectionstate');
-var MongooseError = require('./error');
-var muri = require('muri');
-var PromiseProvider = require('./promise_provider');
-
-/*!
- * Protocol prefix regexp.
- *
- * @api private
- */
-
-var rgxProtocol = /^(?:.)+:\/\//;
-
-/*!
- * A list of authentication mechanisms that don't require a password for authentication.
- * This is used by the authMechanismDoesNotRequirePassword method.
- *
- * @api private
- */
-var authMechanismsWhichDontRequirePassword = [
- 'MONGODB-X509'
-];
-
-/**
- * Connection constructor
- *
- * For practical reasons, a Connection equals a Db.
- *
- * @param {Mongoose} base a mongoose instance
- * @inherits NodeJS EventEmitter http://nodejs.org/api/events.html#events_class_events_eventemitter
- * @event `connecting`: Emitted when `connection.{open,openSet}()` is executed on this connection.
- * @event `connected`: Emitted when this connection successfully connects to the db. May be emitted _multiple_ times in `reconnected` scenarios.
- * @event `open`: Emitted after we `connected` and `onOpen` is executed on all of this connections models.
- * @event `disconnecting`: Emitted when `connection.close()` was executed.
- * @event `disconnected`: Emitted after getting disconnected from the db.
- * @event `close`: Emitted after we `disconnected` and `onClose` executed on all of this connections models.
- * @event `reconnected`: Emitted after we `connected` and subsequently `disconnected`, followed by successfully another successfull connection.
- * @event `error`: Emitted when an error occurs on this connection.
- * @event `fullsetup`: Emitted in a replica-set scenario, when primary and at least one seconaries specified in the connection string are connected.
- * @event `all`: Emitted in a replica-set scenario, when all nodes specified in the connection string are connected.
- * @api public
- */
-
-function Connection(base) {
- this.base = base;
- this.collections = {};
- this.models = {};
- this.config = {autoIndex: true};
- this.replica = false;
- this.hosts = null;
- this.host = null;
- this.port = null;
- this.user = null;
- this.pass = null;
- this.name = null;
- this.options = null;
- this.otherDbs = [];
- this._readyState = STATES.disconnected;
- this._closeCalled = false;
- this._hasOpened = false;
-}
-
-/*!
- * Inherit from EventEmitter
- */
-
-Connection.prototype.__proto__ = EventEmitter.prototype;
-
-/**
- * Connection ready state
- *
- * - 0 = disconnected
- * - 1 = connected
- * - 2 = connecting
- * - 3 = disconnecting
- *
- * Each state change emits its associated event name.
- *
- * ####Example
- *
- * conn.on('connected', callback);
- * conn.on('disconnected', callback);
- *
- * @property readyState
- * @api public
- */
-
-Object.defineProperty(Connection.prototype, 'readyState', {
- get: function() {
- return this._readyState;
- },
- set: function(val) {
- if (!(val in STATES)) {
- throw new Error('Invalid connection state: ' + val);
- }
-
- if (this._readyState !== val) {
- this._readyState = val;
- // loop over the otherDbs on this connection and change their state
- for (var i = 0; i < this.otherDbs.length; i++) {
- this.otherDbs[i].readyState = val;
- }
-
- if (STATES.connected === val) {
- this._hasOpened = true;
- }
-
- this.emit(STATES[val]);
- }
- }
-});
-
-/**
- * A hash of the collections associated with this connection
- *
- * @property collections
- */
-
-Connection.prototype.collections;
-
-/**
- * The mongodb.Db instance, set when the connection is opened
- *
- * @property db
- */
-
-Connection.prototype.db;
-
-/**
- * A hash of the global options that are associated with this connection
- *
- * @property config
- */
-
-Connection.prototype.config;
-
-/**
- * Opens the connection to MongoDB.
- *
- * `options` is a hash with the following possible properties:
- *
- * config - passed to the connection config instance
- * db - passed to the connection db instance
- * server - passed to the connection server instance(s)
- * replset - passed to the connection ReplSet instance
- * user - username for authentication
- * pass - password for authentication
- * auth - options for authentication (see http://mongodb.github.com/node-mongodb-native/api-generated/db.html#authenticate)
- *
- * ####Notes:
- *
- * Mongoose forces the db option `forceServerObjectId` false and cannot be overridden.
- * Mongoose defaults the server `auto_reconnect` options to true which can be overridden.
- * See the node-mongodb-native driver instance for options that it understands.
- *
- * _Options passed take precedence over options included in connection strings._
- *
- * @param {String} connection_string mongodb://uri or the host to which you are connecting
- * @param {String} [database] database name
- * @param {Number} [port] database port
- * @param {Object} [options] options
- * @param {Function} [callback]
- * @see node-mongodb-native https://github.com/mongodb/node-mongodb-native
- * @see http://mongodb.github.com/node-mongodb-native/api-generated/db.html#authenticate
- * @api public
- */
-
-Connection.prototype.open = function(host, database, port, options, callback) {
- var parsed;
- var Promise = PromiseProvider.get();
-
- if (typeof database === 'string') {
- switch (arguments.length) {
- case 2:
- port = 27017;
- break;
- case 3:
- switch (typeof port) {
- case 'function':
- callback = port;
- port = 27017;
- break;
- case 'object':
- options = port;
- port = 27017;
- break;
- }
- break;
- case 4:
- if (typeof options === 'function') {
- callback = options;
- options = {};
- }
- }
- } else {
- switch (typeof database) {
- case 'function':
- callback = database;
- database = undefined;
- break;
- case 'object':
- options = database;
- database = undefined;
- callback = port;
- break;
- }
-
- if (!rgxProtocol.test(host)) {
- host = 'mongodb://' + host;
- }
-
- try {
- parsed = muri(host);
- } catch (err) {
- this.error(err, callback);
- return this;
- }
-
- database = parsed.db;
- host = parsed.hosts[0].host || parsed.hosts[0].ipc;
- port = parsed.hosts[0].port || 27017;
- }
-
- this.options = this.parseOptions(options, parsed && parsed.options);
-
- // make sure we can open
- if (STATES.disconnected !== this.readyState) {
- var err = new Error('Trying to open unclosed connection.');
- err.state = this.readyState;
- this.error(err, callback);
- return new Promise.ES6(function(resolve, reject) {
- reject(err);
- });
- }
-
- if (!host) {
- this.error(new Error('Missing hostname.'), callback);
- return new Promise.ES6(function(resolve, reject) {
- reject(err);
- });
- }
-
- if (!database) {
- this.error(new Error('Missing database name.'), callback);
- return new Promise.ES6(function(resolve, reject) {
- reject(err);
- });
- }
-
- // authentication
- if (this.optionsProvideAuthenticationData(options)) {
- this.user = options.user;
- this.pass = options.pass;
- } else if (parsed && parsed.auth) {
- this.user = parsed.auth.user;
- this.pass = parsed.auth.pass;
-
- // Check hostname for user/pass
- } else if (/@/.test(host) && /:/.test(host.split('@')[0])) {
- host = host.split('@');
- var auth = host.shift().split(':');
- host = host.pop();
- this.user = auth[0];
- this.pass = auth[1];
- } else {
- this.user = this.pass = undefined;
- }
-
- // global configuration options
- if (options && options.config) {
- this.config.autoIndex = options.config.autoIndex !== false;
- }
-
- this.name = database;
- this.host = host;
- this.port = port;
-
- var _this = this;
- var promise = new Promise.ES6(function(resolve, reject) {
- _this._open(true, function(error) {
- callback && callback(error);
- if (error) {
- reject(error);
- if (!callback && !promise.$hasHandler) {
- _this.emit('error', error);
- }
- return;
- }
- resolve();
- });
- });
- return promise;
-};
-
-/**
- * Helper for `dropDatabase()`.
- *
- * @param {Function} callback
- * @return {Promise}
- * @api public
- */
-
-Connection.prototype.dropDatabase = function(callback) {
- var Promise = PromiseProvider.get();
- var _this = this;
- var promise = new Promise.ES6(function(resolve, reject) {
- if (_this.readyState !== STATES.connected) {
- _this.on('open', function() {
- _this.db.dropDatabase(function(error) {
- if (error) {
- reject(error);
- } else {
- resolve();
- }
- });
- });
- } else {
- _this.db.dropDatabase(function(error) {
- if (error) {
- reject(error);
- } else {
- resolve();
- }
- });
- }
- });
- if (callback) {
- promise.then(function() { callback(); }, callback);
- }
- return promise;
-};
-
-/**
- * Opens the connection to a replica set.
- *
- * ####Example:
- *
- * var db = mongoose.createConnection();
- * db.openSet("mongodb://user:pwd@localhost:27020,localhost:27021,localhost:27012/mydb");
- *
- * The database name and/or auth need only be included in one URI.
- * The `options` is a hash which is passed to the internal driver connection object.
- *
- * Valid `options`
- *
- * db - passed to the connection db instance
- * server - passed to the connection server instance(s)
- * replset - passed to the connection ReplSetServer instance
- * user - username for authentication
- * pass - password for authentication
- * auth - options for authentication (see http://mongodb.github.com/node-mongodb-native/api-generated/db.html#authenticate)
- * mongos - Boolean - if true, enables High Availability support for mongos
- *
- * _Options passed take precedence over options included in connection strings._
- *
- * ####Notes:
- *
- * _If connecting to multiple mongos servers, set the `mongos` option to true._
- *
- * conn.open('mongodb://mongosA:27501,mongosB:27501', { mongos: true }, cb);
- *
- * Mongoose forces the db option `forceServerObjectId` false and cannot be overridden.
- * Mongoose defaults the server `auto_reconnect` options to true which can be overridden.
- * See the node-mongodb-native driver instance for options that it understands.
- *
- * _Options passed take precedence over options included in connection strings._
- *
- * @param {String} uris MongoDB connection string
- * @param {String} [database] database name if not included in `uris`
- * @param {Object} [options] passed to the internal driver
- * @param {Function} [callback]
- * @see node-mongodb-native https://github.com/mongodb/node-mongodb-native
- * @see http://mongodb.github.com/node-mongodb-native/api-generated/db.html#authenticate
- * @api public
- */
-
-Connection.prototype.openSet = function(uris, database, options, callback) {
- if (!rgxProtocol.test(uris)) {
- uris = 'mongodb://' + uris;
- }
-
- var Promise = PromiseProvider.get();
-
- switch (arguments.length) {
- case 3:
- switch (typeof database) {
- case 'string':
- this.name = database;
- break;
- case 'object':
- callback = options;
- options = database;
- database = null;
- break;
- }
-
- if (typeof options === 'function') {
- callback = options;
- options = {};
- }
- break;
- case 2:
- switch (typeof database) {
- case 'string':
- this.name = database;
- break;
- case 'function':
- callback = database;
- database = null;
- break;
- case 'object':
- options = database;
- database = null;
- break;
- }
- }
-
- if (typeof database === 'string') {
- this.name = database;
- }
-
- var parsed;
- try {
- parsed = muri(uris);
- } catch (err) {
- this.error(err, callback);
- return new Promise.ES6(function(resolve, reject) {
- reject(err);
- });
- }
-
- if (!this.name) {
- this.name = parsed.db;
- }
-
- this.hosts = parsed.hosts;
- this.options = this.parseOptions(options, parsed && parsed.options);
- this.replica = true;
-
- if (!this.name) {
- var err = new Error('No database name provided for replica set');
- this.error(err, callback);
- return new Promise.ES6(function(resolve, reject) {
- reject(err);
- });
- }
-
- // authentication
- if (this.optionsProvideAuthenticationData(options)) {
- this.user = options.user;
- this.pass = options.pass;
- } else if (parsed && parsed.auth) {
- this.user = parsed.auth.user;
- this.pass = parsed.auth.pass;
- } else {
- this.user = this.pass = undefined;
- }
-
- // global configuration options
- if (options && options.config) {
- this.config.autoIndex = options.config.autoIndex !== false;
- }
-
- var _this = this;
- var emitted = false;
- var promise = new Promise.ES6(function(resolve, reject) {
- _this._open(true, function(error) {
- callback && callback(error);
- if (error) {
- reject(error);
- if (!callback && !promise.$hasHandler && !emitted) {
- emitted = true;
- _this.emit('error', error);
- }
- return;
- }
- resolve();
- });
- });
- return promise;
-};
-
-/**
- * error
- *
- * Graceful error handling, passes error to callback
- * if available, else emits error on the connection.
- *
- * @param {Error} err
- * @param {Function} callback optional
- * @api private
- */
-
-Connection.prototype.error = function(err, callback) {
- if (callback) {
- return callback(err);
- }
- this.emit('error', err);
-};
-
-/**
- * Handles opening the connection with the appropriate method based on connection type.
- *
- * @param {Function} callback
- * @api private
- */
-
-Connection.prototype._open = function(emit, callback) {
- this.readyState = STATES.connecting;
- this._closeCalled = false;
-
- var _this = this;
-
- var method = this.replica
- ? 'doOpenSet'
- : 'doOpen';
-
- // open connection
- this[method](function(err) {
- if (err) {
- _this.readyState = STATES.disconnected;
- if (_this._hasOpened) {
- if (callback) {
- callback(err);
- }
- } else {
- _this.error(err, emit && callback);
- }
- return;
- }
-
- _this.onOpen(callback);
- });
-};
-
-/**
- * Called when the connection is opened
- *
- * @api private
- */
-
-Connection.prototype.onOpen = function(callback) {
- var _this = this;
-
- function open(err, isAuth) {
- if (err) {
- _this.readyState = isAuth ? STATES.unauthorized : STATES.disconnected;
- _this.error(err, callback);
- return;
- }
-
- _this.readyState = STATES.connected;
-
- // avoid having the collection subscribe to our event emitter
- // to prevent 0.3 warning
- for (var i in _this.collections) {
- if (utils.object.hasOwnProperty(_this.collections, i)) {
- _this.collections[i].onOpen();
- }
- }
-
- callback && callback();
- _this.emit('open');
- }
-
- // re-authenticate if we're not already connected #3871
- if (this._readyState !== STATES.connected && this.shouldAuthenticate()) {
- _this.db.authenticate(_this.user, _this.pass, _this.options.auth, function(err) {
- open(err, true);
- });
- } else {
- open();
- }
-};
-
-/**
- * Closes the connection
- *
- * @param {Function} [callback] optional
- * @return {Connection} self
- * @api public
- */
-
-Connection.prototype.close = function(callback) {
- var _this = this;
- var Promise = PromiseProvider.get();
- return new Promise.ES6(function(resolve, reject) {
- _this._close(function(error) {
- callback && callback(error);
- if (error) {
- reject(error);
- return;
- }
- resolve();
- });
- });
-};
-
-/**
- * Handles closing the connection
- *
- * @param {Function} callback
- * @api private
- */
-Connection.prototype._close = function(callback) {
- var _this = this;
- this._closeCalled = true;
-
- switch (this.readyState) {
- case 0: // disconnected
- callback && callback();
- break;
-
- case 1: // connected
- case 4: // unauthorized
- this.readyState = STATES.disconnecting;
- this.doClose(function(err) {
- if (err) {
- _this.error(err, callback);
- } else {
- _this.onClose();
- callback && callback();
- }
- });
- break;
-
- case 2: // connecting
- this.once('open', function() {
- _this.close(callback);
- });
- break;
-
- case 3: // disconnecting
- if (!callback) {
- break;
- }
- this.once('close', function() {
- callback();
- });
- break;
- }
-
- return this;
-};
-
-/**
- * Called when the connection closes
- *
- * @api private
- */
-
-Connection.prototype.onClose = function() {
- this.readyState = STATES.disconnected;
-
- // avoid having the collection subscribe to our event emitter
- // to prevent 0.3 warning
- for (var i in this.collections) {
- if (utils.object.hasOwnProperty(this.collections, i)) {
- this.collections[i].onClose();
- }
- }
-
- this.emit('close');
-};
-
-/**
- * Retrieves a collection, creating it if not cached.
- *
- * Not typically needed by applications. Just talk to your collection through your model.
- *
- * @param {String} name of the collection
- * @param {Object} [options] optional collection options
- * @return {Collection} collection instance
- * @api public
- */
-
-Connection.prototype.collection = function(name, options) {
- if (!(name in this.collections)) {
- this.collections[name] = new Collection(name, this, options);
- }
- return this.collections[name];
-};
-
-/**
- * Defines or retrieves a model.
- *
- * var mongoose = require('mongoose');
- * var db = mongoose.createConnection(..);
- * db.model('Venue', new Schema(..));
- * var Ticket = db.model('Ticket', new Schema(..));
- * var Venue = db.model('Venue');
- *
- * _When no `collection` argument is passed, Mongoose produces a collection name by passing the model `name` to the [utils.toCollectionName](#utils_exports.toCollectionName) method. This method pluralizes the name. If you don't like this behavior, either pass a collection name or set your schemas collection name option._
- *
- * ####Example:
- *
- * var schema = new Schema({ name: String }, { collection: 'actor' });
- *
- * // or
- *
- * schema.set('collection', 'actor');
- *
- * // or
- *
- * var collectionName = 'actor'
- * var M = conn.model('Actor', schema, collectionName)
- *
- * @param {String} name the model name
- * @param {Schema} [schema] a schema. necessary when defining a model
- * @param {String} [collection] name of mongodb collection (optional) if not given it will be induced from model name
- * @see Mongoose#model #index_Mongoose-model
- * @return {Model} The compiled model
- * @api public
- */
-
-Connection.prototype.model = function(name, schema, collection) {
- // collection name discovery
- if (typeof schema === 'string') {
- collection = schema;
- schema = false;
- }
-
- if (utils.isObject(schema) && !schema.instanceOfSchema) {
- schema = new Schema(schema);
- }
- if (schema && !schema.instanceOfSchema) {
- throw new Error('The 2nd parameter to `mongoose.model()` should be a ' +
- 'schema or a POJO');
- }
-
- if (this.models[name] && !collection) {
- // model exists but we are not subclassing with custom collection
- if (schema && schema.instanceOfSchema && schema !== this.models[name].schema) {
- throw new MongooseError.OverwriteModelError(name);
- }
- return this.models[name];
- }
-
- var opts = {cache: false, connection: this};
- var model;
-
- if (schema && schema.instanceOfSchema) {
- // compile a model
- model = this.base.model(name, schema, collection, opts);
-
- // only the first model with this name is cached to allow
- // for one-offs with custom collection names etc.
- if (!this.models[name]) {
- this.models[name] = model;
- }
-
- model.init();
- return model;
- }
-
- if (this.models[name] && collection) {
- // subclassing current model with alternate collection
- model = this.models[name];
- schema = model.prototype.schema;
- var sub = model.__subclass(this, schema, collection);
- // do not cache the sub model
- return sub;
- }
-
- // lookup model in mongoose module
- model = this.base.models[name];
-
- if (!model) {
- throw new MongooseError.MissingSchemaError(name);
- }
-
- if (this === model.prototype.db
- && (!collection || collection === model.collection.name)) {
- // model already uses this connection.
-
- // only the first model with this name is cached to allow
- // for one-offs with custom collection names etc.
- if (!this.models[name]) {
- this.models[name] = model;
- }
-
- return model;
- }
- this.models[name] = model.__subclass(this, schema, collection);
- return this.models[name];
-};
-
-/**
- * Returns an array of model names created on this connection.
- * @api public
- * @return {Array}
- */
-
-Connection.prototype.modelNames = function() {
- return Object.keys(this.models);
-};
-
-/**
- * @brief Returns if the connection requires authentication after it is opened. Generally if a
- * username and password are both provided than authentication is needed, but in some cases a
- * password is not required.
- * @api private
- * @return {Boolean} true if the connection should be authenticated after it is opened, otherwise false.
- */
-Connection.prototype.shouldAuthenticate = function() {
- return (this.user !== null && this.user !== void 0) &&
- ((this.pass !== null || this.pass !== void 0) || this.authMechanismDoesNotRequirePassword());
-};
-
-/**
- * @brief Returns a boolean value that specifies if the current authentication mechanism needs a
- * password to authenticate according to the auth objects passed into the open/openSet methods.
- * @api private
- * @return {Boolean} true if the authentication mechanism specified in the options object requires
- * a password, otherwise false.
- */
-Connection.prototype.authMechanismDoesNotRequirePassword = function() {
- if (this.options && this.options.auth) {
- return authMechanismsWhichDontRequirePassword.indexOf(this.options.auth.authMechanism) >= 0;
- }
- return true;
-};
-
-/**
- * @brief Returns a boolean value that specifies if the provided objects object provides enough
- * data to authenticate with. Generally this is true if the username and password are both specified
- * but in some authentication methods, a password is not required for authentication so only a username
- * is required.
- * @param {Object} [options] the options object passed into the open/openSet methods.
- * @api private
- * @return {Boolean} true if the provided options object provides enough data to authenticate with,
- * otherwise false.
- */
-Connection.prototype.optionsProvideAuthenticationData = function(options) {
- return (options) &&
- (options.user) &&
- ((options.pass) || this.authMechanismDoesNotRequirePassword());
-};
-
-/*!
- * Module exports.
- */
-
-Connection.STATES = STATES;
-module.exports = Connection;