diff --git a/apps/server/src/persistence/Layers/Sqlite.ts b/apps/server/src/persistence/Layers/Sqlite.ts index 2dddfc3bfa..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.gen(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.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,