Function connection_pool

library/src/bootstrap.rs:174–189

()

static POOL: OnceLock<PgPool> = OnceLock::new();

pub async fn connection_pool() -> &'static PgPool {
    let url = &env::var("DATABASE_URL").expect("DATABASE_URL must be set");
    let p = match POOL.get() {
        None => {
            let pool = PgPoolOptions::new()
                .max_connections(30)
                .connect(url)
                .await
                .map_err(|err| ApplicationError::DatabaseConnectionError(Box::new(err)))
                .unwrap();
            POOL.get_or_init(|| pool)
        }
        Some(pool) => pool,
    };
    p
}

static DEPENDENCY: OnceLock<Dependency> = OnceLock::new();