Function make

packages/sql/src/internal/client.ts:32–107

({
  acquirer,
  beginTransaction = "BEGIN",
  commit = "COMMIT",
  compiler,
  reactiveMailbox,
  rollback = "ROLLBACK",
  rollbackSavepoint = (id) => `ROLLBACK TO SAVEPOINT ${id}`,
  savepoint = (id) => `SAVEPOINT ${id}`,
  spanAttributes,
  transactionAcquirer,
  transformRows
}: Client.SqlClient.MakeOptions)

/** @internal */
export function make({
  acquirer,
  beginTransaction = "BEGIN",
  commit = "COMMIT",
  compiler,
  reactiveMailbox,
  rollback = "ROLLBACK",
  rollbackSavepoint = (id) => `ROLLBACK TO SAVEPOINT ${id}`,
  savepoint = (id) => `SAVEPOINT ${id}`,
  spanAttributes,
  transactionAcquirer,
  transformRows
}: Client.SqlClient.MakeOptions): Effect.Effect<Client.SqlClient, never, Reactivity.Reactivity> {
  return Effect.gen(function*() {
    const getConnection = Effect.flatMap(
      Effect.serviceOption(TransactionConnection),
      Option.match({
        onNone: () => acquirer,
        onSome: ([conn]) => Effect.succeed(conn)
      })
    )

    transactionAcquirer = transactionAcquirer ?? acquirer
    const withTransaction = makeWithTransaction({
      transactionTag: TransactionConnection,
      spanAttributes,
      acquireConnection: Effect.flatMap(
        Scope.make(),
        (scope) => Effect.map(Scope.extend(transactionAcquirer!, scope), (conn) => [scope, conn] as const)
      ),
      begin: (conn) => conn.executeUnprepared(beginTransaction, [], undefined),
      savepoint: (conn, id) => conn.executeUnprepared(savepoint(`effect_sql_${id}`), [], undefined),
      commit: (conn) => conn.executeUnprepared(commit, [], undefined),
      rollback: (conn) => conn.executeUnprepared(rollback, [], undefined),
      rollbackSavepoint: (conn, id) => conn.executeUnprepared(rollbackSavepoint(`effect_sql_${id}`), [], undefined)
    })

    const reactivity = yield* Reactivity.Reactivity
    const client: Client.SqlClient = Object.assign(
      Statement.make(getConnection, compiler, spanAttributes, transformRows),
      {
        [TypeId as Client.TypeId]: TypeId as Client.TypeId,
        safe: undefined as any,
        withTransaction,
        reserve: transactionAcquirer,
        withoutTransforms(): any {
          if (transformRows === undefined) {
            return this
          }
          const statement = Statement.make(getConnection, compiler.withoutTransform, spanAttributes, undefined)
          const client = Object.assign(statement, {
            ...this,
            ...statement
          })
          ;(client as any).safe = client
          ;(client as any).withoutTransforms = () => client
          return client
        },