feat: restore just .sql files

This commit is contained in:
izzy
2025-11-21 14:58:49 +00:00
parent a7245627fc
commit 874782edf0

View File

@@ -198,9 +198,14 @@ export async function restoreBackup(
logger.log(`Database Restore Starting. Database Version: ${databaseMajorVersion}`);
const fileStream = storage.createPlainReadStream(backupFilePath);
const gunzip = storage.createGunzip();
fileStream.pipe(gunzip);
let inputStream: Readable;
if (backupFilePath.endsWith('.gz')) {
const fileStream = storage.createPlainReadStream(backupFilePath);
const inputStream = storage.createGunzip();
fileStream.pipe(inputStream);
} else {
inputStream = storage.createPlainReadStream(backupFilePath);
}
async function* sql() {
yield `
@@ -219,7 +224,7 @@ export async function restoreBackup(
GRANT ALL ON SCHEMA public TO public;
`;
for await (const chunk of gunzip) {
for await (const chunk of inputStream) {
yield chunk;
}
}