deno.land / x / mongoose@6.7.5 / lib / drivers / node-mongodb-native / collection.js
نووسراو ببینە
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420'use strict';
/*! * Module dependencies. */
const MongooseCollection = require('../../collection');const MongooseError = require('../../error/mongooseError');const Collection = require('mongodb').Collection;const ObjectId = require('./objectid');const getConstructorName = require('../../helpers/getConstructorName');const stream = require('stream');const util = require('util');
/** * A [node-mongodb-native](https://github.com/mongodb/node-mongodb-native) collection implementation. * * All methods methods from the [node-mongodb-native](https://github.com/mongodb/node-mongodb-native) driver are copied and wrapped in queue management. * * @inherits Collection * @api private */
function NativeCollection(name, conn, options) { this.collection = null; this.Promise = options.Promise || Promise; this.modelName = options.modelName; delete options.modelName; this._closed = false; MongooseCollection.apply(this, arguments);}
/*! * Inherit from abstract Collection. */
Object.setPrototypeOf(NativeCollection.prototype, MongooseCollection.prototype);
/** * Called when the connection opens. * * @api private */
NativeCollection.prototype.onOpen = function() { const _this = this;
_this.collection = _this.conn.db.collection(_this.name); MongooseCollection.prototype.onOpen.call(_this); return _this.collection;};
/** * Called when the connection closes * * @api private */
NativeCollection.prototype.onClose = function(force) { MongooseCollection.prototype.onClose.call(this, force);};
/*! * ignore */
const syncCollectionMethods = { watch: true, find: true, aggregate: true };
/** * Copy the collection methods and make them subject to queues * @param {Number|String} I * @api private */
function iter(i) { NativeCollection.prototype[i] = function() { const collection = this.collection; const args = Array.from(arguments); const _this = this; const debug = _this && _this.conn && _this.conn.base && _this.conn.base.options && _this.conn.base.options.debug; const lastArg = arguments[arguments.length - 1]; const opId = new ObjectId();
// If user force closed, queueing will hang forever. See #5664 if (this.conn.$wasForceClosed) { const error = new MongooseError('Connection was force closed'); if (args.length > 0 && typeof args[args.length - 1] === 'function') { args[args.length - 1](error); return; } else { throw error; } }
let _args = args; let callback = null; if (this._shouldBufferCommands() && this.buffer) { if (syncCollectionMethods[i] && typeof lastArg !== 'function') { throw new Error('Collection method ' + i + ' is synchronous'); }
this.conn.emit('buffer', { _id: opId, modelName: _this.modelName, collectionName: _this.name, method: i, args: args });
let callback; let _args = args; let promise = null; let timeout = null; if (syncCollectionMethods[i]) { this.addQueue(() => { lastArg.call(this, null, this[i].apply(this, _args.slice(0, _args.length - 1))); }, []); } else if (typeof lastArg === 'function') { callback = function collectionOperationCallback() { if (timeout != null) { clearTimeout(timeout); } return lastArg.apply(this, arguments); }; _args = args.slice(0, args.length - 1).concat([callback]); } else { promise = new this.Promise((resolve, reject) => { callback = function collectionOperationCallback(err, res) { if (timeout != null) { clearTimeout(timeout); } if (err != null) { return reject(err); } resolve(res); }; _args = args.concat([callback]); this.addQueue(i, _args); }); }
const bufferTimeoutMS = this._getBufferTimeoutMS(); timeout = setTimeout(() => { const removed = this.removeQueue(i, _args); if (removed) { const message = 'Operation `' + this.name + '.' + i + '()` buffering timed out after ' + bufferTimeoutMS + 'ms'; const err = new MongooseError(message); this.conn.emit('buffer-end', { _id: opId, modelName: _this.modelName, collectionName: _this.name, method: i, error: err }); callback(err); } }, bufferTimeoutMS);
if (!syncCollectionMethods[i] && typeof lastArg === 'function') { this.addQueue(i, _args); return; }
return promise; } else if (!syncCollectionMethods[i] && typeof lastArg === 'function') { callback = function collectionOperationCallback(err, res) { if (err != null) { _this.conn.emit('operation-end', { _id: opId, modelName: _this.modelName, collectionName: _this.name, method: i, error: err }); } else { _this.conn.emit('operation-end', { _id: opId, modelName: _this.modelName, collectionName: _this.name, method: i, result: res }); } return lastArg.apply(this, arguments); }; _args = args.slice(0, args.length - 1).concat([callback]); }
if (debug) { if (typeof debug === 'function') { debug.apply(_this, [_this.name, i].concat(args.slice(0, args.length - 1))); } else if (debug instanceof stream.Writable) { this.$printToStream(_this.name, i, args, debug); } else { const color = debug.color == null ? true : debug.color; const shell = debug.shell == null ? false : debug.shell; this.$print(_this.name, i, args, color, shell); } }
this.conn.emit('operation-start', { _id: opId, modelName: _this.modelName, collectionName: this.name, method: i, params: _args });
try { if (collection == null) { const message = 'Cannot call `' + this.name + '.' + i + '()` before initial connection ' + 'is complete if `bufferCommands = false`. Make sure you `await mongoose.connect()` if ' + 'you have `bufferCommands = false`.'; throw new MongooseError(message); }
if (syncCollectionMethods[i] && typeof lastArg === 'function') { return lastArg.call(this, null, collection[i].apply(collection, _args.slice(0, _args.length - 1))); }
const ret = collection[i].apply(collection, _args); if (ret != null && typeof ret.then === 'function') { return ret.then( res => { this.conn.emit('operation-end', { _id: opId, modelName: this.modelName, collectionName: this.name, method: i, result: res }); return res; }, err => { this.conn.emit('operation-end', { _id: opId, modelName: this.modelName, collectionName: this.name, method: i, error: err }); throw err; } ); } return ret; } catch (error) { // Collection operation may throw because of max bson size, catch it here // See gh-3906 if (typeof lastArg === 'function') { return lastArg(error); } else { this.conn.emit('operation-end', { _id: opId, modelName: _this.modelName, collectionName: this.name, method: i, error: error });
throw error; } } };}
for (const key of Object.getOwnPropertyNames(Collection.prototype)) { // Janky hack to work around gh-3005 until we can get rid of the mongoose // collection abstraction const descriptor = Object.getOwnPropertyDescriptor(Collection.prototype, key); // Skip properties with getters because they may throw errors (gh-8528) if (descriptor.get !== undefined) { continue; } if (typeof Collection.prototype[key] !== 'function') { continue; }
iter(key);}
/** * Debug print helper * * @api public * @method $print */
NativeCollection.prototype.$print = function(name, i, args, color, shell) { const moduleName = color ? '\x1B[0;36mMongoose:\x1B[0m ' : 'Mongoose: '; const functionCall = [name, i].join('.'); const _args = []; for (let j = args.length - 1; j >= 0; --j) { if (this.$format(args[j]) || _args.length) { _args.unshift(this.$format(args[j], color, shell)); } } const params = '(' + _args.join(', ') + ')';
console.info(moduleName + functionCall + params);};
/** * Debug print helper * * @api public * @method $print */
NativeCollection.prototype.$printToStream = function(name, i, args, stream) { const functionCall = [name, i].join('.'); const _args = []; for (let j = args.length - 1; j >= 0; --j) { if (this.$format(args[j]) || _args.length) { _args.unshift(this.$format(args[j])); } } const params = '(' + _args.join(', ') + ')';
stream.write(functionCall + params, 'utf8');};
/** * Formatter for debug print args * * @api public * @method $format */
NativeCollection.prototype.$format = function(arg, color, shell) { const type = typeof arg; if (type === 'function' || type === 'undefined') return ''; return format(arg, false, color, shell);};
/** * Debug print helper * @param {Any} representation * @api private */
function inspectable(representation) { const ret = { inspect: function() { return representation; } }; if (util.inspect.custom) { ret[util.inspect.custom] = ret.inspect; } return ret;}function map(o) { return format(o, true);}function formatObjectId(x, key) { x[key] = inspectable('ObjectId("' + x[key].toHexString() + '")');}function formatDate(x, key, shell) { if (shell) { x[key] = inspectable('ISODate("' + x[key].toUTCString() + '")'); } else { x[key] = inspectable('new Date("' + x[key].toUTCString() + '")'); }}function format(obj, sub, color, shell) { if (obj && typeof obj.toBSON === 'function') { obj = obj.toBSON(); } if (obj == null) { return obj; }
const clone = require('../../helpers/clone'); let x = clone(obj, { transform: false }); const constructorName = getConstructorName(x);
if (constructorName === 'Binary') { x = 'BinData(' + x.sub_type + ', "' + x.toString('base64') + '")'; } else if (constructorName === 'ObjectID') { x = inspectable('ObjectId("' + x.toHexString() + '")'); } else if (constructorName === 'Date') { x = inspectable('new Date("' + x.toUTCString() + '")'); } else if (constructorName === 'Object') { const keys = Object.keys(x); const numKeys = keys.length; let key; for (let i = 0; i < numKeys; ++i) { key = keys[i]; if (x[key]) { let error; if (typeof x[key].toBSON === 'function') { try { // `session.toBSON()` throws an error. This means we throw errors // in debug mode when using transactions, see gh-6712. As a // workaround, catch `toBSON()` errors, try to serialize without // `toBSON()`, and rethrow if serialization still fails. x[key] = x[key].toBSON(); } catch (_error) { error = _error; } } const _constructorName = getConstructorName(x[key]); if (_constructorName === 'Binary') { x[key] = 'BinData(' + x[key].sub_type + ', "' + x[key].buffer.toString('base64') + '")'; } else if (_constructorName === 'Object') { x[key] = format(x[key], true); } else if (_constructorName === 'ObjectID') { formatObjectId(x, key); } else if (_constructorName === 'Date') { formatDate(x, key, shell); } else if (_constructorName === 'ClientSession') { x[key] = inspectable('ClientSession("' + ( x[key] && x[key].id && x[key].id.id && x[key].id.id.buffer || '' ).toString('hex') + '")'); } else if (Array.isArray(x[key])) { x[key] = x[key].map(map); } else if (error != null) { // If there was an error with `toBSON()` and the object wasn't // already converted to a string representation, rethrow it. // Open to better ideas on how to handle this. throw error; } } } } if (sub) { return x; }
return util. inspect(x, false, 10, color). replace(/\n/g, ''). replace(/\s{2,}/g, ' ');}
/** * Retrieves information about this collections indexes. * * @param {Function} callback * @method getIndexes * @api public */
NativeCollection.prototype.getIndexes = NativeCollection.prototype.indexInformation;
/*! * Module exports. */
module.exports = NativeCollection;
mongoose
Version Info
a year ago
