Function putMetadata

lib/routes/routeBackbeat.js:521–876

(request, response, bucketInfo, objMd, log, callback)

}

function putMetadata(request, response, bucketInfo, objMd, log, callback) {
    return _getRequestPayload(request, (err, payload) => {
        if (err) {
            return callback(err);
        }

        let omVal;

        try {
            omVal = JSON.parse(payload);
        } catch {
            return callback(errors.MalformedPOSTRequest);
        }

        const { headers, bucketName, objectKey } = request;

        // Destination-side delete-marker replication.
        // We need the REPLICA status to distinguish from
        // source-side replication status updates that also carry isDeleteMarker=true.
        if (
            omVal.isDeleteMarker &&
            omVal.replicationInfo &&
            omVal.replicationInfo.status === 'REPLICA' &&
            request.serverAccessLog
        ) {
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.replication = true;
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.deleteMarker = true;
        }

        // Destination-side tag-only replication.
        // AWS uses REST.PUT.OBJECT_TAGGING for both - a tag-delete
        // is replicated as a PUT of an empty tag set with the same
        // URI shape.
        // The REPLICA status excludes source-side replication-status updates.
        if (
            omVal.replicationInfo &&
            omVal.replicationInfo.status === 'REPLICA' &&
            (omVal.originOp === 's3:ObjectTagging:Put' || omVal.originOp === 's3:ObjectTagging:Delete') &&
            request.serverAccessLog
        ) {
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.replication = true;
            // eslint-disable-next-line no-param-reassign
            request.serverAccessLog.tagging = true;
        }

        // Destination-side ACL-only replication.
        // AWS uses REST.PUT.ACL on the destination with URI
        // PUT /<bucket>/<key>?acl&versionId=<srcVersionId> and
        // populates the aclRequired field.
        // The REPLICA status excludes source-side replication-status updates.
        if (
            omVal.replicationInfo &&
            omVal.replicationInfo.status === 'REPLICA' &&
            omVal.originOp === 's3:ObjectAcl:Put' &&
            request.serverAccessLog