Page MenuHomePhabricator
Files F3366110

D4263.id13497.diff
No OneTemporary
Actions

D4263.id13497.diff
View Options

diff --git a/keyserver/src/cron/backups.js b/keyserver/src/cron/backups.js
--- a/keyserver/src/cron/backups.js
+++ b/keyserver/src/cron/backups.js
@@ -194,27 +194,19 @@
}
async function deleteOldestBackup() {
- const backupConfig = await getBackupConfig();
+ const [backupConfig, backupInfos] = await Promise.all([
+ getBackupConfig(),
+ getBackupInfos(),
+ ]);
+
invariant(backupConfig, 'backupConfig should be non-null');
- const files = await readdir(backupConfig.directory);
- let oldestFile;
- for (const file of files) {
- if (!file.endsWith('.sql.gz') || !file.startsWith('comm.')) {
- continue;
- }
- const stat = await lstat(`${backupConfig.directory}/${file}`);
- if (stat.isDirectory()) {
- continue;
- }
- if (!oldestFile || stat.mtime < oldestFile.mtime) {
- oldestFile = { file, mtime: stat.mtime };
- }
- }
- if (!oldestFile) {
+ if (backupInfos.length === 0) {
throw new Error('no_backups_left');
}
+
+ const oldestFilename = backupInfos[0].filename;
try {
- await unlink(`${backupConfig.directory}/${oldestFile.file}`);
+ await unlink(`${backupConfig.directory}/${oldestFilename}`);
} catch (e) {
// Check if it's already been deleted
if (e.code !== 'ENOENT') {
@@ -223,4 +215,36 @@
}
}
+type BackupInfo = {
+ +filename: string,
+ +lastModifiedTime: number,
+ +bytes: number,
+};
+async function getBackupInfos(): Promise<BackupInfo[]> {
+ const backupConfig = await getBackupConfig();
+ invariant(backupConfig, 'backupConfig should be non-null');
+
+ const filenames = await readdir(backupConfig.directory);
+ const backups = await Promise.all(
+ filenames.map(async filename => {
+ if (!filename.endsWith('.sql.gz') || !filename.startsWith('comm.')) {
+ return null;
+ }
+ const stats = await lstat(`${backupConfig.directory}/${filename}`);
+ if (stats.isDirectory()) {
+ return null;
+ }
+ return {
+ filename,
+ lastModifiedTime: stats.mtime,
+ bytes: stats.size,
+ };
+ }),
+ );
+
+ const filteredBackups = backups.filter(Boolean);
+ filteredBackups.sort((a, b) => a.lastModifiedTime - b.lastModifiedTime);
+ return filteredBackups;
+}
+
export { backupDB };

File Metadata

Mime Type
text/plain
Expires
Tue, Nov 26, 9:35 AM (21 h, 8 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2584171
Default Alt Text
D4263.id13497.diff (2 KB)

Event Timeline