Function make

packages/sql-sqlite-node/src/SqliteClient.ts:90–252

(
  options: SqliteClientConfig
)

 * @since 1.0.0
 */
export const make = (
  options: SqliteClientConfig
): Effect.Effect<SqliteClient, never, Scope.Scope | Reactivity.Reactivity> =>
  Effect.gen(function*() {
    const compiler = Statement.makeCompilerSqlite(options.transformQueryNames)
    const transformRows = options.transformResultNames ?
      Statement.defaultTransforms(
        options.transformResultNames
      ).array :
      undefined

    const makeConnection = Effect.gen(function*() {
      const scope = yield* Effect.scope
      const db = new Sqlite(options.filename, {
        readonly: options.readonly ?? false
      })
      yield* Scope.addFinalizer(scope, Effect.sync(() => db.close()))

      if (options.disableWAL !== true) {
        db.pragma("journal_mode = WAL")
      }

      const prepareCache = yield* Cache.make({
        capacity: options.prepareCacheSize ?? 200,
        timeToLive: options.prepareCacheTTL ?? Duration.minutes(10),
        lookup: (sql: string) =>
          Effect.try({
            try: () => db.prepare(sql),
            catch: (cause) => new SqlError({ cause, message: "Failed to prepare statement " })
          })
      })

      const runStatement = (
        statement: Sqlite.Statement,
        params: ReadonlyArray<unknown>,
        raw: boolean
      ) =>
        Effect.withFiberRuntime<ReadonlyArray<any>, SqlError>((fiber) => {
          if (Context.get(fiber.currentContext, Client.SafeIntegers)) {
            statement.safeIntegers(true)
          }
          try {
            if (statement.reader) {
              return Effect.succeed(statement.all(...params))
            }
            const result = statement.run(...params)
            return Effect.succeed(raw ? result as unknown as ReadonlyArray<any> : [])
          } catch (cause) {
            return Effect.fail(new SqlError({ cause, message: "Failed to execute statement" }))
          }
        })

      const run = (
        sql: string,
        params: ReadonlyArray<unknown>,
        raw = false
      ) =>
        Effect.flatMap(