summaryrefslogtreecommitdiffstats
path: root/node_modules/mongoose/lib/collection.js
diff options
context:
space:
mode:
authorGravatar Piotr Russ <mail@pruss.it> 2020-11-18 23:26:45 +0100
committerGravatar Piotr Russ <mail@pruss.it> 2020-11-18 23:26:45 +0100
commit81ddf9b700bc48a1f8e472209f080f9c1d9a9b09 (patch)
tree8b959d50c5a614cbf9fcb346ed556140374d4b6d /node_modules/mongoose/lib/collection.js
parent1870f3fdf43707a15fda0f609a021f516f45eb63 (diff)
downloadwebsite_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.gz
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.tar.bz2
website_creator-81ddf9b700bc48a1f8e472209f080f9c1d9a9b09.zip
rm node_modules
Diffstat (limited to 'node_modules/mongoose/lib/collection.js')
-rw-r--r--node_modules/mongoose/lib/collection.js282
1 files changed, 0 insertions, 282 deletions
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;