Function _createBucketWithNFSEnabled

lib/nfs/utilities.js:7–57

(host, port, bucketName, accessKey,
    secretKey, verbose, ssl, locationConstraint)

const logger = require('../utilities/logger');

function _createBucketWithNFSEnabled(host, port, bucketName, accessKey,
    secretKey, verbose, ssl, locationConstraint) {
    const options = {
        host,
        port,
        method: 'PUT',
        path: `/${bucketName}/`,
        headers: { 'x-scal-nfs-enabled': 'true' },
        rejectUnauthorized: false,
    };
    const transport = ssl ? https : http;
    const request = transport.request(options, response => {
        if (verbose) {
            logger.info('response status code', {
                statusCode: response.statusCode,
            });
            logger.info('response headers', { headers: response.headers });
        }
        const body = [];
        response.setEncoding('utf8');
        response.on('data', chunk => body.push(chunk));
        response.on('end', () => {
            if (response.statusCode >= 200 && response.statusCode < 300) {
                logger.info('Success', {
                    statusCode: response.statusCode,
                    body: verbose ? body.join('') : undefined,
                });
                process.exit(0);
            } else {
                logger.error('request failed with HTTP Status ', {
                    statusCode: response.statusCode,
                    body: body.join(''),
                });
                process.exit(1);
            }
        });
    });

    auth.client.generateV4Headers(request, '', accessKey, secretKey, 's3');
    if (verbose) {
        logger.info('request headers', { headers: request.getHeaders() });
    }
    if (locationConstraint) {
        const createBucketConfiguration = '<CreateBucketConfiguration ' +
        'xmlns="http://s3.amazonaws.com/doc/2006-03-01/">' +
        `<LocationConstraint>${locationConstraint}</LocationConstraint>` +
        '</CreateBucketConfiguration >';
        request.write(createBucketConfiguration);
    }
    request.end();
}

/**
 * This function is used as a binary to send a request to S3 and create a