NuKVM/xen-orchestra
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(xo-server#_listPoolMetadataBackups): use @xen-orchestra/backups lib (#5607)

Browse Source
This commit is contained in:
badrAZ 2021-02-24 10:02:57 +01:00 committed by GitHub
parent 637afdb540
commit e36efaec08
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
packages/xo-server/src/xo-mixins/metadata-backups.js
View File

@ -1,7 +1,7 @@
// @flow
import asyncMap from '@xen-orchestra/async-map'
import createLogger from '@xen-orchestra/log'
import { fromEvent, ignoreErrors, timeout } from 'promise-toolbox'
import { fromEvent, ignoreErrors, timeout, using } from 'promise-toolbox'
import { parseDuration } from '@vates/parse-duration'
import { debounceWithKey, REMOVE_CACHE_ENTRY } from '../_pDebounceWithKey'
@ -713,59 +713,29 @@ export default class metadataBackup {
// }
async _listPoolMetadataBackups(remoteId) {
const app = this._app
const { proxy, url, options } = await app.getRemoteWithCredentials(remoteId)
if (proxy !== undefined) {
const { [remoteId]: backupsByPool } = await app.callProxyMethod(proxy, 'backup.listPoolMetadataBackups', {
const remote = await app.getRemoteWithCredentials(remoteId)
let backupsByPool
if (remote.proxy !== undefined) {
;({ [remoteId]: backupsByPool } = await app.callProxyMethod(remote.proxy, 'backup.listPoolMetadataBackups', {
remotes: {
[remoteId]: {
url,
options,
url: remote.url,
options: remote.options,
},
},
})
// inject the remote id on the backup which is needed for restoreMetadataBackup()
Object.values(backupsByPool).forEach(backups =>
backups.forEach(backup => {
backup.id = `${remoteId}${backup.id}`
})
)
return backupsByPool
}))
} else {
backupsByPool = await using(app.getBackupsRemoteAdapter(remote), adapter => adapter.listPoolMetadataBackups())
}
const handler = await this._app.getRemoteHandler(remoteId)
const safeReaddir = createSafeReaddir(handler, 'listXoMetadataBackups')
const backupsByPool = {}
await asyncMap(safeReaddir(DIR_XO_POOL_METADATA_BACKUPS, { prependDir: true }), scheduleDir =>
asyncMap(safeReaddir(scheduleDir), poolId => {
const backups = backupsByPool[poolId] ?? (backupsByPool[poolId] = [])
return asyncMap(safeReaddir(`${scheduleDir}/${poolId}`, { prependDir: true }), async backupDir => {
try {
backups.push({
id: `${remoteId}${backupDir}`,
...JSON.parse(String(await handler.readFile(`${backupDir}/metadata.json`))),
})
} catch (error) {
log.warn(`listPoolMetadataBackups ${backupDir}`, {
error,
})
}
})
// inject the remote id on the backup which is needed for restoreMetadataBackup()
Object.values(backupsByPool).forEach(backups =>
backups.forEach(backup => {
backup.id = `${remoteId}${backup.id}`
})
)
// delete empty entries and sort backups
Object.keys(backupsByPool).forEach(poolId => {
const backups = backupsByPool[poolId]
if (backups.length === 0) {
delete backupsByPool[poolId]
} else {
backups.sort(compareTimestamp)
}
})
return backupsByPool
}