Function batchDelete

lib/routes/routeBackbeat.js:1385–1481

(request, response, userInfo, log, callback)

}

function batchDelete(request, response, userInfo, log, callback) {
    return _getRequestPayload(request, (err, payload) => {
        if (err) {
            return callback(err);
        }
        let parsedPayload;
        try {
            parsedPayload = JSON.parse(payload);
        } catch {
            // FIXME: add error type MalformedJSON
            return callback(errors.MalformedPOSTRequest);
        }
        if (!parsedPayload || !Array.isArray(parsedPayload.Locations)) {
            return callback(errors.MalformedPOSTRequest);
        }
        const locations = parsedPayload.Locations;
        if (_shouldConditionallyDelete(request, locations)) {
            return _performConditionalDelete(request, response, locations, log, callback);
        }
        log.trace('batch delete locations', { locations });
        return async.eachLimit(
            locations,
            5,
            (loc, next) => {
                const _loc = Object.assign({}, loc);
                if (_loc.dataStoreVersionId !== undefined) {
                    // required by cloud backends
                    _loc.deleteVersion = true;
                }
                dataWrapper.data.delete(_loc, log, err => {
                    if (err?.is?.ObjNotFound) {
                        log.info('batch delete: data location do not exist', {
                            method: 'batchDelete',
                            location: loc,
                        });
                        return next();
                    }
                    return next(err);
                });
            },
            err => {
                if (err) {
                    log.error('batch delete failed', {
                        method: 'batchDelete',
                        locations,
                        error: err,
                    });
                    return callback(err);
                }
                log.debug('batch delete successful', { locations });

                // Update inflight metrics for the data which has just been freed
                const bucket = request.bucketName;
                const contentLength = locations.reduce((length, loc) => length + loc.size, 0);

                // TODO: `bucket` should probably always be passed, to be confirmed in CLDSRV-643
                // For now be leniant and skip inflight updates if it is not specified, to avoid any
                // impact esp. on CRR