arcula 1.0.3

Arcula - MongoDB database synchronization tool
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

use anyhow::Result;
use colored::Colorize;
use log::info;

use crate::config::MongoConfig;
use crate::utils::mongodb;

pub async fn execute() -> Result<()> {
    info!("Displaying MongoDB environment information");

    // Dynamically get all available environments from environment variables
    let environments = crate::config::get_available_environments();

    println!("\n{}", "MongoDB Environments:".bold().underline());

    if environments.is_empty() {
        println!("\n{}", "No MongoDB environments configured.".yellow());
        println!("Configure environments by setting environment variables like:");
        println!("  MONGO_LOCAL_URI=mongodb://localhost:27017");
        println!("  MONGO_DEV_URI=mongodb://user:password@dev.example.com:27017");
        println!("  MONGO_GIO_URI=mongodb://user:password@gio.example.com:27017");
        return Ok(());
    }

    for env in environments {
        match MongoConfig::from_env(env.clone()) {
            Ok(config) => {
                println!(
                    "\n{} {}",
                    "Environment:".green().bold(),
                    env.to_string().bold()
                );
                println!(
                    "{} {}",
                    "Connection:".yellow(),
                    mask_connection_string(&config.connection_string)
                );

                match mongodb::list_databases(&config).await {
                    Ok(databases) => {
                        println!("{} {}", "Databases:".yellow(), databases.len());
                        for db in databases {
                            if !should_skip_db(&db) {
                                println!("  - {}", db);
                            }
                        }
                    }
                    Err(e) => {
                        println!("{} Could not list databases: {}", "Error:".red().bold(), e);
                    }
                }
            }
            Err(_) => {
                println!(
                    "\n{} {}",
                    "Environment:".green().bold(),
                    env.to_string().bold()
                );
                println!("{} {}", "Status:".yellow(), "Not configured".red());
            }
        }
    }

    println!(
        "\n{}",
        "To configure additional environments, set environment variables in the format:".italic()
    );
    println!("  MONGO_<ENV>_URI=mongodb://...  (e.g. MONGO_GIO_URI)");
    println!();

    Ok(())
}

fn mask_connection_string(uri: &str) -> String {
    // Basic masking of connection string to hide sensitive details
    let parts: Vec<&str> = uri.split('@').collect();
    if parts.len() > 1 {
        return format!("mongodb://*****@{}", parts[1]);
    }
    "mongodb://*****".to_string()
}

fn should_skip_db(db_name: &str) -> bool {
    // Skip system databases
    matches!(db_name, "admin" | "local" | "config")
}