Function putObjectTagging

lib/routes/routeBackbeat.js:1232–1258

(request, response, log, callback)

}

function putObjectTagging(request, response, log, callback) {
    const err = _checkMultipleBackendRequest(request, log);
    if (err) {
        return callback(err);
    }
    const sourceVersionId = request.headers['x-scal-source-version-id'];
    const sourceBucket = request.headers['x-scal-source-bucket'];
    const site = request.headers['x-scal-replication-endpoint-site'];
    let dataStoreVersionId = request.headers['x-scal-data-store-version-id'];
    // If the tagging request is made before the replication has completed, the
    // Kafka entry will not have the dataStoreVersionId available so we
    // retrieve it from metadata here.
    if (dataStoreVersionId === '') {
        return metadataGetObject(sourceBucket, request.objectKey, sourceVersionId, null, log, (err, objMD) => {
            if (err) {
                return callback(err);
            }
            if (!objMD) {
                return callback(errors.NoSuchKey);
            }
            const backend = objMD.replicationInfo.backends.find(o => o.site === site);
            dataStoreVersionId = backend.dataStoreVersionId;
            return handleTaggingOperation(request, response, 'Put', dataStoreVersionId, log, callback);
        });
    }
    return handleTaggingOperation(request, response, 'Put', dataStoreVersionId, log, callback);
}

function deleteObjectTagging(request, response, log, callback) {
    const err = _checkMultipleBackendRequest(request, log);