123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173 |
- 'use strict';
- const handleTimestampOption = require('../schema/handleTimestampOption');
- module.exports = applyTimestampsToChildren;
- /*!
- * ignore
- */
- function applyTimestampsToChildren(now, update, schema) {
- if (update == null) {
- return;
- }
- const keys = Object.keys(update);
- let key;
- let createdAt;
- let updatedAt;
- let timestamps;
- let path;
- const hasDollarKey = keys.length && keys[0].charAt(0) === '$';
- if (hasDollarKey) {
- if (update.$push) {
- for (key in update.$push) {
- const $path = schema.path(key);
- if (update.$push[key] &&
- $path &&
- $path.$isMongooseDocumentArray &&
- $path.schema.options.timestamps) {
- timestamps = $path.schema.options.timestamps;
- createdAt = handleTimestampOption(timestamps, 'createdAt');
- updatedAt = handleTimestampOption(timestamps, 'updatedAt');
- if (update.$push[key].$each) {
- update.$push[key].$each.forEach(function(subdoc) {
- if (updatedAt != null) {
- subdoc[updatedAt] = now;
- }
- if (createdAt != null) {
- subdoc[createdAt] = now;
- }
- });
- } else {
- if (updatedAt != null) {
- update.$push[key][updatedAt] = now;
- }
- if (createdAt != null) {
- update.$push[key][createdAt] = now;
- }
- }
- }
- }
- }
- if (update.$set != null) {
- const keys = Object.keys(update.$set);
- for (key of keys) {
- // Replace positional operator `$` and array filters `$[]` and `$[.*]`
- const keyToSearch = key.
- replace(/\.\$(\[[^\]]*\])?\./g, '.0.').
- replace(/\.(\[[^\]]*\])?\$$/, '.0');
- path = schema.path(keyToSearch);
- if (!path) {
- continue;
- }
- if (Array.isArray(update.$set[key]) && path.$isMongooseDocumentArray) {
- applyTimestampsToDocumentArray(update.$set[key], path, now);
- } else if (update.$set[key] && path.$isSingleNested) {
- applyTimestampsToSingleNested(update.$set[key], path, now);
- } else if (path.$parentSchema !== schema && path.$parentSchema != null) {
- const parentPath = path.$parentSchema.$schemaType;
- if (parentPath == null) {
- continue;
- }
- timestamps = parentPath.schema.options.timestamps;
- createdAt = handleTimestampOption(timestamps, 'createdAt');
- updatedAt = handleTimestampOption(timestamps, 'updatedAt');
- if (updatedAt == null) {
- continue;
- }
- if (parentPath.$isSingleNested) {
- // Single nested is easy
- update.$set[parentPath.path + '.' + updatedAt] = now;
- continue;
- }
- let childPath = key.substr(parentPath.path.length + 1);
- const firstDot = childPath.indexOf('.');
- // Shouldn't happen, but if it does ignore this path
- if (firstDot === -1) {
- continue;
- }
- childPath = childPath.substr(0, firstDot);
- update.$set[parentPath.path + '.' + childPath + '.' + updatedAt] = now;
- } else if (path.schema != null && path.schema != schema) {
- timestamps = path.schema.options.timestamps;
- createdAt = handleTimestampOption(timestamps, 'createdAt');
- updatedAt = handleTimestampOption(timestamps, 'updatedAt');
- if (updatedAt != null) {
- update.$set[key][updatedAt] = now;
- }
- if (createdAt != null) {
- update.$set[key][createdAt] = now;
- }
- }
- }
- }
- } else {
- const keys = Object.keys(update).filter(key => !key.startsWith('$'));
- for (key of keys) {
- // Replace positional operator `$` and array filters `$[]` and `$[.*]`
- const keyToSearch = key.
- replace(/\.\$(\[[^\]]*\])?\./g, '.0.').
- replace(/\.(\[[^\]]*\])?\$$/, '.0');
- path = schema.path(keyToSearch);
- if (!path) {
- continue;
- }
- if (Array.isArray(update[key]) && path.$isMongooseDocumentArray) {
- applyTimestampsToDocumentArray(update[key], path, now);
- } else if (update[key] != null && path.$isSingleNested) {
- applyTimestampsToSingleNested(update[key], path, now);
- }
- }
- }
- }
- function applyTimestampsToDocumentArray(arr, schematype, now) {
- const timestamps = schematype.schema.options.timestamps;
- if (!timestamps) {
- return;
- }
- const len = arr.length;
- const createdAt = handleTimestampOption(timestamps, 'createdAt');
- const updatedAt = handleTimestampOption(timestamps, 'updatedAt');
- for (let i = 0; i < len; ++i) {
- if (updatedAt != null) {
- arr[i][updatedAt] = now;
- }
- if (createdAt != null) {
- arr[i][createdAt] = now;
- }
- }
- }
- function applyTimestampsToSingleNested(subdoc, schematype, now) {
- const timestamps = schematype.schema.options.timestamps;
- if (!timestamps) {
- return;
- }
- const createdAt = handleTimestampOption(timestamps, 'createdAt');
- const updatedAt = handleTimestampOption(timestamps, 'updatedAt');
- if (updatedAt != null) {
- subdoc[updatedAt] = now;
- }
- if (createdAt != null) {
- subdoc[createdAt] = now;
- }
- }
|