123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313 |
- /* eslint no-empty: 1 */
- /*!
- * Module dependencies.
- */
- var ArrayType = require('./array');
- var CastError = require('../error/cast');
- var MongooseDocumentArray = require('../types/documentarray');
- var SchemaType = require('../schematype');
- var Subdocument = require('../types/embedded');
- var util = require('util');
- /**
- * SubdocsArray SchemaType constructor
- *
- * @param {String} key
- * @param {Schema} schema
- * @param {Object} options
- * @inherits SchemaArray
- * @api public
- */
- function DocumentArray(key, schema, options) {
- // compile an embedded document for this schema
- function EmbeddedDocument() {
- Subdocument.apply(this, arguments);
- }
- EmbeddedDocument.prototype = Object.create(Subdocument.prototype);
- EmbeddedDocument.prototype.$__setSchema(schema);
- EmbeddedDocument.schema = schema;
- // apply methods
- for (var i in schema.methods) {
- EmbeddedDocument.prototype[i] = schema.methods[i];
- }
- // apply statics
- for (i in schema.statics) {
- EmbeddedDocument[i] = schema.statics[i];
- }
- EmbeddedDocument.options = options;
- ArrayType.call(this, key, EmbeddedDocument, options);
- this.schema = schema;
- this.$isMongooseDocumentArray = true;
- var fn = this.defaultValue;
- if (!('defaultValue' in this) || fn !== void 0) {
- this.default(function() {
- var arr = fn.call(this);
- if (!Array.isArray(arr)) {
- arr = [arr];
- }
- // Leave it up to `cast()` to convert this to a documentarray
- return arr;
- });
- }
- }
- /**
- * This schema type's name, to defend against minifiers that mangle
- * function names.
- *
- * @api public
- */
- DocumentArray.schemaName = 'DocumentArray';
- /*!
- * Inherits from ArrayType.
- */
- DocumentArray.prototype = Object.create(ArrayType.prototype);
- DocumentArray.prototype.constructor = DocumentArray;
- /**
- * Performs local validations first, then validations on each embedded doc
- *
- * @api private
- */
- DocumentArray.prototype.doValidate = function(array, fn, scope, options) {
- var _this = this;
- SchemaType.prototype.doValidate.call(this, array, function(err) {
- if (err) {
- return fn(err);
- }
- var count = array && array.length;
- var error;
- if (!count) {
- return fn();
- }
- if (options && options.updateValidator) {
- return fn();
- }
- // handle sparse arrays, do not use array.forEach which does not
- // iterate over sparse elements yet reports array.length including
- // them :(
- function callback(err) {
- if (err) {
- error = err;
- }
- --count || fn(error);
- }
- for (var i = 0, len = count; i < len; ++i) {
- // sidestep sparse entries
- var doc = array[i];
- if (!doc) {
- --count || fn(error);
- continue;
- }
- // If you set the array index directly, the doc might not yet be
- // a full fledged mongoose subdoc, so make it into one.
- if (!(doc instanceof Subdocument)) {
- doc = array[i] = new _this.casterConstructor(doc, array, undefined,
- undefined, i);
- }
- // HACK: use $__original_validate to avoid promises so bluebird doesn't
- // complain
- if (doc.$__original_validate) {
- doc.$__original_validate({__noPromise: true}, callback);
- } else {
- doc.validate({__noPromise: true}, callback);
- }
- }
- }, scope);
- };
- /**
- * Performs local validations first, then validations on each embedded doc.
- *
- * ####Note:
- *
- * This method ignores the asynchronous validators.
- *
- * @return {MongooseError|undefined}
- * @api private
- */
- DocumentArray.prototype.doValidateSync = function(array, scope) {
- var schemaTypeError = SchemaType.prototype.doValidateSync.call(this, array, scope);
- if (schemaTypeError) {
- return schemaTypeError;
- }
- var count = array && array.length,
- resultError = null;
- if (!count) {
- return;
- }
- // handle sparse arrays, do not use array.forEach which does not
- // iterate over sparse elements yet reports array.length including
- // them :(
- for (var i = 0, len = count; i < len; ++i) {
- // only first error
- if (resultError) {
- break;
- }
- // sidestep sparse entries
- var doc = array[i];
- if (!doc) {
- continue;
- }
- var subdocValidateError = doc.validateSync();
- if (subdocValidateError) {
- resultError = subdocValidateError;
- }
- }
- return resultError;
- };
- /**
- * Casts contents
- *
- * @param {Object} value
- * @param {Document} document that triggers the casting
- * @api private
- */
- DocumentArray.prototype.cast = function(value, doc, init, prev, options) {
- var selected,
- subdoc,
- i;
- if (!Array.isArray(value)) {
- // gh-2442 mark whole array as modified if we're initializing a doc from
- // the db and the path isn't an array in the document
- if (!!doc && init) {
- doc.markModified(this.path);
- }
- return this.cast([value], doc, init, prev);
- }
- if (!(value && value.isMongooseDocumentArray) &&
- (!options || !options.skipDocumentArrayCast)) {
- value = new MongooseDocumentArray(value, this.path, doc);
- if (prev && prev._handlers) {
- for (var key in prev._handlers) {
- doc.removeListener(key, prev._handlers[key]);
- }
- }
- } else if (value && value.isMongooseDocumentArray) {
- // We need to create a new array, otherwise change tracking will
- // update the old doc (gh-4449)
- value = new MongooseDocumentArray(value, this.path, doc);
- }
- i = value.length;
- while (i--) {
- if (!value[i]) {
- continue;
- }
- // Check if the document has a different schema (re gh-3701)
- if ((value[i] instanceof Subdocument) &&
- value[i].schema !== this.casterConstructor.schema) {
- value[i] = value[i].toObject({ transform: false, virtuals: false });
- }
- if (!(value[i] instanceof Subdocument) && value[i]) {
- if (init) {
- if (doc) {
- selected || (selected = scopePaths(this, doc.$__.selected, init));
- } else {
- selected = true;
- }
- subdoc = new this.casterConstructor(null, value, true, selected, i);
- value[i] = subdoc.init(value[i]);
- } else {
- try {
- subdoc = prev.id(value[i]._id);
- } catch (e) {
- }
- if (prev && subdoc) {
- // handle resetting doc with existing id but differing data
- // doc.array = [{ doc: 'val' }]
- subdoc.set(value[i]);
- // if set() is hooked it will have no return value
- // see gh-746
- value[i] = subdoc;
- } else {
- try {
- subdoc = new this.casterConstructor(value[i], value, undefined,
- undefined, i);
- // if set() is hooked it will have no return value
- // see gh-746
- value[i] = subdoc;
- } catch (error) {
- var valueInErrorMessage = util.inspect(value[i]);
- throw new CastError('embedded', valueInErrorMessage,
- value._path, error);
- }
- }
- }
- }
- }
- return value;
- };
- /*!
- * Scopes paths selected in a query to this array.
- * Necessary for proper default application of subdocument values.
- *
- * @param {DocumentArray} array - the array to scope `fields` paths
- * @param {Object|undefined} fields - the root fields selected in the query
- * @param {Boolean|undefined} init - if we are being created part of a query result
- */
- function scopePaths(array, fields, init) {
- if (!(init && fields)) {
- return undefined;
- }
- var path = array.path + '.',
- keys = Object.keys(fields),
- i = keys.length,
- selected = {},
- hasKeys,
- key;
- while (i--) {
- key = keys[i];
- if (key.indexOf(path) === 0) {
- hasKeys || (hasKeys = true);
- selected[key.substring(path.length)] = fields[key];
- }
- }
- return hasKeys && selected || undefined;
- }
- /*!
- * Module exports.
- */
- module.exports = DocumentArray;
|