diff --git a/dashboard/src/components/BackupList.vue b/dashboard/src/components/BackupList.vue index bb0d0a06c..922879e04 100644 --- a/dashboard/src/components/BackupList.vue +++ b/dashboard/src/components/BackupList.vue @@ -9,6 +9,7 @@ import { Button, ButtonGroup, ProgressBar, FormGroup, TextInput, Checkbox, Table import { prettyLongDate, copyToClipboard } from '@cloudron/pankow/utils'; import { TASK_TYPES } from '../constants.js'; import Section from '../components/Section.vue'; +import SettingsItem from '../components/SettingsItem.vue'; import BackupsModel from '../models/BackupsModel.js'; import BackupTargetsModel from '../models/BackupTargetsModel.js'; import AppsModel from '../models/AppsModel.js'; @@ -49,43 +50,50 @@ const columns = { const busy = ref(true); const backups = ref([]); const taskLogsMenu = ref([]); -const lastTask = ref({}); +const trackingTask = ref({}); +const targets = ref([]); -async function waitForTask() { - if (!lastTask.value.id) return; +async function waitForTask(id) { + if (!id || (trackingTask.value.id && trackingTask.value.id !== id)) return; - const [error, result] = await tasksModel.get(lastTask.value.id); + const [error, result] = await tasksModel.get(id); if (error) return console.error(error); - lastTask.value = result; + trackingTask.value = result; // task done, refresh menu if (!result.active) { + trackingTask.value = {}; refreshBackups(); refreshTasks(); return; } - setTimeout(waitForTask, 2000); + setTimeout(waitForTask.bind(null, id), 2000); } async function refreshTasks() { - const [error, result] = await tasksModel.getByType(TASK_TYPES.TASK_BACKUP); - if (error) return console.error(error); + let tasks = []; - lastTask.value = result[0] || {}; + for (const target of targets.value) { + const [error, result] = await tasksModel.getByType(TASK_TYPES.TASK_FULL_BACKUP_PREFIX + target.id); + if (error) return console.error(error); + + tasks = tasks.concat(result); + + // if last task is currently active, start polling + if (result[0] && result[0].active) waitForTask(result[0].id); + } // limit to last 10 - taskLogsMenu.value = result.slice(0,10).map(t => { + tasks.sort((a, b) => a.creationTime - b.creationTime); + taskLogsMenu.value = tasks.slice(0,10).map(t => { return { icon: 'fa-solid ' + ((!t.active && t.success) ? 'status-active fa-check-circle' : (t.active ? 'fa-circle-notch fa-spin' : 'status-error fa-times-circle')), label: prettyLongDate(t.ts), action: () => { window.open(`/logs.html?taskId=${t.id}`); } }; }); - - // if last task is currently active, start polling - if (lastTask.value.active) waitForTask(); } async function refreshBackups() { @@ -157,7 +165,7 @@ const stopBackupBusy = ref(false); async function onStopBackup() { stopBackupBusy.value = true; - const [error] = await tasksModel.stop(lastTask.value.id); + const [error] = await tasksModel.stop(trackingTask.value.id); if (error) return console.error(error); await refreshTasks(); @@ -230,6 +238,8 @@ onMounted(async () => { const [error, result] = await backupTargetsModel.list(); if (error) return console.error(error); + targets.value = result; + const primaryTarget = result.find(t => t.primary); if (!primaryTarget) return; @@ -307,10 +317,21 @@ onMounted(async () => { + +
+ +
{{ trackingTask.message }}
+
{{ startBackupError }}
+
+
+ +
+
+

@@ -335,19 +356,5 @@ onMounted(async () => { - -
- -
- -
{{ lastTask.message }}
-
-
- -
- - -
{{ startBackupError }}
-
diff --git a/dashboard/src/constants.js b/dashboard/src/constants.js index 51c698ab0..23197d975 100644 --- a/dashboard/src/constants.js +++ b/dashboard/src/constants.js @@ -78,7 +78,9 @@ const ROLES = { // sync up with tasks.js const TASK_TYPES = { TASK_APP: 'app', - TASK_BACKUP: 'backup', + TASK_APP_BACKUP_PREFIX: 'appBackup_', + TASK_FULL_BACKUP_PREFIX: 'backup_', // full backup + TASK_CLEAN_BACKUPS_PREFIX: 'cleanBackups_', TASK_UPDATE: 'boxUpdate', TASK_CHECK_CERTS: 'checkCerts', TASK_PREPARE_DASHBOARD_LOCATION: 'prepareDashboardLocation',