Function _createEncryptedBucket

lib/kms/utilities.js:8–65

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

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

function _createEncryptedBucket(host,
                                port,
                                bucketName,
                                accessKey,
                                secretKey,
                                verbose, ssl,
                                locationConstraint) {
    const options = {
        host,
        port,
        method: 'PUT',
        path: `/${bucketName}/`,
        headers: {
            'x-amz-scal-server-side-encryption': 'AES256',
        },
        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();
}