import test from 'node:test'
import assert from 'node:assert/strict'
import { createRequire } from 'node:module'
import { mkdtempSync, rmSync, writeFileSync, existsSync } from 'node:fs'
import { tmpdir } from 'node:os'
import { resolve, join } from 'node:path'
import { spawnSync } from 'node:child_process'
const root = resolve(import.meta.dirname, '../..')
const Database = createRequire(join(root, 'packages/db/package.json'))('better-sqlite3')
const script = join(root, 'deploy/docker/evofw/sqlite-backup.mjs')

test('online backup includes committed WAL and restore verifies before offline replacement', () => {
  const directory = mkdtempSync(join(tmpdir(), 'evofw-backup-test-'))
  let db
  const run = (...args) => spawnSync(process.execPath, [script, ...args], { cwd: directory, encoding: 'utf8', env: { ...process.env, NODE_PATH: join(root, 'packages/db/node_modules') } })
  try {
    const source = join(directory, 'source.db')
    const backup = join(directory, 'backup.db')
    const restored = join(directory, 'restored.db')
    db = new Database(source)
    db.pragma('journal_mode = WAL')
    db.exec('CREATE TABLE records(id INTEGER PRIMARY KEY, value TEXT); INSERT INTO records VALUES(1,\'committed WAL\')')
    assert.ok(existsSync(`${source}-wal`))
    const result = run('backup', source, backup)
    assert.equal(result.status, 0, result.stderr)
    const snapshot = new Database(backup, { readonly: true })
    assert.equal(snapshot.prepare('SELECT value FROM records').get().value, 'committed WAL')
    snapshot.close()
    assert.notEqual(run('backup', source, backup).status, 0, 'never overwrite an existing backup')
    assert.notEqual(run('restore', backup, restored).status, 0, 'offline declaration required')
    writeFileSync(restored, 'old offline data')
    writeFileSync(`${restored}-wal`, 'stale')
    writeFileSync(`${restored}-shm`, 'stale')
    const recovery = run('restore', backup, restored, '--offline')
    assert.equal(recovery.status, 0, recovery.stderr)
    assert.ok(!existsSync(`${restored}-wal`))
    const recovered = new Database(restored, { readonly: true })
    assert.equal(recovered.prepare('SELECT value FROM records').get().value, 'committed WAL')
    recovered.close()
    const invalid = join(directory, 'invalid.db')
    writeFileSync(invalid, 'not sqlite')
    assert.notEqual(run('restore', invalid, restored, '--offline').status, 0)
    const preserved = new Database(restored, { readonly: true })
    assert.equal(preserved.prepare('SELECT count(*) AS n FROM records').get().n, 1)
    preserved.close()
  } finally {
    db?.close()
    rmSync(directory, { recursive: true, force: true })
  }
})