mirror of https://github.com/therootcompany/s3.js
209 lines
5.7 KiB
JavaScript
209 lines
5.7 KiB
JavaScript
|
'use strict';
|
||
|
|
||
|
var aws4 = require('aws4');
|
||
|
var request = require('@root/request');
|
||
|
var env = process.env;
|
||
|
|
||
|
module.exports = {
|
||
|
// HEAD
|
||
|
head: function({
|
||
|
accessKeyId,
|
||
|
secretAccessKey,
|
||
|
region,
|
||
|
bucket,
|
||
|
prefix,
|
||
|
key
|
||
|
}) {
|
||
|
// TODO support minio
|
||
|
/*
|
||
|
var awsHost = config.awsHost;
|
||
|
if (!awsHost) {
|
||
|
if (awsRegion) {
|
||
|
awsHost = awsHost || 's3.'+awsRegion+'.amazonaws.com';
|
||
|
} else {
|
||
|
// default
|
||
|
awsHost = 's3.amazonaws.com';
|
||
|
}
|
||
|
}
|
||
|
*/
|
||
|
/*
|
||
|
if (env.AWS_ACCESS_KEY) {
|
||
|
accessKeyId = accessKeyId || env.AWS_ACCESS_KEY;
|
||
|
secretAccessKey = secretAccessKey || env.AWS_SECRET_ACCESS_KEY;
|
||
|
bucket = bucket || env.AWS_BUCKET;
|
||
|
prefix = prefix || env.AWS_BUCKET_PREFIX;
|
||
|
region = region || env.AWS_REGION;
|
||
|
endpoint = endpoint || env.AWS_ENDPOINT;
|
||
|
}
|
||
|
*/
|
||
|
prefix = prefix || '';
|
||
|
if (prefix) {
|
||
|
// whatever => whatever/
|
||
|
// whatever/ => whatever/
|
||
|
prefix = prefix.replace(/\/?$/, '/');
|
||
|
}
|
||
|
var signed = aws4.sign(
|
||
|
{
|
||
|
// host: awsHost
|
||
|
service: 's3',
|
||
|
region: region,
|
||
|
path: '/' + bucket + '/' + prefix + key,
|
||
|
method: 'HEAD',
|
||
|
signQuery: true
|
||
|
},
|
||
|
{ accessKeyId: accessKeyId, secretAccessKey: secretAccessKey }
|
||
|
);
|
||
|
var url = 'https://' + signed.hostname + signed.path;
|
||
|
|
||
|
return request({ method: 'HEAD', url }).then(function(resp) {
|
||
|
if (200 === resp.statusCode) {
|
||
|
return resp;
|
||
|
}
|
||
|
var err = new Error(
|
||
|
'expected status 200 but got ' +
|
||
|
resp.statusCode +
|
||
|
'. See err.response for more info.'
|
||
|
);
|
||
|
err.url = url;
|
||
|
err.response = resp;
|
||
|
throw err;
|
||
|
});
|
||
|
},
|
||
|
|
||
|
// GET
|
||
|
get: function({
|
||
|
accessKeyId,
|
||
|
secretAccessKey,
|
||
|
region,
|
||
|
bucket,
|
||
|
prefix,
|
||
|
key,
|
||
|
json
|
||
|
}) {
|
||
|
prefix = prefix || '';
|
||
|
if (prefix) {
|
||
|
prefix = prefix.replace(/\/?$/, '/');
|
||
|
}
|
||
|
var signed = aws4.sign(
|
||
|
{
|
||
|
service: 's3',
|
||
|
region: region,
|
||
|
path: '/' + bucket + '/' + prefix + key,
|
||
|
method: 'GET',
|
||
|
signQuery: true
|
||
|
},
|
||
|
{ accessKeyId: accessKeyId, secretAccessKey: secretAccessKey }
|
||
|
);
|
||
|
var url = 'https://' + signed.hostname + signed.path;
|
||
|
|
||
|
// stay binary by default
|
||
|
var encoding = null;
|
||
|
if (json) {
|
||
|
encoding = undefined;
|
||
|
}
|
||
|
return request({ method: 'GET', url, encoding: null, json: json }).then(
|
||
|
function(resp) {
|
||
|
if (200 === resp.statusCode) {
|
||
|
return resp;
|
||
|
}
|
||
|
var err = new Error(
|
||
|
'expected status 200 but got ' +
|
||
|
resp.statusCode +
|
||
|
'. See err.response for more info.'
|
||
|
);
|
||
|
err.url = url;
|
||
|
err.response = resp;
|
||
|
throw err;
|
||
|
}
|
||
|
);
|
||
|
},
|
||
|
|
||
|
// PUT
|
||
|
set: function({
|
||
|
accessKeyId,
|
||
|
secretAccessKey,
|
||
|
region,
|
||
|
bucket,
|
||
|
prefix,
|
||
|
key,
|
||
|
body,
|
||
|
size
|
||
|
}) {
|
||
|
prefix = prefix || '';
|
||
|
if (prefix) {
|
||
|
prefix = prefix.replace(/\/?$/, '/');
|
||
|
}
|
||
|
var signed = aws4.sign(
|
||
|
{
|
||
|
service: 's3',
|
||
|
region: region,
|
||
|
path: '/' + bucket + '/' + prefix + key,
|
||
|
method: 'PUT',
|
||
|
signQuery: true
|
||
|
},
|
||
|
{ accessKeyId: accessKeyId, secretAccessKey: secretAccessKey }
|
||
|
);
|
||
|
var url = 'https://' + signed.hostname + signed.path;
|
||
|
var headers = {};
|
||
|
if ('undefined' !== typeof size) {
|
||
|
headers['Content-Length'] = size;
|
||
|
}
|
||
|
|
||
|
return request({ method: 'PUT', url, body, headers }).then(function(
|
||
|
resp
|
||
|
) {
|
||
|
if (200 === resp.statusCode) {
|
||
|
return resp;
|
||
|
}
|
||
|
var err = new Error(
|
||
|
'expected status 201 but got ' +
|
||
|
resp.statusCode +
|
||
|
'. See err.response for more info.'
|
||
|
);
|
||
|
err.url = url;
|
||
|
err.response = resp;
|
||
|
throw err;
|
||
|
});
|
||
|
},
|
||
|
|
||
|
// DELETE
|
||
|
del: function({
|
||
|
accessKeyId,
|
||
|
secretAccessKey,
|
||
|
region,
|
||
|
bucket,
|
||
|
prefix,
|
||
|
key
|
||
|
}) {
|
||
|
prefix = prefix || '';
|
||
|
if (prefix) {
|
||
|
prefix = prefix.replace(/\/?$/, '/');
|
||
|
}
|
||
|
var signed = aws4.sign(
|
||
|
{
|
||
|
service: 's3',
|
||
|
region: region,
|
||
|
path: '/' + bucket + '/' + prefix + key,
|
||
|
method: 'DELETE',
|
||
|
signQuery: true
|
||
|
},
|
||
|
{ accessKeyId: accessKeyId, secretAccessKey: secretAccessKey }
|
||
|
);
|
||
|
var url = 'https://' + signed.hostname + signed.path;
|
||
|
|
||
|
return request({ method: 'DELETE', url }).then(function(resp) {
|
||
|
if (204 === resp.statusCode) {
|
||
|
return resp;
|
||
|
}
|
||
|
var err = new Error(
|
||
|
'expected status 204 but got ' +
|
||
|
resp.statusCode +
|
||
|
'. See err.response for more info.'
|
||
|
);
|
||
|
err.url = url;
|
||
|
err.response = resp;
|
||
|
throw err;
|
||
|
});
|
||
|
}
|
||
|
};
|