Function SQLiteStoreLayer

packages/infra/src/Store/SQL.ts:717–746

(
  cfg: StorageConfig,
  options?: { makeSqlClientLayer?: (namespace: string) => Layer.Layer<SqlClient.SqlClient> }
)

          }))
        },

        queryRaw: (query) =>
          s.all.pipe(
            Effect.map(query.memory),
            annotateDb({
              operation: "queryRaw",
              system: "sqlite",
              collection: tableName,
              entity: name
            })
          )
      }

      yield* seedNamespace("primary").pipe(Effect.orDie)

      return s
    })
  }
}

export function SQLiteStoreLayer(
  cfg: StorageConfig,
  options?: { makeSqlClientLayer?: (namespace: string) => Layer.Layer<SqlClient.SqlClient> }
) {
  if (options?.makeSqlClientLayer) {
    return Layer.effectContext(
      Effect.gen(function*() {
        const layerMap = yield* LayerMap.make(
          (namespace: string) => options.makeSqlClientLayer!(namespace),
          { idleTimeToLive: "10 minutes" }
        )

        const withNsSql: WithNsSqlFn = (ns, f) => SqlClient.SqlClient.use(f).pipe(Effect.provide(layerMap.get(ns)))