Function make

packages/sql-sqlite-bun/src/SqliteClient.ts:78–198

(
  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 db = new Database(options.filename, {
        readonly: options.readonly,
        readwrite: options.readwrite ?? true,
        create: options.create ?? true
      } as any)
      yield* Effect.addFinalizer(() => Effect.sync(() => db.close()))

      if (options.disableWAL !== true) {
        db.run("PRAGMA journal_mode = WAL;")
      }

      const run = (
        sql: string,
        params: ReadonlyArray<unknown> = []
      ) =>
        Effect.withFiberRuntime<Array<any>, SqlError>((fiber) => {
          const useSafeIntegers = Context.get(fiber.currentContext, Client.SafeIntegers)
          try {
            const statement = db.query(sql)
            // @ts-ignore bun-types missing safeIntegers method, fixed in https://github.com/oven-sh/bun/pull/26627
            statement.safeIntegers(useSafeIntegers)
            return Effect.succeed((statement.all(...(params as any)) ?? []) as Array<any>)
          } catch (cause) {
            return Effect.fail(new SqlError({ cause, message: "Failed to execute statement" }))
          }
        })

      const runValues = (
        sql: string,
        params: ReadonlyArray<unknown> = []
      ) =>
        Effect.withFiberRuntime<Array<any>, SqlError>((fiber) => {
          const useSafeIntegers = Context.get(fiber.currentContext, Client.SafeIntegers)
          try {
            const statement = db.query(sql)
            // @ts-ignore bun-types missing safeIntegers method, fixed in https://github.com/oven-sh/bun/pull/26627
            statement.safeIntegers(useSafeIntegers)
            return Effect.succeed((statement.values(...(params as any)) ?? []) as Array<any>)
          } catch (cause) {
            return Effect.fail(new SqlError({ cause, message: "Failed to execute statement" }))
          }
        })

      return identity<SqliteConnection>({
        execute(sql, params, transformRows) {
          return transformRows