Function makeClient

repos/effect/packages/sql/pg/src/PgClient.ts:215–267

(
  options: PgClientConfig & {
    /**
     * Whether to acquire a separate client for each sql.stream / sql.listen
     */
    readonly acquireForStream?: boolean | undefined
  }
)

 * @since 4.0.0
 */
export const makeClient = (
  options: PgClientConfig & {
    /**
     * Whether to acquire a separate client for each sql.stream / sql.listen
     */
    readonly acquireForStream?: boolean | undefined
  }
): Effect.Effect<PgClient, SqlError, Scope.Scope | Reactivity.Reactivity> => {
  function onError() {}
  return fromClient({
    ...options,
    acquire: Effect.acquireRelease(
      Effect.tryPromise({
        try: async () => {
          const client = new Pg.Client({
            connectionString: options.url ? Redacted.value(options.url) : undefined,
            user: options.username,
            host: options.host,
            database: options.database,
            password: options.password ? Redacted.value(options.password) : undefined,
            ssl: options.ssl,
            port: options.port,
            ...(options.stream ? { stream: options.stream } : {}),
            application_name: options.applicationName ?? "@effect/sql-pg",
            types: options.types
          })
          client.on("error", onError)
          await client.connect()
          return client
        },
        catch: (cause) => new SqlError({ reason: classifyError(cause, "PgClient: Failed to connect", "connect") })
      }),
      (client) =>
        Effect.promise(() => {
          client.off("error", onError)
          return client.end()
        }).pipe(
          Effect.timeoutOption(1000)
        ),
      { interruptible: true }
    ).pipe(
      Effect.timeoutOrElse({
        duration: options.connectTimeout ?? Duration.seconds(5),
        orElse: () =>
          Effect.fail(
            new SqlError({
              reason: new ConnectionError({
                cause: new Error("Connection timed out"),
                message: "PgClient: Connection timed out",
                operation: "connect"
              })
            })
          )
      })
    ),
    acquireForStream: options.acquireForStream ?? false