jjkiers/cloudron-box
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Report backup progress via progress.json

Browse Source
This commit is contained in:
Johannes Zellner
2015-06-02 14:05:08 +02:00
parent 166a30b8f9
commit ef0476ecff
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cloudron.js
+15 -4
View File
@@ -284,21 +284,32 @@ function backup(callback) {
apps.getAll(function (error, allApps) {
if (error) return callback(new CloudronError(CloudronError.INTERNAL_ERROR, error));
var processed = 0;
var step = 100/(allApps.length+1);
progress.set(progress.BACKUP, processed, '');
async.mapSeries(allApps, function iterator(app, iteratorCallback) {
// only backup apps that are installed or pending configure. Rest of them are in some
// state not good for consistent backup
if ((app.installationState === appdb.ISTATE_INSTALLED && app.health === appdb.HEALTH_HEALTHY)
|| app.installationState === appdb.ISTATE_PENDING_CONFIGURE) {
return backupApp(app, iteratorCallback);
if ((app.installationState === appdb.ISTATE_INSTALLED && app.health === appdb.HEALTH_HEALTHY) || app.installationState === appdb.ISTATE_PENDING_CONFIGURE) {
return backupApp(app, function (error, backupId) {
progress.set(progress.BACKUP, step * processed, app.location);
iteratorCallback(error, backupId);
});
}
debugApp(app, 'Skipping backup (istate:%s health%s). Reusing %s', app.installationState, app.health, app.lastBackupId);
progress.set(progress.BACKUP, step * processed, app.location);
return iteratorCallback(null, app.lastBackupId);
}, function appsBackedUp(error, backupIds) {
if (error) return callback(error);
backupBoxWithAppBackupIds(backupIds, callback);
backupBoxWithAppBackupIds(backupIds, function (error) {
progress.set(progress.BACKUP, 100, '');
callback(error);
});
});
});
}