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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

use anyhow::Result;
use clap::{Parser, Subcommand};
use dotenv::dotenv;
use env_logger::Env;

mod commands;
mod config;
mod core;
mod utils;

#[derive(Parser)]
#[command(name = "arcula")]
#[command(about = "Arcula - MongoDB database synchronization tool", long_about = None)]
struct Cli {
    #[command(subcommand)]
    command: Commands,
}

#[derive(Subcommand)]
enum Commands {
    /// Synchronize data between MongoDB environments
    Sync {
        /// Source environment (LOCAL, DEV, STG, PROD)
        #[arg(short, long)]
        from: Option<String>,

        /// Target environment (LOCAL, DEV, STG, PROD)
        #[arg(short, long)]
        to: Option<String>,

        /// Database to synchronize
        #[arg(short, long)]
        db: Option<String>,

        /// Target database name (defaults to source database name)
        #[arg(short = 'n', long)]
        target_db: Option<String>,

        /// Create backup before import
        #[arg(short, long, default_value = "true")]
        backup: Option<bool>,

        /// Drop collections during import
        #[arg(short = 'D', long, default_value = "true")]
        drop: Option<bool>,

        /// Clear collections during import (ignored if drop is enabled)
        #[arg(short = 'c', long, default_value = "false")]
        clear: Option<bool>,

        /// Interactive mode - prompt for values not provided on command line
        #[arg(short, long)]
        interactive: bool,
    },
    /// Show information about available MongoDB environments
    Info,
}

#[tokio::main]
async fn main() -> Result<()> {
    // Initialize environment
    dotenv().ok();
    env_logger::Builder::from_env(Env::default().default_filter_or("info")).init();

    // Check if MongoDB tools are available
    if let Err(err) = config::check_mongodb_tools() {
        eprintln!("Error: MongoDB tools not found. Please install MongoDB tools (mongodump and mongorestore).");
        eprintln!("Error details: {}", err);

        return Err(anyhow::anyhow!("MongoDB tools not found"));
    }

    // Parse CLI arguments
    let cli = Cli::parse();

    // Process commands
    match cli.command {
        Commands::Sync {
            from,
            to,
            db,
            target_db,
            backup,
            drop,
            clear,
            interactive,
        } => {
            let params = commands::sync::SyncParams {
                from,
                to,
                db,
                target_db,
                backup,
                drop,
                clear,
                interactive,
            };
            commands::sync::execute_with_params(params).await?;
        }
        Commands::Info => {
            commands::info::execute().await?;
        }
    }

    Ok(())
}