feat: add patroni, enhance database configuration and cluster management (#36)

Author: PierreLeGuen

Cargo.lock

@@ -32,7 +32,15 @@ async fn main() -> anyhow::Result<()> {
 
     tracing::info!(
         "Database: {}:{}/{}",
-        config.database.host,
+        config
+            .database
+            .host
+            .as_deref()
+            .unwrap_or(if !config.database.primary_app_id.is_empty() {
+                &config.database.primary_app_id
+            } else {
+                "localhost"
+            }),
         config.database.port,
         config.database.database
     );

crates/api/src/main.rs

@@ -74,18 +74,26 @@ Tests automatic conversation tracking:
    DATABASE_PASSWORD=your_password
    ```
 
-3. **Valid Session Token**: The tests use `SESSION_TOKEN` constant - ensure you have a valid session in the database
+3. **Test Feature Flag**: Most tests require the `test` feature flag to enable the mock-login endpoint
 
 ### Run All Tests
 
 ```bash
+# Run all tests (including admin tests)
+cargo test --features test
+
 # Run all E2E tests (they make real OpenAI API calls)
-cargo test --test e2e_api_tests -- --ignored --nocapture
+cargo test --test e2e_api_tests --features test -- --ignored --nocapture
+
+# Run admin tests
+cargo test --test admin_tests --features test
 
 # Run a specific test
-cargo test --test e2e_api_tests test_conversation_workflow -- --ignored --nocapture
+cargo test --test e2e_api_tests test_conversation_workflow --features test -- --ignored --nocapture
 ```
 
+**Important**: The `--features test` flag is required for most tests because it enables the `/v1/auth/mock-login` endpoint used for test authentication without requiring real OAuth providers.
+
 ### Test Output
 
 The tests provide detailed output showing:

crates/api/tests/README.md

@@ -2,20 +2,23 @@ use serde::Deserialize;
 
 #[derive(Debug, Clone, Deserialize)]
 pub struct DatabaseConfig {
-    pub host: String,
+    pub host: Option<String>,
     pub port: u16,
     pub database: String,
     pub username: String,
     pub password: String,
     pub max_connections: u32,
     pub tls_enabled: bool,
     pub tls_ca_cert_path: Option<String>,
+    pub primary_app_id: String,
+    pub refresh_interval: u64,
+    pub mock: bool,
 }
 
 impl Default for DatabaseConfig {
     fn default() -> Self {
         Self {
-            host: std::env::var("DATABASE_HOST").unwrap_or_else(|_| "localhost".to_string()),
+            host: std::env::var("DATABASE_HOST").ok(),
             port: std::env::var("DATABASE_PORT")
                 .ok()
                 .and_then(|p| p.parse().ok())
@@ -32,6 +35,15 @@ impl Default for DatabaseConfig {
                 .and_then(|v| v.parse().ok())
                 .unwrap_or(false),
             tls_ca_cert_path: std::env::var("DATABASE_TLS_CA_CERT_PATH").ok(),
+            primary_app_id: std::env::var("DATABASE_PRIMARY_APP_ID").unwrap_or_default(),
+            refresh_interval: std::env::var("DATABASE_REFRESH_INTERVAL")
+                .ok()
+                .and_then(|v| v.parse().ok())
+                .unwrap_or(30),
+            mock: std::env::var("DATABASE_MOCK")
+                .ok()
+                .and_then(|v| v.parse().ok())
+                .unwrap_or(false),
         }
     }
 }

crates/config/src/lib.rs

@@ -51,3 +51,7 @@ refinery = { version = "0.8", features = ["tokio-postgres"] }
 # For hashing API keys and session tokens
 sha2 = "0.10"
 rand = "0.9.2"
+reqwest = { version = "0.12.24", features = ["json", "rustls-tls"] }
+deadpool = "0.12.3"
+native-tls = "0.2.14"
+postgres-native-tls = "0.5.2"