|
|
/*! * Module dependencies. */
var SchemaType = require('../schematype') , ArrayType = require('./array') , MongooseDocumentArray = require('../types/documentarray') , Subdocument = require('../types/embedded') , Document = require('../document');
/** * SubdocsArray SchemaType constructor * * @param {String} key * @param {Schema} schema * @param {Object} options * @inherits SchemaArray * @api private */
function DocumentArray (key, schema, options) {
// compile an embedded document for this schema
function EmbeddedDocument () { Subdocument.apply(this, arguments); }
EmbeddedDocument.prototype.__proto__ = 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 (var i in schema.statics) EmbeddedDocument[i] = schema.statics[i];
EmbeddedDocument.options = options; this.schema = schema;
ArrayType.call(this, key, EmbeddedDocument, options);
this.schema = schema; var path = this.path; var fn = this.defaultValue;
this.default(function(){ var arr = fn.call(this); if (!Array.isArray(arr)) arr = [arr]; return new MongooseDocumentArray(arr, path, this); }); };
/*! * Inherits from ArrayType. */
DocumentArray.prototype.__proto__ = ArrayType.prototype;
/** * Performs local validations first, then validations on each embedded doc * * @api private */
DocumentArray.prototype.doValidate = function (array, fn, scope) { var self = this;
SchemaType.prototype.doValidate.call(this, array, function (err) { if (err) return fn(err);
var count = array && array.length , error;
if (!count) return fn();
// 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) { // sidestep sparse entries
var doc = array[i]; if (!doc) { --count || fn(); continue; }
;(function (i) { doc.validate(function (err) { if (err && !error) { // rewrite the key
err.key = self.key + '.' + i + '.' + err.key; return fn(error = err); } --count || fn(); }); })(i); } }, scope); };
/** * Casts contents * * @param {Object} value * @param {Document} document that triggers the casting * @api private */
DocumentArray.prototype.cast = function (value, doc, init, prev) { var selected , subdoc , i
if (!Array.isArray(value)) { return this.cast([value], doc, init, prev); }
if (!(value instanceof MongooseDocumentArray)) { value = new MongooseDocumentArray(value, this.path, doc); }
i = value.length;
while (i--) { if (!(value[i] instanceof Subdocument) && value[i]) { if (init) { selected || (selected = scopePaths(this, doc.$__.selected, init)); subdoc = new this.casterConstructor(null, value, true, selected); value[i] = subdoc.init(value[i]); } else { if (prev && (subdoc = prev.id(value[i]._id))) { // handle resetting doc with existing id but differing data
// doc.array = [{ doc: 'val' }]
subdoc.set(value[i]); } else { subdoc = new this.casterConstructor(value[i], value); }
// if set() is hooked it will have no return value
// see gh-746
value[i] = subdoc; } } }
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 (0 === key.indexOf(path)) { hasKeys || (hasKeys = true); selected[key.substring(path.length)] = fields[key]; } }
return hasKeys && selected || undefined; }
/*! * Module exports. */
module.exports = DocumentArray;
|