From 9f6686a13d308289c187c9da369f4874f0b5acc5 Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Wed, 1 Apr 2026 09:14:26 -0700
Subject: [PATCH] [codex] migrate Effect.fn in
 apps/server/src/persistence/Layers/Sqlite.ts (#1631)

Co-authored-by: codex <codex@users.noreply.github.com>
---
 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 2dddfc3bfa4ab614017b23c0c96400364634e67a..07cbf44794be14c295a31cc82309aebd469df9fb 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<string, () => Promise<Loader>>;
 
-const makeRuntimeSqliteLayer = (
+const makeRuntimeSqliteLayer = Effect.fn("makeRuntimeSqliteLayer")(function* (
   config: RuntimeSqliteLayerConfig,
-): Layer.Layer<SqlClient.SqlClient> =>
-  Effect.gen(function* () {
-    const runtime = process.versions.bun !== undefined ? "bun" : "node";
-    const loader = defaultSqliteClientLoaders[runtime];
-    const clientModule = yield* Effect.promise<Loader>(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>(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.gen(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,
-- 
2.54.0