12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286 |
- 'use strict';
- const ChangeStream = require('./cursor/ChangeStream');
- const EventEmitter = require('events').EventEmitter;
- const Schema = require('./schema');
- const Collection = require('./driver').get().Collection;
- const STATES = require('./connectionstate');
- const MongooseError = require('./error/index');
- const PromiseProvider = require('./promise_provider');
- const ServerSelectionError = require('./error/serverSelection');
- const applyPlugins = require('./helpers/schema/applyPlugins');
- const promiseOrCallback = require('./helpers/promiseOrCallback');
- const get = require('./helpers/get');
- const immediate = require('./helpers/immediate');
- const mongodb = require('mongodb');
- const pkg = require('../package.json');
- const utils = require('./utils');
- const parseConnectionString = require('mongodb/lib/core').parseConnectionString;
- let id = 0;
- const noPasswordAuthMechanisms = [
- 'MONGODB-X509'
- ];
- function Connection(base) {
- this.base = base;
- this.collections = {};
- this.models = {};
- this.config = { autoIndex: true };
- this.replica = false;
- this.options = null;
- this.otherDbs = [];
- this.relatedDbs = {};
- this.states = STATES;
- this._readyState = STATES.disconnected;
- this._closeCalled = false;
- this._hasOpened = false;
- this.plugins = [];
- this.id = id++;
- }
- Connection.prototype.__proto__ = EventEmitter.prototype;
- 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;
-
- for (const db of this.otherDbs) {
- db.readyState = val;
- }
-
- for (const k in this.relatedDbs) {
- this.relatedDbs[k].readyState = val;
- }
- if (STATES.connected === val) {
- this._hasOpened = true;
- }
- this.emit(STATES[val]);
- }
- }
- });
- Connection.prototype.get = function(key) {
- return get(this.options, key);
- };
- Connection.prototype.set = function(key, val) {
- this.options = this.options || {};
- this.options[key] = val;
- return val;
- };
- Connection.prototype.collections;
- Connection.prototype.name;
- Connection.prototype.models;
- Connection.prototype.id;
- Object.defineProperty(Connection.prototype, 'plugins', {
- configurable: false,
- enumerable: true,
- writable: true
- });
- Object.defineProperty(Connection.prototype, 'host', {
- configurable: true,
- enumerable: true,
- writable: true
- });
- Object.defineProperty(Connection.prototype, 'port', {
- configurable: true,
- enumerable: true,
- writable: true
- });
- Object.defineProperty(Connection.prototype, 'user', {
- configurable: true,
- enumerable: true,
- writable: true
- });
- Object.defineProperty(Connection.prototype, 'pass', {
- configurable: true,
- enumerable: true,
- writable: true
- });
- Connection.prototype.db;
- Connection.prototype.config;
- Connection.prototype.createCollection = _wrapConnHelper(function createCollection(collection, options, cb) {
- if (typeof options === 'function') {
- cb = options;
- options = {};
- }
- this.db.createCollection(collection, options, cb);
- });
- Connection.prototype.startSession = _wrapConnHelper(function startSession(options, cb) {
- if (typeof options === 'function') {
- cb = options;
- options = null;
- }
- const session = this.client.startSession(options);
- cb(null, session);
- });
- Connection.prototype.dropCollection = _wrapConnHelper(function dropCollection(collection, cb) {
- this.db.dropCollection(collection, cb);
- });
- Connection.prototype.dropDatabase = _wrapConnHelper(function dropDatabase(cb) {
-
-
-
-
- for (const name of Object.keys(this.models)) {
- delete this.models[name].$init;
- }
- this.db.dropDatabase(cb);
- });
- function _wrapConnHelper(fn) {
- return function() {
- const cb = arguments.length > 0 ? arguments[arguments.length - 1] : null;
- const argsWithoutCb = typeof cb === 'function' ?
- Array.prototype.slice.call(arguments, 0, arguments.length - 1) :
- Array.prototype.slice.call(arguments);
- const disconnectedError = new MongooseError('Connection ' + this.id +
- ' was disconnected when calling `' + fn.name + '`');
- return promiseOrCallback(cb, cb => {
-
-
-
- immediate(() => {
- if (this.readyState === STATES.connecting) {
- this.once('open', function() {
- fn.apply(this, argsWithoutCb.concat([cb]));
- });
- } else if (this.readyState === STATES.disconnected && this.db == null) {
- cb(disconnectedError);
- } else {
- fn.apply(this, argsWithoutCb.concat([cb]));
- }
- });
- });
- };
- }
- Connection.prototype.error = function(err, callback) {
- if (callback) {
- callback(err);
- return null;
- }
- if (this.listeners('error').length > 0) {
- this.emit('error', err);
- }
- return Promise.reject(err);
- };
- Connection.prototype.onOpen = function() {
- this.readyState = STATES.connected;
-
-
- for (const i in this.collections) {
- if (utils.object.hasOwnProperty(this.collections, i)) {
- this.collections[i].onOpen();
- }
- }
- this.emit('open');
- };
- Connection.prototype.openUri = function(uri, options, callback) {
- this.readyState = STATES.connecting;
- this._closeCalled = false;
- if (typeof options === 'function') {
- callback = options;
- options = null;
- }
- if (['string', 'number'].indexOf(typeof options) !== -1) {
- throw new MongooseError('Mongoose 5.x no longer supports ' +
- '`mongoose.connect(host, dbname, port)` or ' +
- '`mongoose.createConnection(host, dbname, port)`. See ' +
- 'http://mongoosejs.com/docs/connections.html for supported connection syntax');
- }
- if (typeof uri !== 'string') {
- throw new MongooseError('The `uri` parameter to `openUri()` must be a ' +
- `string, got "${typeof uri}". Make sure the first parameter to ` +
- '`mongoose.connect()` or `mongoose.createConnection()` is a string.');
- }
- if (callback != null && typeof callback !== 'function') {
- throw new MongooseError('3rd parameter to `mongoose.connect()` or ' +
- '`mongoose.createConnection()` must be a function, got "' +
- typeof callback + '"');
- }
- const Promise = PromiseProvider.get();
- const _this = this;
- if (options) {
- options = utils.clone(options);
- const autoIndex = options.config && options.config.autoIndex != null ?
- options.config.autoIndex :
- options.autoIndex;
- if (autoIndex != null) {
- this.config.autoIndex = autoIndex !== false;
- delete options.config;
- delete options.autoIndex;
- }
- if ('autoCreate' in options) {
- this.config.autoCreate = !!options.autoCreate;
- delete options.autoCreate;
- }
- if ('useCreateIndex' in options) {
- this.config.useCreateIndex = !!options.useCreateIndex;
- delete options.useCreateIndex;
- }
- if ('useFindAndModify' in options) {
- this.config.useFindAndModify = !!options.useFindAndModify;
- delete options.useFindAndModify;
- }
-
- if (options.user || options.pass) {
- options.auth = options.auth || {};
- options.auth.user = options.user;
- options.auth.password = options.pass;
- this.user = options.user;
- this.pass = options.pass;
- }
- delete options.user;
- delete options.pass;
- if (options.bufferCommands != null) {
- options.bufferMaxEntries = 0;
- this.config.bufferCommands = options.bufferCommands;
- delete options.bufferCommands;
- }
- if (options.useMongoClient != null) {
- handleUseMongoClient(options);
- }
- } else {
- options = {};
- }
- this._connectionOptions = options;
- const dbName = options.dbName;
- if (dbName != null) {
- this.$dbName = dbName;
- }
- delete options.dbName;
- if (!('promiseLibrary' in options)) {
- options.promiseLibrary = PromiseProvider.get();
- }
- if (!('useNewUrlParser' in options)) {
- if ('useNewUrlParser' in this.base.options) {
- options.useNewUrlParser = this.base.options.useNewUrlParser;
- } else {
- options.useNewUrlParser = false;
- }
- }
- if (!utils.hasUserDefinedProperty(options, 'useUnifiedTopology')) {
- if (utils.hasUserDefinedProperty(this.base.options, 'useUnifiedTopology')) {
- options.useUnifiedTopology = this.base.options.useUnifiedTopology;
- } else {
- options.useUnifiedTopology = false;
- }
- }
- if (!utils.hasUserDefinedProperty(options, 'driverInfo')) {
- options.driverInfo = {
- name: 'Mongoose',
- version: pkg.version
- };
- }
- const parsePromise = new Promise((resolve, reject) => {
- parseConnectionString(uri, options, (err, parsed) => {
- if (err) {
- return reject(err);
- }
- if (dbName) {
- this.name = dbName;
- } else if (parsed.defaultDatabase) {
- this.name = parsed.defaultDatabase;
- } else {
- this.name = get(parsed, 'auth.db', null);
- }
- this.host = get(parsed, 'hosts.0.host', 'localhost');
- this.port = get(parsed, 'hosts.0.port', 27017);
- this.user = this.user || get(parsed, 'auth.username');
- this.pass = this.pass || get(parsed, 'auth.password');
- resolve();
- });
- });
- const _handleReconnect = () => {
-
-
-
-
- if (_this.readyState !== STATES.connected) {
- _this.readyState = STATES.connected;
- _this.emit('reconnect');
- _this.emit('reconnected');
- }
- };
- const promise = new Promise((resolve, reject) => {
- const client = new mongodb.MongoClient(uri, options);
- _this.client = client;
- client.connect(function(error) {
- if (error) {
- _this.readyState = STATES.disconnected;
- return reject(error);
- }
- const db = dbName != null ? client.db(dbName) : client.db();
- _this.db = db;
-
- const type = get(db, 's.topology.s.description.type', '');
- if (options.useUnifiedTopology) {
- if (type === 'Single') {
- const server = Array.from(db.s.topology.s.servers.values())[0];
- server.s.topology.on('serverHeartbeatSucceeded', () => {
- _handleReconnect();
- });
- server.s.pool.on('reconnect', () => {
- _handleReconnect();
- });
- client.on('serverDescriptionChanged', ev => {
- const newDescription = ev.newDescription;
- if (newDescription.type === 'Standalone') {
- _handleReconnect();
- } else {
- _this.readyState = STATES.disconnected;
- }
- });
- } else if (type.startsWith('ReplicaSet')) {
- client.on('topologyDescriptionChanged', ev => {
-
-
- const description = ev.newDescription;
- const servers = Array.from(ev.newDescription.servers.values());
- const allServersDisconnected = description.type === 'ReplicaSetNoPrimary' &&
- servers.reduce((cur, d) => cur || d.type === 'Unknown', false);
- if (_this.readyState === STATES.connected && allServersDisconnected) {
-
- _this.readyState = STATES.disconnected;
- } else if (_this.readyState === STATES.disconnected && !allServersDisconnected) {
- _handleReconnect();
- }
- });
- db.on('close', function() {
- const type = get(db, 's.topology.s.description.type', '');
- if (type !== 'ReplicaSetWithPrimary') {
-
- _this.readyState = STATES.disconnected;
- }
- });
- }
- }
-
- db.on('reconnect', function() {
- _handleReconnect();
- });
- db.s.topology.on('reconnectFailed', function() {
- _this.emit('reconnectFailed');
- });
- if (!options.useUnifiedTopology) {
- db.s.topology.on('left', function(data) {
- _this.emit('left', data);
- });
- }
- db.s.topology.on('joined', function(data) {
- _this.emit('joined', data);
- });
- db.s.topology.on('fullsetup', function(data) {
- _this.emit('fullsetup', data);
- });
- if (get(db, 's.topology.s.coreTopology.s.pool') != null) {
- db.s.topology.s.coreTopology.s.pool.on('attemptReconnect', function() {
- _this.emit('attemptReconnect');
- });
- }
- if (!options.useUnifiedTopology || !type.startsWith('ReplicaSet')) {
- db.on('close', function() {
-
- _this.readyState = STATES.disconnected;
- });
- }
- if (!options.useUnifiedTopology) {
- client.on('left', function() {
- if (_this.readyState === STATES.connected &&
- get(db, 's.topology.s.coreTopology.s.replicaSetState.topologyType') === 'ReplicaSetNoPrimary') {
- _this.readyState = STATES.disconnected;
- }
- });
- }
- db.on('timeout', function() {
- _this.emit('timeout');
- });
- delete _this.then;
- delete _this.catch;
- _this.readyState = STATES.connected;
- for (const i in _this.collections) {
- if (utils.object.hasOwnProperty(_this.collections, i)) {
- _this.collections[i].onOpen();
- }
- }
- resolve(_this);
- _this.emit('open');
- });
- });
- const serverSelectionError = new ServerSelectionError();
- this.$initialConnection = Promise.all([promise, parsePromise]).
- then(res => res[0]).
- catch(err => {
- if (err != null && err.name === 'MongoServerSelectionError') {
- err = serverSelectionError.assimilateError(err);
- }
- if (this.listeners('error').length > 0) {
- process.nextTick(() => this.emit('error', err));
- }
- throw err;
- });
- this.then = function(resolve, reject) {
- return this.$initialConnection.then(resolve, reject);
- };
- this.catch = function(reject) {
- return this.$initialConnection.catch(reject);
- };
- if (callback != null) {
- this.$initialConnection = this.$initialConnection.then(
- () => callback(null, this),
- err => callback(err)
- );
- }
- return this;
- };
- const handleUseMongoClient = function handleUseMongoClient(options) {
- console.warn('WARNING: The `useMongoClient` option is no longer ' +
- 'necessary in mongoose 5.x, please remove it.');
- const stack = new Error().stack;
- console.warn(stack.substr(stack.indexOf('\n') + 1));
- delete options.useMongoClient;
- };
- Connection.prototype.close = function(force, callback) {
- if (typeof force === 'function') {
- callback = force;
- force = false;
- }
- this.$wasForceClosed = !!force;
- return promiseOrCallback(callback, cb => {
- this._close(force, cb);
- });
- };
- Connection.prototype._close = function(force, callback) {
- const _this = this;
- this._closeCalled = true;
- switch (this.readyState) {
- case STATES.disconnected:
- callback();
- break;
- case STATES.connected:
- this.readyState = STATES.disconnecting;
- this.doClose(force, function(err) {
- if (err) {
- return callback(err);
- }
- _this.onClose(force);
- callback(null);
- });
- break;
- case STATES.connecting:
- this.once('open', function() {
- _this.close(callback);
- });
- break;
- case STATES.disconnecting:
- this.once('close', function() {
- callback();
- });
- break;
- }
- return this;
- };
- Connection.prototype.onClose = function(force) {
- this.readyState = STATES.disconnected;
-
-
- for (const i in this.collections) {
- if (utils.object.hasOwnProperty(this.collections, i)) {
- this.collections[i].onClose(force);
- }
- }
- this.emit('close', force);
- };
- Connection.prototype.collection = function(name, options) {
- options = options ? utils.clone(options) : {};
- options.$wasForceClosed = this.$wasForceClosed;
- if (!(name in this.collections)) {
- this.collections[name] = new Collection(name, this, options);
- }
- return this.collections[name];
- };
- Connection.prototype.plugin = function(fn, opts) {
- this.plugins.push([fn, opts]);
- return this;
- };
- Connection.prototype.model = function(name, schema, collection) {
- if (!(this instanceof Connection)) {
- throw new MongooseError('`connection.model()` should not be run with ' +
- '`new`. If you are doing `new db.model(foo)(bar)`, use ' +
- '`db.model(foo)(bar)` instead');
- }
- let fn;
- if (typeof name === 'function') {
- fn = name;
- name = fn.name;
- }
-
- 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) {
-
- if (schema && schema.instanceOfSchema && schema !== this.models[name].schema) {
- throw new MongooseError.OverwriteModelError(name);
- }
- return this.models[name];
- }
- const opts = { cache: false, connection: this };
- let model;
- if (schema && schema.instanceOfSchema) {
- applyPlugins(schema, this.plugins, null, '$connectionPluginsApplied');
-
- model = this.base.model(fn || name, schema, collection, opts);
-
-
- if (!this.models[name]) {
- this.models[name] = model;
- }
-
- model.init(function $modelInitNoop() {});
- return model;
- }
- if (this.models[name] && collection) {
-
- model = this.models[name];
- schema = model.prototype.schema;
- const sub = model.__subclass(this, schema, collection);
-
- return sub;
- }
-
- model = this.base.models[name];
- if (!model) {
- throw new MongooseError.MissingSchemaError(name);
- }
- if (this === model.prototype.db
- && (!collection || collection === model.collection.name)) {
-
-
-
- if (!this.models[name]) {
- this.models[name] = model;
- }
- return model;
- }
- this.models[name] = model.__subclass(this, schema, collection);
- return this.models[name];
- };
- Connection.prototype.deleteModel = function(name) {
- if (typeof name === 'string') {
- const model = this.model(name);
- if (model == null) {
- return this;
- }
- const collectionName = model.collection.name;
- delete this.models[name];
- delete this.collections[collectionName];
- delete this.base.modelSchemas[name];
- } else if (name instanceof RegExp) {
- const pattern = name;
- const names = this.modelNames();
- for (const name of names) {
- if (pattern.test(name)) {
- this.deleteModel(name);
- }
- }
- } else {
- throw new Error('First parameter to `deleteModel()` must be a string ' +
- 'or regexp, got "' + name + '"');
- }
- return this;
- };
- Connection.prototype.watch = function(pipeline, options) {
- const disconnectedError = new MongooseError('Connection ' + this.id +
- ' was disconnected when calling `watch()`');
- const changeStreamThunk = cb => {
- immediate(() => {
- if (this.readyState === STATES.connecting) {
- this.once('open', function() {
- const driverChangeStream = this.db.watch(pipeline, options);
- cb(null, driverChangeStream);
- });
- } else if (this.readyState === STATES.disconnected && this.db == null) {
- cb(disconnectedError);
- } else {
- const driverChangeStream = this.db.watch(pipeline, options);
- cb(null, driverChangeStream);
- }
- });
- };
- const changeStream = new ChangeStream(changeStreamThunk, pipeline, options);
- return changeStream;
- };
- Connection.prototype.modelNames = function() {
- return Object.keys(this.models);
- };
- Connection.prototype.shouldAuthenticate = function() {
- return this.user != null &&
- (this.pass != null || this.authMechanismDoesNotRequirePassword());
- };
- Connection.prototype.authMechanismDoesNotRequirePassword = function() {
- if (this.options && this.options.auth) {
- return noPasswordAuthMechanisms.indexOf(this.options.auth.authMechanism) >= 0;
- }
- return true;
- };
- Connection.prototype.optionsProvideAuthenticationData = function(options) {
- return (options) &&
- (options.user) &&
- ((options.pass) || this.authMechanismDoesNotRequirePassword());
- };
- Connection.STATES = STATES;
- module.exports = Connection;
|