Function _save

services/cloudObjects.js:213–270

(appId, collectionName, document, accessList, isMasterKey, reqType, opts, encryption_key)

async function _save(appId, collectionName, document, accessList, isMasterKey, reqType, opts, encryption_key) {
  const deferred = q.defer();
  try {
    const docToSave = document;

    const promises = [];
    // To keep track of documents whether the document is save or update, this keeps track by id document with value
    // as "save" or "update"
    let unModDoc = [];
    /* reqType keeps track of the collections which are for save and which are for update.
         * It stores the id of collections for save in save array and update in update array */
    if (!reqType) {
      reqType = {
        save: [],
        update: [],
      };

      document = _generateId(document, reqType);
    }
    const parentId = document._id;

    document = _getModifiedDocs(document, unModDoc);
    if (document && Object.keys(document).length > 0) {
      let listOfDocs = await customHelper.checkWriteAclAndUpdateVersion(appId, document, accessList, isMasterKey);
      let obj = _seperateDocs(listOfDocs);
      listOfDocs = obj.newDoc;
      obj = obj.oldDoc;
      const newListOfDocs = await _validateSchema(appId, listOfDocs, accessList, isMasterKey, encryption_key)
      const mongoDocs = newListOfDocs.map(doc => Object.assign({}, doc));

      promises.push(mongoService.document.save(appId, mongoDocs));
      q.allSettled(promises).then((array) => {
        if (array[0].state === 'fulfilled') {
          _sendNotification(appId, array[0], reqType);
          unModDoc = _merge(parentId, array[0].value, unModDoc);
          deferred.resolve(unModDoc);
        } else {
          _rollBack(appId, array, listOfDocs, obj).then((res) => {
            winston.log('error', res);
            deferred.reject('Unable to Save the document at this time');
          }, (err) => {
            winston.log('error', err);
            deferred.reject(err);
          });
        }
      });
    } else {
      deferred.resolve(docToSave);
    }
  } catch (err) {
    winston.log('error', {
      error: String(err),
      stack: new Error().stack,
    });
    deferred.reject(err);
  }
  return deferred.promise;
}