'use strict'
const commit = require('../operations/commit')
const { DB_OPS: { REPLACE } } = require('../constants')
const { pick, omit, isObject } = require('lodash')
const { JoiRG, validate, checkValidation } = require('../routes/helpers')
const { UPDATE_BODY_SCHEMA } = require('../routes/schemas')
const shallowOptKeys = ['returnNew', 'returnOld', 'silent']
const optionsSchema = JoiRG.object().keys({
returnNew: JoiRG.boolean(),
returnOld: JoiRG.boolean(),
silent: JoiRG.boolean(),
ignoreRevs: JoiRG.boolean()
})
const providerSchemas = [JoiRG.string().collection().required(), UPDATE_BODY_SCHEMA, optionsSchema]
function replaceSingle ({ pathParams, body }, options, deepOpts) {
let shallowOpts
if (!isObject(deepOpts)) {
shallowOpts = pick(options, shallowOptKeys)
deepOpts = omit(options, shallowOptKeys)
} else {
shallowOpts = options
}
return commit(
pathParams.collection,
body,
REPLACE,
shallowOpts,
deepOpts
)
}
function replaceMultiple ({ pathParams, body }, options) {
const shallowOpts = pick(options, shallowOptKeys)
const deepOpts = omit(options, shallowOptKeys)
const nodes = []
body.forEach(node => {
try {
nodes.push(
replaceSingle({ pathParams, body: node }, shallowOpts, deepOpts)
)
} catch (e) {
console.error(e.stack)
nodes.push(e)
}
})
return nodes
}
replaceProvider
Replaces an existing document or documents and updates the tracking index.
Args:
collection- The collection into which to replace the document.data- An object or array of objects containing document contents to be replaced.options- An optional object, containing any combination of the following keys:returnNew- Whether to return the newly updated object. Defaultfalse.returnOld- Whether to return the old object. Defaultfalse.silent- Whether to return anything in the result. Defaultfalse.ignoreRevs- Whether to ignore a revision match before replace. Defaulttrue.Return:
The contents of the result returned by the method is identical to the contents of the response body of the corresponding HTTP API, invoked with identical input, except when the method throws an error. In the latter case, the error message would be identical to the error response of the HTTP call.
Errors:
If
datais a single object, then any error that occurs while executing the method is thrown back to the caller.If, on the other hand,
datais an array of objects, then the method always returns an array of results. For every element of thedataarray which incurs an error, the error object is present at the corresponding index in the result array. For every input element that the method handles successfully, the result array contains an element that is identical to the result that would have been returned had the method been invoked singly for this element, with identical options.Examples: