import { ajax } from "discourse/lib/ajax"; import showModal from "discourse/lib/show-modal"; import BackupStatus from "admin/models/backup-status"; import Backup from "admin/models/backup"; import PreloadStore from "preload-store"; const LOG_CHANNEL = "/admin/backups/logs"; export default Discourse.Route.extend({ activate() { this.messageBus.subscribe(LOG_CHANNEL, log => { if (log.message === "[STARTED]") { Discourse.User.currentProp("hideReadOnlyAlert", true); this.controllerFor("adminBackups").set( "model.isOperationRunning", true ); this.controllerFor("adminBackupsLogs") .get("logs") .clear(); } else if (log.message === "[FAILED]") { this.controllerFor("adminBackups").set( "model.isOperationRunning", false ); bootbox.alert( I18n.t("admin.backups.operations.failed", { operation: log.operation }) ); } else if (log.message === "[SUCCESS]") { Discourse.User.currentProp("hideReadOnlyAlert", false); this.controllerFor("adminBackups").set( "model.isOperationRunning", false ); if (log.operation === "restore") { // redirect to homepage when the restore is done (session might be lost) window.location.pathname = Discourse.getURL("/"); } } else { this.controllerFor("adminBackupsLogs") .get("logs") .pushObject(Em.Object.create(log)); } }); }, model() { return PreloadStore.getAndRemove("operations_status", function() { return ajax("/admin/backups/status.json"); }).then(status => { return BackupStatus.create({ isOperationRunning: status.is_operation_running, canRollback: status.can_rollback, allowRestore: status.allow_restore }); }); }, deactivate() { this.messageBus.unsubscribe(LOG_CHANNEL); }, actions: { showStartBackupModal() { showModal("admin-start-backup", { admin: true }); this.controllerFor("modal").set("modalClass", "start-backup-modal"); }, startBackup(withUploads) { this.transitionTo("admin.backups.logs"); Backup.start(withUploads); }, destroyBackup(backup) { const self = this; bootbox.confirm( I18n.t("admin.backups.operations.destroy.confirm"), I18n.t("no_value"), I18n.t("yes_value"), function(confirmed) { if (confirmed) { backup.destroy().then(function() { self .controllerFor("adminBackupsIndex") .get("model") .removeObject(backup); }); } } ); }, startRestore(backup) { const self = this; bootbox.confirm( I18n.t("admin.backups.operations.restore.confirm"), I18n.t("no_value"), I18n.t("yes_value"), function(confirmed) { if (confirmed) { self.transitionTo("admin.backups.logs"); backup.restore(); } } ); }, cancelOperation() { const self = this; bootbox.confirm( I18n.t("admin.backups.operations.cancel.confirm"), I18n.t("no_value"), I18n.t("yes_value"), function(confirmed) { if (confirmed) { Backup.cancel().then(function() { self .controllerFor("adminBackups") .set("model.isOperationRunning", false); }); } } ); }, rollback() { bootbox.confirm( I18n.t("admin.backups.operations.rollback.confirm"), I18n.t("no_value"), I18n.t("yes_value"), function(confirmed) { if (confirmed) { Backup.rollback(); } } ); }, uploadSuccess(filename) { bootbox.alert( I18n.t("admin.backups.upload.success", { filename: filename }) ); }, uploadError(filename, message) { bootbox.alert( I18n.t("admin.backups.upload.error", { filename: filename, message: message }) ); }, remoteUploadSuccess() { Backup.find().then(backups => { this.controllerFor("adminBackupsIndex").set( "model", backups.map(backup => Backup.create(backup)) ); }); } } });