Function objectPut

lib/api/objectPut.js:52–277

* PUT Object in the requested bucket. Steps include: * validating metadata for authorization, bucket and object existence etc. * store object data in datastore upon successful authorization * store object location returned by datastore and * object's (custom) headers in metadata * return the re

(authInfo, request, streamingV4Params, log, callback)

 * @return {undefined}
 */
function objectPut(authInfo, request, streamingV4Params, log, callback) {
    log.debug('processing request', { method: 'objectPut' });

    const putVersionId = request.headers['x-scal-s3-version-id'];
    const isPutVersion = putVersionId || putVersionId === '';

    let versionId;

    if (putVersionId) {
        const decodedVidResult = decodeVID(putVersionId);
        if (decodedVidResult instanceof Error) {
            log.trace('invalid x-scal-s3-version-id header', {
                versionId: putVersionId,
                error: decodedVidResult,
            });
            return process.nextTick(() => callback(decodedVidResult));
        }
        versionId = decodedVidResult;
    }

    const {
        bucketName,
        headers,
        method,
        objectKey,
        parsedContentLength,
        query,
    } = request;
    if (headers['x-amz-storage-class'] &&
        !constants.validStorageClasses.includes(headers['x-amz-storage-class'])) {
        log.trace('invalid storage-class header');
        monitoring.promMetrics('PUT', request.bucketName,
            errorInstances.InvalidStorageClass.code, 'putObject');
        return callback(errors.InvalidStorageClass);
    }
    if (!aclUtils.checkGrantHeaderValidity(headers)) {
        log.trace('invalid acl header');
        monitoring.promMetrics('PUT', request.bucketName, 400,
            'putObject');
        return callback(errors.InvalidArgument);
    }
    const queryContainsVersionId = checkQueryVersionId(query);
    if (queryContainsVersionId instanceof Error) {
        return callback(queryContainsVersionId);
    }

    const keyLengthError = validateObjectKeyLength(objectKey, config.objectKeyByteLimit);
    if (keyLengthError) {
        return callback(keyLengthError);
    }

    const size = request.parsedContentLength;
    if (Number.parseInt(size, 10) > constants.maximumAllowedUploadSize
        && !config.bypassMaxPutObjectSize) {
        log.debug('Upload size exceeds maximum allowed for a single PUT',
            { size });
        return callback(errors.EntityTooLarge);
    }