diff options
Diffstat (limited to 'node_modules/mongoose/lib/helpers/aggregate')
-rw-r--r-- | node_modules/mongoose/lib/helpers/aggregate/stringifyAccumulatorOptions.js | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/node_modules/mongoose/lib/helpers/aggregate/stringifyAccumulatorOptions.js b/node_modules/mongoose/lib/helpers/aggregate/stringifyAccumulatorOptions.js new file mode 100644 index 0000000..7362514 --- /dev/null +++ b/node_modules/mongoose/lib/helpers/aggregate/stringifyAccumulatorOptions.js @@ -0,0 +1,38 @@ +'use strict'; + +module.exports = function stringifyAccumulatorOptions(pipeline) { + if (!Array.isArray(pipeline)) { + return; + } + + for (const stage of pipeline) { + if (stage == null) { + continue; + } + + const canHaveAccumulator = stage.$group || stage.$bucket || stage.$bucketAuto; + if (canHaveAccumulator != null) { + for (const key of Object.keys(canHaveAccumulator)) { + handleAccumulator(canHaveAccumulator[key]); + } + } + + if (stage.$facet != null) { + for (const key of Object.keys(stage.$facet)) { + stringifyAccumulatorOptions(stage.$facet[key]); + } + } + } +}; + +function handleAccumulator(operator) { + if (operator == null || operator.$accumulator == null) { + return; + } + + for (const key of ['init', 'accumulate', 'merge', 'finalize']) { + if (typeof operator.$accumulator[key] === 'function') { + operator.$accumulator[key] = String(operator.$accumulator[key]); + } + } +}
\ No newline at end of file |