43 lines
2.6 KiB
JavaScript
43 lines
2.6 KiB
JavaScript
import test from 'node:test';
|
||
import assert from 'node:assert/strict';
|
||
import fs from 'node:fs';
|
||
import {tmpdir} from 'node:os';
|
||
import {join} from 'node:path';
|
||
import {DatabaseSync} from 'node:sqlite';
|
||
import {backupDataVolume,verifyDataVolume,restoreDataVolume} from '../server/backup-data-volume.mjs';
|
||
|
||
test('shared volume backup captures multiple SQLite stores, committed WAL and nested files',async()=>{
|
||
const dir=fs.mkdtempSync(join(tmpdir(),'ihaleist-volume-')),source=join(dir,'source'),backup=join(dir,'backup'),restored=join(dir,'restored');
|
||
fs.mkdirSync(source);let live;
|
||
try {
|
||
for(const name of ['kalem.sqlite','tender-history.sqlite']) {
|
||
const db=new DatabaseSync(join(source,name));db.exec('PRAGMA journal_mode=WAL;CREATE TABLE records(value TEXT);');db.prepare('INSERT INTO records VALUES (?)').run('Son Türkçe kayıt');
|
||
if(name==='kalem.sqlite')live=db;else db.close();
|
||
}
|
||
fs.mkdirSync(join(source,'nested'));fs.writeFileSync(join(source,'nested','cache.json'),'["İhale"]');
|
||
const manifest=await backupDataVolume(source,backup,{offline:true});
|
||
assert.equal(manifest.files.length,3);assert.equal(manifest.files.filter(f=>f.sqlite).length,2);
|
||
assert.equal(manifest.files.some(f=>/-wal$|-shm$/.test(f.name)),false);
|
||
await restoreDataVolume(backup,restored);
|
||
const db=new DatabaseSync(join(restored,'kalem.sqlite'));assert.equal(db.prepare('SELECT value FROM records').get().value,'Son Türkçe kayıt');db.close();
|
||
assert.equal(fs.readFileSync(join(restored,'nested','cache.json'),'utf8'),'["İhale"]');
|
||
await assert.rejects(restoreDataVolume(backup,restored),/EEXIST/);
|
||
fs.appendFileSync(join(backup,'nested','cache.json'),'changed');
|
||
await assert.rejects(verifyDataVolume(backup),/değişmiş/);
|
||
} finally {live?.close();fs.rmSync(dir,{recursive:true,force:true});}
|
||
});
|
||
test('volume backup refuses unconfirmed offline, symlinks, nested output and unlisted files',async()=>{
|
||
const dir=fs.mkdtempSync(join(tmpdir(),'ihaleist-volume-')),source=join(dir,'source'),backup=join(dir,'backup');fs.mkdirSync(source);
|
||
try {
|
||
fs.writeFileSync(join(source,'data.json'),'{}');
|
||
await assert.rejects(backupDataVolume(source,backup),/offline/);
|
||
await assert.rejects(backupDataVolume(source,join(source,'inside'),{offline:true}),/iç içe/);
|
||
fs.symlinkSync(join(source,'data.json'),join(source,'link'));
|
||
await assert.rejects(backupDataVolume(source,backup,{offline:true}),/sembolik/);
|
||
fs.unlinkSync(join(source,'link'));
|
||
await backupDataVolume(source,backup,{offline:true});
|
||
fs.writeFileSync(join(backup,'unlisted'),'extra');
|
||
await assert.rejects(verifyDataVolume(backup),/Manifest dışında/);
|
||
} finally {fs.rmSync(dir,{recursive:true,force:true});}
|
||
});
|