From 81ddf9b700bc48a1f8e472209f080f9c1d9a9b09 Mon Sep 17 00:00:00 2001 From: Piotr Russ Date: Wed, 18 Nov 2020 23:26:45 +0100 Subject: rm node_modules --- node_modules/mongoose/lib/collection.js | 282 -------------------------------- 1 file changed, 282 deletions(-) delete mode 100644 node_modules/mongoose/lib/collection.js (limited to 'node_modules/mongoose/lib/collection.js') diff --git a/node_modules/mongoose/lib/collection.js b/node_modules/mongoose/lib/collection.js deleted file mode 100644 index 1f60a63..0000000 --- a/node_modules/mongoose/lib/collection.js +++ /dev/null @@ -1,282 +0,0 @@ -'use strict'; - -/*! - * Module dependencies. - */ - -const EventEmitter = require('events').EventEmitter; -const STATES = require('./connectionstate'); -const immediate = require('./helpers/immediate'); - -/** - * Abstract Collection constructor - * - * This is the base class that drivers inherit from and implement. - * - * @param {String} name name of the collection - * @param {Connection} conn A MongooseConnection instance - * @param {Object} opts optional collection options - * @api public - */ - -function Collection(name, conn, opts) { - if (opts === void 0) { - opts = {}; - } - if (opts.capped === void 0) { - opts.capped = {}; - } - - if (typeof opts.capped === 'number') { - opts.capped = { size: opts.capped }; - } - - this.opts = opts; - this.name = name; - this.collectionName = name; - this.conn = conn; - this.queue = []; - this.buffer = true; - this.emitter = new EventEmitter(); - - if (STATES.connected === this.conn.readyState) { - this.onOpen(); - } -} - -/** - * The collection name - * - * @api public - * @property name - */ - -Collection.prototype.name; - -/** - * The collection name - * - * @api public - * @property collectionName - */ - -Collection.prototype.collectionName; - -/** - * The Connection instance - * - * @api public - * @property conn - */ - -Collection.prototype.conn; - -/** - * Called when the database connects - * - * @api private - */ - -Collection.prototype.onOpen = function() { - this.buffer = false; - immediate(() => this.doQueue()); -}; - -/** - * Called when the database disconnects - * - * @api private - */ - -Collection.prototype.onClose = function(force) { - if (this._shouldBufferCommands() && !force) { - this.buffer = true; - } -}; - -/** - * Queues a method for later execution when its - * database connection opens. - * - * @param {String} name name of the method to queue - * @param {Array} args arguments to pass to the method when executed - * @api private - */ - -Collection.prototype.addQueue = function(name, args) { - this.queue.push([name, args]); - return this; -}; - -/** - * Executes all queued methods and clears the queue. - * - * @api private - */ - -Collection.prototype.doQueue = function() { - for (const method of this.queue) { - if (typeof method[0] === 'function') { - method[0].apply(this, method[1]); - } else { - this[method[0]].apply(this, method[1]); - } - } - this.queue = []; - const _this = this; - process.nextTick(function() { - _this.emitter.emit('queue'); - }); - return this; -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.ensureIndex = function() { - throw new Error('Collection#ensureIndex unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.createIndex = function() { - throw new Error('Collection#createIndex unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.findAndModify = function() { - throw new Error('Collection#findAndModify unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.findOneAndUpdate = function() { - throw new Error('Collection#findOneAndUpdate unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.findOneAndDelete = function() { - throw new Error('Collection#findOneAndDelete unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.findOneAndReplace = function() { - throw new Error('Collection#findOneAndReplace unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.findOne = function() { - throw new Error('Collection#findOne unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.find = function() { - throw new Error('Collection#find unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.insert = function() { - throw new Error('Collection#insert unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.insertOne = function() { - throw new Error('Collection#insertOne unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.insertMany = function() { - throw new Error('Collection#insertMany unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.save = function() { - throw new Error('Collection#save unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.update = function() { - throw new Error('Collection#update unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.getIndexes = function() { - throw new Error('Collection#getIndexes unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.mapReduce = function() { - throw new Error('Collection#mapReduce unimplemented by driver'); -}; - -/** - * Abstract method that drivers must implement. - */ - -Collection.prototype.watch = function() { - throw new Error('Collection#watch unimplemented by driver'); -}; - -/*! - * ignore - */ - -Collection.prototype._shouldBufferCommands = function _shouldBufferCommands() { - const opts = this.opts; - - if (opts.bufferCommands != null) { - return opts.bufferCommands; - } - if (opts && opts.schemaUserProvidedOptions != null && opts.schemaUserProvidedOptions.bufferCommands != null) { - return opts.schemaUserProvidedOptions.bufferCommands; - } - - return this.conn._shouldBufferCommands(); -}; - -/*! - * Module exports. - */ - -module.exports = Collection; -- cgit v1.2.3