eqeqo-api-auth 0.0.1

Centralized authentication and authorization API for multiple independent services. Manages users, roles, permissions, and service associations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use sqlx::{Pool, Postgres, postgres::PgPoolOptions};
use std::env;
use tokio::sync::OnceCell;

#[derive(Clone)]
pub struct DB {
  pool: Pool<Postgres>,
}

static GLOBAL_POOL: OnceCell<Pool<Postgres>> = OnceCell::const_new();

impl DB {
  /// Create a pooled Postgres connection
  pub async fn new() -> Result<Self, sqlx::Error> {
    let pool = GLOBAL_POOL
      .get_or_try_init(|| async {
        // Fallback: intenta cargar .env si aún no se cargó
        let _ = dotenvy::dotenv();

        let database_url =
          env::var("AUTH_DATABASE_URL").expect("AUTH_DATABASE_URL must be set");

        let max_conns: u32 = env::var("MAX_CONNECTIONS")
          .ok()
          .and_then(|v| v.parse().ok())
          .unwrap_or(5);

        PgPoolOptions::new()
          .max_connections(max_conns)
          .connect(&database_url)
          .await
      })
      .await?
      .clone();

    Ok(Self { pool })
  }

  pub fn pool(&self) -> &Pool<Postgres> {
    &self.pool
  }
}