anzar-cli 0.9.21

Anzar is a lightweight authentication and authorization framework that runs as a separate microservice
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

use crate::{
    error::Result,
    shared::{constants, support},
};
use std::{
    fs,
    path::Path,
    sync::atomic::{AtomicU16, Ordering},
};

use owo_colors::OwoColorize;
use shared::config::{AuthStrategy, database::DatabaseDriver};

pub fn run() -> Result<()> {
    let config = support::load_config()?;

    if config.database.driver == DatabaseDriver::MongoDB {
        support::print_result(
            "MongoDB is not supported",
            false,
            Some("switch to SQLite or PostgreSQL in anzar.yml"),
        );
        return Ok(());
    }

    let migrations_dir = Path::new("migrations");
    fs::create_dir_all(migrations_dir)?;

    // Check for existing anzar migrations
    let already_exists = fs::read_dir(migrations_dir)
        .map(|entries| {
            entries
                .filter_map(|e| e.ok())
                .any(|e| e.file_name().to_string_lossy().contains("anzar_create_"))
        })
        .unwrap_or(false);

    if already_exists {
        support::print_result(
            "Migrations already exist",
            false,
            Some("delete existing anzar_create_* files to regenerate"),
        );
        return Ok(());
    }

    let files = match config.auth.strategy {
        AuthStrategy::Session(..) => constants::session_tables(config.database.driver),
        AuthStrategy::Jwt(..) => constants::jwt_tables(config.database.driver),
    };

    println!();
    for (content, name) in files {
        static COUNTER: AtomicU16 = AtomicU16::new(0);
        let cnt = COUNTER.fetch_add(1, Ordering::Relaxed) % 10000;
        let timestamp = format!("{}{:04}", chrono::Utc::now().format("%Y%m%d%H%M%S"), cnt);

        let filename = format!("{}/{}_{}.sql", migrations_dir.display(), timestamp, name);
        match fs::write(&filename, content) {
            Ok(_) => println!("{} {}", "✔ Created".green().bold(), filename.cyan()),
            Err(e) => eprintln!("{} {}", "✗ Failed to create file:".red().bold(), e),
        }
    }

    println!();
    println!(
        "  {} run {} to apply",
        "→".cyan().bold(),
        "anzar migrate".cyan()
    );

    Ok(())
}