Accept JSON db params

fplus-database/src/lib.rs

@@ -1,11 +1,13 @@
 pub mod config;
 pub mod database;
 pub mod models;
+mod types;
 
 use crate::config::get_env_or_throw;
 use once_cell::sync::Lazy;
 use sea_orm::{Database, DatabaseConnection, DbErr};
 use std::sync::Mutex;
+use types::DbConnectParams;
 
 /**
  * The global database connection
@@ -30,15 +32,10 @@ pub fn init() {
  */
 pub async fn setup() -> Result<(), DbErr> {
     let database_url = std::env::var("DB_URL").unwrap_or_else(|_| {
-        format!(
-            "postgres://{}:{}@{}:{}/{}?{}",
-            get_env_or_throw("DB_USER"),
-            urlencoding::encode(&get_env_or_throw("DB_PASS")),
-            get_env_or_throw("DB_HOST"),
-            std::env::var("DB_PORT").unwrap_or("5432".into()),
-            get_env_or_throw("DB_NAME"),
-            std::env::var("DB_OPTIONS").unwrap_or_default()
-        )
+        let params: DbConnectParams =
+            serde_json::from_str(&get_env_or_throw("DB_CONNECT_PARAMS_JSON"))
+                .expect("Invalid JSON in DB_CONNECT_PARAMS_JSON");
+        params.to_url()
     });
     let db_conn = Database::connect(&database_url).await?;
     let mut db_conn_global = DB_CONN.lock().unwrap();