opatel99/pulsy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(sync): filter dump to INSERTs so re-sync is idempotent

Browse Source
This commit is contained in:
Hermes
2026-08-23 01:50:35 +00:00
parent d1860316f6
commit fdc0768725
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/app/api/admin/sync-from-prod/route.ts
+11 -3
View File
@@ -48,11 +48,19 @@ export async function POST(request: NextRequest) {
const tmp = path.join(os.tmpdir(), `pulse-restore-${Date.now()}.sql`); const tmp = path.join(os.tmpdir(), `pulse-restore-${Date.now()}.sql`);
try { try {
fs.writeFileSync(tmp, dump, 'utf-8');
const tableCount = (dump.match(/CREATE TABLE/g) || []).length; const tableCount = (dump.match(/CREATE TABLE/g) || []).length;
// Keep the same SQLite file inode so the running app's connection stays valid. // Keep same SQLite inode so live connection stays valid.
// Clear tables (foreign_keys off) then re-import dump into the same file. // 1) Clear existing rows
spawnSync('sqlite3', [dbPath, "PRAGMA foreign_keys=OFF; DELETE FROM time_entries; DELETE FROM employees; DELETE FROM companies; DELETE FROM audit_log; DELETE FROM __drizzle_migrations; DELETE FROM sqlite_sequence;"], { encoding: 'utf-8' }); spawnSync('sqlite3', [dbPath, "PRAGMA foreign_keys=OFF; DELETE FROM time_entries; DELETE FROM employees; DELETE FROM companies; DELETE FROM audit_log; DELETE FROM __drizzle_migrations; DELETE FROM sqlite_sequence;"], { encoding: 'utf-8' });
// 2) Filter dump to INSERTs only (DDL already exists via migrations) — otherwise CREATE TABLE fails on re-sync
const filtered = dump
.split('\n')
.filter((line) => {
const t = line.trimStart();
return t.startsWith('INSERT ') || t.startsWith('PRAGMA ') || t.startsWith('BEGIN ') || t.startsWith('COMMIT');
})
.join('\n');
fs.writeFileSync(tmp, filtered, 'utf-8');
const restore = spawnSync('sh', ['-c', `sqlite3 "${dbPath}" < "${tmp}"`], { encoding: 'utf-8', maxBuffer: 10 * 1024 * 1024 }); const restore = spawnSync('sh', ['-c', `sqlite3 "${dbPath}" < "${tmp}"`], { encoding: 'utf-8', maxBuffer: 10 * 1024 * 1024 });
if (restore.status !== 0) { if (restore.status !== 0) {
return NextResponse.json(err('restore failed: ' + (restore.stderr || restore.stdout || '').slice(0, 1500)), { status: 500 }); return NextResponse.json(err('restore failed: ' + (restore.stderr || restore.stdout || '').slice(0, 1500)), { status: 500 });