135 lines
4.5 KiB
JavaScript
135 lines
4.5 KiB
JavaScript
'use strict';
|
|
|
|
exports = module.exports = {
|
|
getBoxBackupDetails: getBoxBackupDetails,
|
|
getAppBackupDetails: getAppBackupDetails,
|
|
|
|
getRestoreUrl: getRestoreUrl,
|
|
getAppRestoreConfig: getAppRestoreConfig,
|
|
getLocalFilePath: getLocalFilePath,
|
|
|
|
copyObject: copyObject,
|
|
removeBackup: removeBackup
|
|
};
|
|
|
|
var assert = require('assert'),
|
|
async = require('async'),
|
|
BackupsError = require('../backups.js').BackupsError,
|
|
fs = require('fs'),
|
|
path = require('path'),
|
|
safe = require('safetydance'),
|
|
shell = require('../shell.js');
|
|
|
|
var FALLBACK_BACKUP_FOLDER = '/var/backups';
|
|
var RMBACKUP_CMD = path.join(__dirname, '../scripts/rmbackup.sh');
|
|
|
|
function getBoxBackupDetails(apiConfig, id, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof id, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
|
|
var details = {
|
|
backupScriptArguments: [ 'filesystem', backupFolder, id, apiConfig.key ]
|
|
};
|
|
|
|
callback(null, details);
|
|
}
|
|
|
|
function getAppBackupDetails(apiConfig, appId, dataId, configId, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof appId, 'string');
|
|
assert.strictEqual(typeof dataId, 'string');
|
|
assert.strictEqual(typeof configId, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
|
|
var details = {
|
|
backupScriptArguments: [ 'filesystem', appId, backupFolder, configId, dataId, apiConfig.key ]
|
|
};
|
|
|
|
callback(null, details);
|
|
}
|
|
|
|
function getRestoreUrl(apiConfig, filename, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof filename, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
var restoreUrl = 'file://' + path.join(backupFolder, filename);
|
|
|
|
callback(null, { url: restoreUrl });
|
|
}
|
|
|
|
function getAppRestoreConfig(apiConfig, backupId, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof backupId, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
var configFilename = backupId.replace(/\.tar\.gz$/, '.json');
|
|
|
|
var restoreConfig = safe.require(path.join(backupFolder, configFilename));
|
|
if (!restoreConfig) return callback(new BackupsError(BackupsError.NOT_FOUND, 'No app backup config found for ' + configFilename));
|
|
|
|
callback(null, restoreConfig);
|
|
}
|
|
|
|
function getLocalFilePath(apiConfig, filename, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof filename, 'string');
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
|
|
callback(null, { filePath: path.join(backupFolder, filename) });
|
|
}
|
|
|
|
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');
|
|
|
|
var calledBack = false;
|
|
function done (error) {
|
|
if (!calledBack) callback(error);
|
|
calledBack = true;
|
|
}
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
var readStream = fs.createReadStream(path.join(backupFolder, from));
|
|
var writeStream = fs.createWriteStream(path.join(backupFolder, to));
|
|
|
|
readStream.on('error', done);
|
|
writeStream.on('error', done);
|
|
|
|
writeStream.on('close', function () {
|
|
// avoid passing arguments
|
|
done(null);
|
|
});
|
|
|
|
readStream.pipe(writeStream);
|
|
}
|
|
|
|
function removeBackup(apiConfig, backupId, appBackupIds, callback) {
|
|
assert.strictEqual(typeof apiConfig, 'object');
|
|
assert.strictEqual(typeof backupId, 'string');
|
|
assert(Array.isArray(appBackupIds));
|
|
assert.strictEqual(typeof callback, 'function');
|
|
|
|
var backupFolder = apiConfig.backupFolder || FALLBACK_BACKUP_FOLDER;
|
|
|
|
async.each([backupId].concat(appBackupIds), function (id, callback) {
|
|
var filePath = path.join(backupFolder, id);
|
|
|
|
shell.sudo('deleteBackup', [ RMBACKUP_CMD, filePath ], function (error) {
|
|
if (error) console.error('Unable to remove %s. Not fatal.', filePath, safe.error);
|
|
callback();
|
|
});
|
|
}, callback);
|
|
}
|