refactor: move state to core

1 files changed, 16 insertions, 0 deletions

diff --git a/lib/warden-core/src/state/database.rs b/lib/warden-core/src/state/database.rs
new file mode 100644
index 0000000..cf34484
--- /dev/null
+++ b/lib/warden-core/src/state/database.rs
@@ -0,0 +1,16 @@
+use sqlx::PgPool;
+use tracing::{debug, error};
+
+use crate::{WardenError, config::cli::database::Database};
+
+pub async fn connect(config: &Database) -> Result<PgPool, WardenError> {
+    let url = config.get_url()?;
+    let host = url.host_str();
+    debug!(host = host, "connecting to database");
+
+    Ok(sqlx::postgres::PgPoolOptions::new()
+        .max_connections(config.database_pool_size.unwrap_or(10))
+        .connect(url.as_str())
+        .await
+        .inspect_err(|e| error!("{e}"))?)
+}