129 lines
3.9 KiB
JavaScript
129 lines
3.9 KiB
JavaScript
'use strict';
|
|
|
|
exports = module.exports = {
|
|
getSignedUploadUrl: getSignedUploadUrl,
|
|
getRestoreUrl: getRestoreUrl,
|
|
|
|
copyObject: copyObject,
|
|
getAllPaged: getAllPaged
|
|
};
|
|
|
|
var assert = require('assert'),
|
|
AWS = require('aws-sdk');
|
|
|
|
function getBackupCredentials(apiConfig, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
assert(apiConfig.accessKeyId && apiConfig.secretAccessKey);
|
|
|
|
var credentials = {
|
|
accessKeyId: apiConfig.accessKeyId,
|
|
secretAccessKey: apiConfig.secretAccessKey,
|
|
region: apiConfig.region || 'us-east-1'
|
|
};
|
|
|
|
if (apiConfig.endpoint) credentials.endpoint = new AWS.Endpoint(apiConfig.endpoint);
|
|
|
|
callback(null, credentials);
|
|
}
|
|
|
|
function getAllPaged(apiConfig, page, perPage, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof page, 'number');
|
|
assert.strictEqual(typeof perPage, 'number');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
getBackupCredentials(apiConfig, function (error, credentials) {
|
|
if (error) return callback(error);
|
|
|
|
var s3 = new AWS.S3(credentials);
|
|
|
|
var params = {
|
|
Bucket: apiConfig.bucket,
|
|
EncodingType: 'url',
|
|
Prefix: apiConfig.prefix + '/backup_'
|
|
};
|
|
|
|
s3.listObjects(params, function (error, data) {
|
|
if (error) return callback(error);
|
|
|
|
var results = data.Contents.map(function (backup) {
|
|
return {
|
|
creationTime: backup.LastModified,
|
|
restoreKey: backup.Key.slice(apiConfig.prefix.length + 1),
|
|
dependsOn: [] // FIXME empty dependsOn is wrong and version property is missing!!
|
|
};
|
|
});
|
|
|
|
results.sort(function (a, b) { return a.creationTime < b.creationTime; });
|
|
|
|
return callback(null, results);
|
|
});
|
|
});
|
|
}
|
|
|
|
function getSignedUploadUrl(apiConfig, filename, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof filename, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
getBackupCredentials(apiConfig, function (error, credentials) {
|
|
if (error) return callback(error);
|
|
|
|
var s3 = new AWS.S3(credentials);
|
|
|
|
var params = {
|
|
Bucket: apiConfig.bucket,
|
|
Key: apiConfig.prefix + '/' + filename,
|
|
Expires: 60 * 30 /* 30 minutes */
|
|
};
|
|
|
|
var url = s3.getSignedUrl('putObject', params);
|
|
|
|
callback(null, { url : url });
|
|
});
|
|
}
|
|
|
|
function getRestoreUrl(apiConfig, filename, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof filename, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
getBackupCredentials(apiConfig, function (error, credentials) {
|
|
if (error) return callback(error);
|
|
|
|
var s3 = new AWS.S3(credentials);
|
|
|
|
var params = {
|
|
Bucket: apiConfig.bucket,
|
|
Key: apiConfig.prefix + '/' + filename,
|
|
Expires: 60 * 30 /* 30 minutes */
|
|
};
|
|
|
|
var url = s3.getSignedUrl('getObject', params);
|
|
|
|
callback(null, { url: url });
|
|
});
|
|
}
|
|
|
|
function copyObject(apiConfig, from, to, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof from, 'string');
|
|
assert.strictEqual(typeof to, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
getBackupCredentials(apiConfig, function (error, credentials) {
|
|
if (error) return callback(error);
|
|
|
|
var params = {
|
|
Bucket: apiConfig.bucket, // target bucket
|
|
Key: apiConfig.prefix + '/' + to, // target file
|
|
CopySource: apiConfig.bucket + '/' + apiConfig.prefix + '/' + from, // source
|
|
};
|
|
|
|
var s3 = new AWS.S3(credentials);
|
|
s3.copyObject(params, callback);
|
|
});
|
|
}
|