root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(FN-4083): add WAL enforcement, immediate write transactions, and concu

Browse Source 
Hardened SQLite concurrent-write safety in `@fusion/core` by auditing WAL enforcement and adding immediate write transactions to prevent stale reads under load, with executor semaphore limit tests in `@fusion/engine` validating the concurrency bounds; added a new `store-concurrent-writes.test.ts` in

Fusion-Task-Id: FN-4083

Fusion-Task-Lineage: adabe51a-a9c4-481a-850d-985c373df51a
This commit is contained in:
Fusion
2026-05-12 03:23:06 -07:00
committed by gsxdsm
parent b1a0464d68
commit 06feb61686
14 changed files with 384 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
packages/core/src/db.ts
View File

@@ -33,6 +33,8 @@ const DEFAULT_SQLITE_BUSY_TIMEOUT_MS = 5_000;
const DEFAULT_SQLITE_LOCK_RECOVERY_WINDOW_MS = 1_000;
const DEFAULT_SQLITE_LOCK_RECOVERY_DELAY_MS = 50;
type TransactionMode = "deferred" | "immediate";
// ── JSON Helpers ─────────────────────────────────────────────────────
/**
@@ -3279,20 +3281,26 @@ export class Database {
* If the function throws, the transaction/savepoint is rolled back.
* If the function returns normally, the transaction/savepoint is committed.
*
* Outermost transactions acquire `BEGIN IMMEDIATE` so transient writer-lock
* contention is detected before user code runs, allowing bounded retry
* without re-executing the callback. Nested transactions remain savepoint-based.
* Outermost transactions default to `BEGIN` (DEFERRED) so read-only callers
* avoid taking a writer lock until they actually mutate state.
* Use `transactionImmediate()` for write-heavy paths that should acquire the
* RESERVED lock before user code runs and fail/retry before the callback executes.
*/
transaction<T>(fn: () => T): T {
transaction<T>(fn: () => T, options?: { mode?: TransactionMode }): T {
const depth = this.transactionDepth++;
const isOutermost = depth === 0;
const savepointName = `sp_${depth}`;
const mode: TransactionMode = options?.mode ?? "deferred";
try {
if (isOutermost) {
this.runWithLockRecovery("BEGIN IMMEDIATE", () => {
this.db.exec("BEGIN IMMEDIATE");
});
if (mode === "immediate") {
this.runWithLockRecovery("BEGIN IMMEDIATE", () => {
this.db.exec("BEGIN IMMEDIATE");
});
} else {
this.db.exec("BEGIN");
}
} else {
this.db.exec(`SAVEPOINT ${savepointName}`);
}
@@ -3324,6 +3332,10 @@ export class Database {
}
}
transactionImmediate<T>(fn: () => T): T {
return this.transaction(fn, { mode: "immediate" });
}
/**
* Execute plugin-provided schema initialization hooks.
*