(appId, document, res)
| 987 | } |
| 988 | |
| 989 | function _deleteRollback(appId, document, res) { |
| 990 | const deferred = q.defer(); |
| 991 | |
| 992 | try { |
| 993 | const promises = []; |
| 994 | _getSchema(appId, document._tableName).then((schema) => { |
| 995 | const docToSave = {}; |
| 996 | docToSave.document = document; |
| 997 | docToSave.schema = schema; |
| 998 | document = []; |
| 999 | document.push(docToSave); |
| 1000 | |
| 1001 | if (res[0].state === 'fulfilled') { |
| 1002 | promises.push(mongoService.document.save(appId, document)); |
| 1003 | } |
| 1004 | if (promises.length > 0) { |
| 1005 | q.all(promises).then(() => { |
| 1006 | deferred.resolve('Success'); |
| 1007 | }, (err) => { |
| 1008 | deferred.reject(err); |
| 1009 | }); |
| 1010 | } |
| 1011 | }, () => { |
| 1012 | deferred.reject(); |
| 1013 | }); |
| 1014 | } catch (err) { |
| 1015 | winston.log('error', { |
| 1016 | error: String(err), |
| 1017 | stack: new Error().stack, |
| 1018 | }); |
| 1019 | deferred.reject(err); |
| 1020 | } |
| 1021 | return deferred.promise; |
| 1022 | } |
| 1023 | |
| 1024 | function _merge(collectionId, listOfDocs, unModDoc) { |
| 1025 | try { |
no test coverage detected