From a1df9b7b3d5afe09c220aad0d04a7df2977e66aa Mon Sep 17 00:00:00 2001 From: Julius Marminge Date: Wed, 1 Apr 2026 00:27:12 -0700 Subject: [PATCH 1/2] migrate Effect.fn in apps/server/src/persistence/Layers/Sqlite.ts Co-authored-by: codex --- apps/server/src/persistence/Layers/Sqlite.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/server/src/persistence/Layers/Sqlite.ts b/apps/server/src/persistence/Layers/Sqlite.ts index 2dddfc3bfa..a0166efaf8 100644 --- a/apps/server/src/persistence/Layers/Sqlite.ts +++ b/apps/server/src/persistence/Layers/Sqlite.ts @@ -19,12 +19,12 @@ const defaultSqliteClientLoaders = { const makeRuntimeSqliteLayer = ( config: RuntimeSqliteLayerConfig, ): Layer.Layer => - Effect.gen(function* () { + Effect.fn("makeRuntimeSqliteLayer")(function* () { const runtime = process.versions.bun !== undefined ? "bun" : "node"; const loader = defaultSqliteClientLoaders[runtime]; const clientModule = yield* Effect.promise(loader); return clientModule.layer(config); - }).pipe(Layer.unwrap); + })().pipe(Layer.unwrap); const setup = Layer.effectDiscard( Effect.gen(function* () { @@ -36,13 +36,13 @@ const setup = Layer.effectDiscard( ); export const makeSqlitePersistenceLive = (dbPath: string) => - Effect.gen(function* () { + Effect.fn("makeSqlitePersistenceLive")(function* () { const fs = yield* FileSystem.FileSystem; const path = yield* Path.Path; yield* fs.makeDirectory(path.dirname(dbPath), { recursive: true }); return Layer.provideMerge(setup, makeRuntimeSqliteLayer({ filename: dbPath })); - }).pipe(Layer.unwrap); + })().pipe(Layer.unwrap); export const SqlitePersistenceMemory = Layer.provideMerge( setup, From e9c84e4ceb983c2e20677d77074a8d849447f035 Mon Sep 17 00:00:00 2001 From: Julius Marminge Date: Wed, 1 Apr 2026 08:34:31 -0700 Subject: [PATCH 2/2] bad codex --- apps/server/src/persistence/Layers/Sqlite.ts | 30 ++++++++++---------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/apps/server/src/persistence/Layers/Sqlite.ts b/apps/server/src/persistence/Layers/Sqlite.ts index a0166efaf8..07cbf44794 100644 --- a/apps/server/src/persistence/Layers/Sqlite.ts +++ b/apps/server/src/persistence/Layers/Sqlite.ts @@ -16,15 +16,14 @@ const defaultSqliteClientLoaders = { node: () => import("../NodeSqliteClient.ts"), } satisfies Record Promise>; -const makeRuntimeSqliteLayer = ( +const makeRuntimeSqliteLayer = Effect.fn("makeRuntimeSqliteLayer")(function* ( config: RuntimeSqliteLayerConfig, -): Layer.Layer => - Effect.fn("makeRuntimeSqliteLayer")(function* () { - const runtime = process.versions.bun !== undefined ? "bun" : "node"; - const loader = defaultSqliteClientLoaders[runtime]; - const clientModule = yield* Effect.promise(loader); - return clientModule.layer(config); - })().pipe(Layer.unwrap); +) { + const runtime = process.versions.bun !== undefined ? "bun" : "node"; + const loader = defaultSqliteClientLoaders[runtime]; + const clientModule = yield* Effect.promise(loader); + return clientModule.layer(config); +}, Layer.unwrap); const setup = Layer.effectDiscard( Effect.gen(function* () { @@ -35,14 +34,15 @@ const setup = Layer.effectDiscard( }), ); -export const makeSqlitePersistenceLive = (dbPath: string) => - Effect.fn("makeSqlitePersistenceLive")(function* () { - const fs = yield* FileSystem.FileSystem; - const path = yield* Path.Path; - yield* fs.makeDirectory(path.dirname(dbPath), { recursive: true }); +export const makeSqlitePersistenceLive = Effect.fn("makeSqlitePersistenceLive")(function* ( + dbPath: string, +) { + const fs = yield* FileSystem.FileSystem; + const path = yield* Path.Path; + yield* fs.makeDirectory(path.dirname(dbPath), { recursive: true }); - return Layer.provideMerge(setup, makeRuntimeSqliteLayer({ filename: dbPath })); - })().pipe(Layer.unwrap); + return Layer.provideMerge(setup, makeRuntimeSqliteLayer({ filename: dbPath })); +}, Layer.unwrap); export const SqlitePersistenceMemory = Layer.provideMerge( setup,