feat: uso global pool connection db

Author: enieber

src/database.rs

@@ -3,8 +3,13 @@ use axum::{
 };
 use mysql::{Opts, Pool};
 use std::env;
+use std::sync::OnceLock;
 
-pub fn connect_to_database() -> Result<mysql::PooledConn, (StatusCode, String)> {
+// Pool global usando OnceLock para inicialização única
+static DB_POOL: OnceLock<Pool> = OnceLock::new();
+
+
+pub fn init_db_pool() -> Result<(), (StatusCode, String)> {
     let db_url = env::var("DB_URL").map_err(|_| {
         (
             StatusCode::INTERNAL_SERVER_ERROR,
@@ -26,14 +31,28 @@ pub fn connect_to_database() -> Result<mysql::PooledConn, (StatusCode, String)>
         )
     })?;
 
-    let conn = pool.get_conn().map_err(|_| {
+    DB_POOL.set(pool).map_err(|_| {
         (
             StatusCode::INTERNAL_SERVER_ERROR,
-            "Falha ao obter conexão do pool".to_string(),
+            "Falha ao configurar o pool global".to_string(),
         )
-    })?;
+    })
+}
+
 
-    Ok(conn)
+
+pub fn connect_to_database() -> Result<mysql::PooledConn, (StatusCode, String)> {
+    let pool = DB_POOL.get().ok_or((
+        StatusCode::INTERNAL_SERVER_ERROR,
+        "Pool de conexões não inicializado".to_string(),
+    ))?;
+
+    pool.get_conn().map_err(|_| {
+        (
+            StatusCode::INTERNAL_SERVER_ERROR,
+            "Falha ao obter conexão do pool".to_string(),
+        )
+    })
 }
 
 

src/main.rs

@@ -45,6 +45,20 @@ async fn main() {
         .with(tracing_subscriber::fmt::layer())
         .init();
 
+    let _db_url = match env::var("DB_URL") {
+        Ok(url) => url,
+        Err(_) => {
+            tracing::info!("error url");
+            panic!("Erro crítico: DB_URL não está configurada");
+           
+        }
+    };
+    // Inicializa o pool de conexões do banco de dados
+    if let Err((status, message)) = database::init_db_pool() {
+        tracing::error!("Falha ao inicializar o pool de banco de dados: {}", message);
+        panic!("Erro crítico: Falha ao inicializar o pool de banco de dados");
+    }
+
     let app = Router::new()
         .route("/api/healthcheck", get(health_check_handler))
         .route("/api/authors", post(add_author))
@@ -56,15 +70,6 @@ async fn main() {
         .layer(middleware::from_fn(validation_fingerprint))
         .layer(middleware::from_fn(error_logging_middleware));
 
-    let _db_url = match env::var("DB_URL") {
-        Ok(url) => url,
-        Err(_) => {
-            tracing::info!("error url");
-            panic!("Erro crítico: DB_URL não está configurada");
-           
-        }
-    };
-
     let _api_token = match env::var("API_TOKEN") {
         Ok(url) => url,
         Err(_) => {