summaryrefslogtreecommitdiffstats
path: root/node_modules/mongoose/lib/plugins/trackTransaction.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/plugins/trackTransaction.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/plugins/trackTransaction.js')
-rw-r--r--node_modules/mongoose/lib/plugins/trackTransaction.js91
1 files changed, 0 insertions, 91 deletions
diff --git a/node_modules/mongoose/lib/plugins/trackTransaction.js b/node_modules/mongoose/lib/plugins/trackTransaction.js
deleted file mode 100644
index 410a596..0000000
--- a/node_modules/mongoose/lib/plugins/trackTransaction.js
+++ /dev/null
@@ -1,91 +0,0 @@
-'use strict';
-
-const arrayAtomicsSymbol = require('../helpers/symbols').arrayAtomicsSymbol;
-const sessionNewDocuments = require('../helpers/symbols').sessionNewDocuments;
-
-module.exports = function trackTransaction(schema) {
- schema.pre('save', function() {
- const session = this.$session();
- if (session == null) {
- return;
- }
- if (session.transaction == null || session[sessionNewDocuments] == null) {
- return;
- }
-
- if (!session[sessionNewDocuments].has(this)) {
- const initialState = {};
- if (this.isNew) {
- initialState.isNew = true;
- }
- if (this.schema.options.versionKey) {
- initialState.versionKey = this.get(this.schema.options.versionKey);
- }
-
- initialState.modifiedPaths = new Set(Object.keys(this.$__.activePaths.states.modify));
- initialState.atomics = _getAtomics(this);
-
- session[sessionNewDocuments].set(this, initialState);
- } else {
- const state = session[sessionNewDocuments].get(this);
-
- for (const path of Object.keys(this.$__.activePaths.states.modify)) {
- state.modifiedPaths.add(path);
- }
- state.atomics = _getAtomics(this, state.atomics);
- }
- });
-};
-
-function _getAtomics(doc, previous) {
- const pathToAtomics = new Map();
- previous = previous || new Map();
-
- const pathsToCheck = Object.keys(doc.$__.activePaths.init).concat(Object.keys(doc.$__.activePaths.modify));
-
- for (const path of pathsToCheck) {
- const val = doc.$__getValue(path);
- if (val != null &&
- val instanceof Array &&
- val.isMongooseDocumentArray &&
- val.length &&
- val[arrayAtomicsSymbol] != null &&
- Object.keys(val[arrayAtomicsSymbol]).length > 0) {
- const existing = previous.get(path) || {};
- pathToAtomics.set(path, mergeAtomics(existing, val[arrayAtomicsSymbol]));
- }
- }
-
- const dirty = doc.$__dirty();
- for (const dirt of dirty) {
- const path = dirt.path;
-
- const val = dirt.value;
- if (val != null && val[arrayAtomicsSymbol] != null && Object.keys(val[arrayAtomicsSymbol]).length > 0) {
- const existing = previous.get(path) || {};
- pathToAtomics.set(path, mergeAtomics(existing, val[arrayAtomicsSymbol]));
- }
- }
-
- return pathToAtomics;
-}
-
-function mergeAtomics(destination, source) {
- destination = destination || {};
-
- if (source.$pullAll != null) {
- destination.$pullAll = (destination.$pullAll || []).concat(source.$pullAll);
- }
- if (source.$push != null) {
- destination.$push = destination.$push || {};
- destination.$push.$each = (destination.$push.$each || []).concat(source.$push.$each);
- }
- if (source.$addToSet != null) {
- destination.$addToSet = (destination.$addToSet || []).concat(source.$addToSet);
- }
- if (source.$set != null) {
- destination.$set = Object.assign(destination.$set || {}, source.$set);
- }
-
- return destination;
-} \ No newline at end of file