mpackdb

1.3 KB

1. import MPackDB from '../src/MPackDB.js';
2. import { rm } from 'fs/promises';
4. const TEST_DB_PATH = 'db/lockfile';
6. console.log('--- Lockfile Test ---');
8. // Clean up
9. await rm(TEST_DB_PATH, { recursive: true, force: true });
11. const db = new MPackDB(`${TEST_DB_PATH}/db`);
13. // Test 1: Insert
14. console.log('Test 1: Insert with lock');
15. const id1 = await db.insert({ name: 'Alice', age: 30 });
16. console.log('✓ Inserted:', id1);
18. // Test 2: Multiple inserts
19. console.log('\nTest 2: Multiple inserts');
20. const id2 = await db.insert({ name: 'Bob', age: 25 });
21. const id3 = await db.insert({ name: 'Charlie', age: 35 });
22. console.log('✓ Inserted:', id2, id3);
24. // Test 3: Read (no lock needed)
25. console.log('\nTest 3: Read all');
26. const all = await db.find();
27. console.log('✓ Found', all.length, 'records');
29. // Test 4: Delete with lock
30. console.log('\nTest 4: Delete with lock');
31. await db.delete(u => u.age === 25);
32. const remaining = await db.find();
33. console.log('✓ Remaining:', remaining.length, 'records');
35. // Test 5: Verify no stale lock
36. console.log('\nTest 5: Verify lock cleanup');
37. const { readdirSync } = await import('fs');
38. const files = readdirSync(TEST_DB_PATH);
39. const hasLock = files.some(f => f.endsWith('.lock'));
40. if (hasLock) {
41. throw new Error('❌ Lock file not cleaned up!');
42. }
43. console.log('✓ No stale lock files');
45. console.log('\n✓ All tests passed!');