| 146 | }, |
| 147 | |
| 148 | delete(appId, collectionName, document, accessList, isMasterKey) { |
| 149 | const deferred = q.defer(); |
| 150 | |
| 151 | try { |
| 152 | const promises = []; |
| 153 | if (document.constructor === Array) { |
| 154 | for (let i = 0; i < document.length; i++) { |
| 155 | promises.push(_delete(appId, collectionName, document[i], accessList, isMasterKey)); |
| 156 | } |
| 157 | q.allSettled(promises).then((res) => { |
| 158 | let status = true; |
| 159 | const success = []; |
| 160 | const error = []; |
| 161 | for (let i = 0; i < res.length; i++) { |
| 162 | if (res[i].status === 'fulfilled') { |
| 163 | success.push(res[i].value); |
| 164 | error.push(null); |
| 165 | } else { |
| 166 | status = false; |
| 167 | error.push(res[i].value); |
| 168 | } |
| 169 | } |
| 170 | if (status === true) { |
| 171 | deferred.resolve(success); |
| 172 | } else { |
| 173 | deferred.resolve(error); |
| 174 | } |
| 175 | }); |
| 176 | } else { |
| 177 | _delete(appId, collectionName, document, accessList, isMasterKey).then((res) => { |
| 178 | deferred.resolve(res); |
| 179 | }, (err) => { |
| 180 | deferred.reject(err); |
| 181 | }); |
| 182 | } |
| 183 | } catch (err) { |
| 184 | winston.log('error', { |
| 185 | error: String(err), |
| 186 | stack: new Error().stack, |
| 187 | }); |
| 188 | deferred.reject(err); |
| 189 | } |
| 190 | return deferred.promise; |
| 191 | }, |
| 192 | createIndex(appId, collectionName, columnName) { |
| 193 | const deferred = q.defer(); |
| 194 | |