authorgravatar for julius0216@outlook.comJulius Marminge <julius0216@outlook.com> 2026-02-24 15:27:41-08:00
committergravatar for jmarminge@gmail.comJulius Marminge <jmarminge@gmail.com> 2026-02-26 13:20:36-08:00
log5cbb6ea728903f4a9aa25441f663fe65e456f2c9
treeb8ded157ec6b9ff197692085f1391a9dc6706021
parentbe526df88ae125a0076ecf17109d16001280621c

wal

2 files changed, 1 insertions(+), 11 deletions(-)

apps/server/src/persistence/Layers/Sqlite.ts+1-5
...@@ -5,7 +5,6 @@ import { runMigrations } from "../Migrations.ts";...@@ -5,7 +5,6 @@ import { runMigrations } from "../Migrations.ts";
55
6type RuntimeSqliteLayerConfig = {6type RuntimeSqliteLayerConfig = {
7 readonly filename: string;7 readonly filename: string;
8 readonly disableWAL?: boolean | undefined;
9};8};
109
11type Loader = {10type Loader = {
...@@ -46,8 +45,5 @@ export const makeSqlitePersistenceLive = (dbPath: string) =>...@@ -46,8 +45,5 @@ export const makeSqlitePersistenceLive = (dbPath: string) =>
4645
47export const SqlitePersistenceMemory = Layer.provideMerge(46export const SqlitePersistenceMemory = Layer.provideMerge(
48 setup,47 setup,
49 makeRuntimeSqliteLayer({48 makeRuntimeSqliteLayer({ filename: ":memory:" }),
50 filename: ":memory:",
51 disableWAL: true,
52 }),
53);49);
apps/server/src/persistence/NodeSqliteClient.ts-6
...@@ -35,7 +35,6 @@ export interface SqliteClientConfig {...@@ -35,7 +35,6 @@ export interface SqliteClientConfig {
35 readonly allowExtension?: boolean | undefined;35 readonly allowExtension?: boolean | undefined;
36 readonly prepareCacheSize?: number | undefined;36 readonly prepareCacheSize?: number | undefined;
37 readonly prepareCacheTTL?: Duration.Input | undefined;37 readonly prepareCacheTTL?: Duration.Input | undefined;
38 readonly disableWAL?: boolean | undefined;
39 readonly spanAttributes?: Record<string, unknown> | undefined;38 readonly spanAttributes?: Record<string, unknown> | undefined;
40 readonly transformResultNames?: ((str: string) => string) | undefined;39 readonly transformResultNames?: ((str: string) => string) | undefined;
41 readonly transformQueryNames?: ((str: string) => string) | undefined;40 readonly transformQueryNames?: ((str: string) => string) | undefined;
...@@ -64,10 +63,6 @@ const makeWithDatabase = (...@@ -64,10 +63,6 @@ const makeWithDatabase = (
64 Effect.sync(() => db.close()),63 Effect.sync(() => db.close()),
65 );64 );
6665
67 if (options.disableWAL !== true) {
68 db.exec("PRAGMA journal_mode = WAL");
69 }
70
71 const statementReaderCache = new WeakMap<StatementSync, boolean>();66 const statementReaderCache = new WeakMap<StatementSync, boolean>();
72 const hasRows = (statement: StatementSync): boolean => {67 const hasRows = (statement: StatementSync): boolean => {
73 const cached = statementReaderCache.get(statement);68 const cached = statementReaderCache.get(statement);
...@@ -203,7 +198,6 @@ const makeMemory = (...@@ -203,7 +198,6 @@ const makeMemory = (
203 ...config,198 ...config,
204 filename: ":memory:",199 filename: ":memory:",
205 readonly: false,200 readonly: false,
206 disableWAL: config.disableWAL ?? true,
207 },201 },
208 () => {202 () => {
209 const database = new DatabaseSync(":memory:", {203 const database = new DatabaseSync(":memory:", {