mpackdb

2.6 KB

1. import MPackDB from '../src/MPackDB.js';
2. import { rm } from 'fs/promises';
4. const TEST_DB_PATH = 'db/concurrent-delete-during-scan';
6. console.log('--- Concurrent Delete During Scan Test ---');
7. console.log('Regression test for the refresh() clobber bug (BUG_REPORT.md):');
8. console.log('an unlocked find() must not roll back un-persisted meta mutations');
9. console.log('of a concurrent delete()/insert() in the same process.\n');
11. await rm(TEST_DB_PATH, { recursive: true, force: true });
13. // UTXO-like store: string primary key + secondary indexes, like the blockchain uses
14. const db = new MPackDB(`${TEST_DB_PATH}/utxos`, {
15. primaryKey: 'id',
16. indexes: ['symbol', '*blockNumber'],
17. });
19. const ROUNDS = 40;
20. let resurrections = 0;
21. let lostInserts = 0;
23. for (let round = 0; round < ROUNDS; round++) {
24. const spentId = `spent-${round}`;
25. const keptId = `kept-${round}`;
26. await db.insert({ id: spentId, symbol: 'ADR', blockNumber: round, v: 1 });
28. // Hammer scans while deleting, so a scan's refresh() lands inside delete()'s await window
29. const hammer = (async () => {
30. for (let i = 0; i < 25; i++) {
31. for await (const _ of db.find(() => true)) { /* full scan */ }
32. }
33. })();
35. await Promise.all([
36. db.delete(spentId),
37. db.insert({ id: keptId, symbol: 'ADR', blockNumber: round, v: 2 }),
38. hammer,
39. ]);
41. const spent = await db.find(spentId);
42. if (spent.length !== 0) {
43. resurrections++;
44. console.log(` round ${round}: ✗ deleted record '${spentId}' RESURRECTED (${spent.length} copies)`);
45. }
46. const kept = await db.find(keptId);
47. if (kept.length !== 1) {
48. lostInserts++;
49. console.log(` round ${round}: ✗ inserted record '${keptId}' wrong count: ${kept.length} (expected 1)`);
50. }
51. }
53. // Also verify against a full unindexed scan (bypasses index paths)
54. const all = await db.find(() => true);
55. const spentAlive = all.filter(r => r.id.startsWith('spent-'));
56. const keptAlive = all.filter(r => r.id.startsWith('kept-'));
58. console.log(`\nRounds: ${ROUNDS}`);
59. console.log(`Resurrected deletes (PK lookup): ${resurrections} (expected: 0)`);
60. console.log(`Lost inserts (PK lookup): ${lostInserts} (expected: 0)`);
61. console.log(`Deleted records in full scan: ${spentAlive.length} (expected: 0)`);
62. console.log(`Kept records in full scan: ${keptAlive.length} (expected: ${ROUNDS})`);
64. await db.close();
66. const pass = resurrections === 0 && lostInserts === 0 && spentAlive.length === 0 && keptAlive.length === ROUNDS;
67. console.log(`\n${pass ? '✓ All concurrent delete-during-scan tests passed!' : '✗ FAILED — concurrent scans corrupted meta'}`);
68. if (!pass) {
69. throw new Error('concurrent-delete-during-scan FAILED: deletes resurrected or inserts lost during concurrent scans');
70. }