rustminidb 0.2.0

A lightweight embedded database with native REST API
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
//! 启动横幅与视觉输出
//!
//! 提供 ANSI 彩色启动横幅、Logo 以及服务器信息面板。
//! 自动检测终端色彩支持并降级为纯文本。

use std::time::Instant;

use std::io::IsTerminal;

// ── ANSI Escape Codes ───────────────────────────────────

const RESET: &str = "\x1b[0m";
const BOLD: &str = "\x1b[1m";
const DIM: &str = "\x1b[2m";

const FG_CYAN: &str = "\x1b[36m";
const FG_GREEN: &str = "\x1b[32m";
const FG_YELLOW: &str = "\x1b[33m";
const FG_MAGENTA: &str = "\x1b[35m";
const FG_WHITE: &str = "\x1b[37m";
const FG_BLUE: &str = "\x1b[34m";

// ── 颜色探测 ────────────────────────────────────────────

/// 检测终端是否支持 ANSI 颜色
fn supports_color() -> bool {
    // 优先检查 NO_COLOR 环境变量
    if std::env::var_os("NO_COLOR").is_some() {
        return false;
    }
    // 检查 RUSTMINIDB_COLOR 环境变量,可强制开启/关闭
    if let Ok(val) = std::env::var("RUSTMINIDB_COLOR") {
        match val.as_str() {
            "0" | "false" | "off" | "no" => return false,
            "1" | "true" | "on" | "yes" => return true,
            _ => {}
        }
    }
    // Windows: 检查终端类型
    #[cfg(windows)]
    {
        // 检查是否支持 VT processing
        if let Ok(output) = std::process::Command::new("cmd")
            .args(["/c", "echo", "%TERM%"])
            .output()
        {
            let term = String::from_utf8_lossy(&output.stdout);
            if term.trim().contains("xterm") || term.trim().contains("cygwin") {
                return true;
            }
        }
        // 默认 Windows 10+ 新终端都支持
        return true;
    }
    #[cfg(not(windows))]
    {
        std::env::var("TERM")
            .ok()
            .map(|t| t != "dumb")
            .unwrap_or(false)
    }
}

/// 检查输出是否被重定向到管道/文件
fn is_pipe_output() -> bool {
    std::io::stdout().is_terminal()
}

/// 外部模块可调用,判断是否应该使用颜色
pub fn use_color() -> bool {
    supports_color() && is_pipe_output()
}

// ── Logo 定义 ───────────────────────────────────────────

/// 大号 "R" 科技感图标(标志性主视觉)
const LOGO_M_ART: &str = r#"
    ██████╗
    ██╔══██╗
    ██████╔╝
    ██╔══██╗
    ██║  ██║
    ╚═╝  ╚═╝
"#;

/// 完整 Logo 面板 — 现代科技感 "RustMinidb" 块状字标
const LOGO_ART: &str = r#"
  ╔══════════════════════════════════════════════════════╗
  ║                                                      ║
  ║    ██████╗ ██╗   ██╗███████╗████████╗               ║
  ║    ██╔══██╗██║   ██║██╔════╝╚══██╔══╝               ║
  ║    ██████╔╝██║   ██║███████╗   ██║                  ║
  ║    ██╔══██╗██║   ██║╚════██║   ██║                  ║
  ║    ██║  ██║╚██████╔╝███████║   ██║                  ║
  ║    ╚═╝  ╚═╝ ╚═════╝ ╚══════╝   ╚═╝                  ║
  ║                                                      ║
  ║    ███╗   ███╗██╗███╗   ██╗██╗██████╗ ██████╗       ║
  ║    ████╗ ████║██║████╗  ██║██║██╔══██╗██╔══██╗      ║
  ║    ██╔████╔██║██║██╔██╗ ██║██║██████╔╝██████╔╝      ║
  ║    ██║╚██╔╝██║██║██║╚██╗██║██║██╔══██╗██╔══██╗      ║
  ║    ██║ ╚═╝ ██║██║██║ ╚████║██║██████╔╝██████╔╝      ║
  ║    ╚═╝     ╚═╝╚═╝╚═╝  ╚═══╝╚═╝╚═════╝ ╚═════╝       ║
  ║                                                      ║
  ╚══════════════════════════════════════════════════════╝
"#;

/// 紧凑版 Logo(终端宽度有限时使用)
const LOGO_COMPACT: &str = r#"
   _  _  __  __  _  _  ___  _  _  ___
  | \| |/ _\ \/ / | \| | _ \| \| | _ \
  | .` | (_ >  <  | .` |   /| .` |  _/
  |_|\_|\___/_/\_\|_|\_|_|_\|_|\_|_|
"#;

/// 生成彩色渐变的 "R" 科技图标
fn colored_m_logo() -> String {
    if !use_color() {
        return LOGO_M_ART.to_string();
    }

    let lines: Vec<&str> = LOGO_M_ART.lines().collect();
    // 科技感渐变色:深蓝 → 青 → 紫
    let colors = [FG_BLUE, FG_CYAN, FG_MAGENTA, FG_CYAN, FG_BLUE, FG_MAGENTA];
    let mut out = String::new();
    for (i, line) in lines.iter().enumerate() {
        let color = colors[i.min(colors.len() - 1)];
        out.push_str(&format!("{}{}{}\n", color, line, RESET));
    }
    out
}

/// 生成彩色渐变的完整 Logo(科技感配色)
fn colored_logo() -> String {
    if !use_color() {
        return LOGO_ART.to_string();
    }

    let lines: Vec<&str> = LOGO_ART.lines().collect();
    // 科技感渐变色:边框深蓝 → Rust 段青绿 → 分隔冰蓝 → Minidb 段紫青
    let colors = [
        FG_CYAN,    // 1. 顶部边框
        FG_CYAN,    // 2. 空行
        FG_CYAN,    // 3. Rust: R
        FG_CYAN,    // 4. Rust: u
        FG_BLUE,    // 5. Rust: s
        FG_BLUE,    // 6. Rust: t
        FG_BLUE,    // 7. Rust end
        FG_MAGENTA, // 8. Rust bottom
        FG_CYAN,    // 9. 分隔行
        FG_MAGENTA, // 10. Minidb: M
        FG_MAGENTA, // 11. Minidb: i
        FG_BLUE,    // 12. Minidb: n
        FG_BLUE,    // 13. Minidb: i
        FG_CYAN,    // 14. Minidb: d
        FG_CYAN,    // 15. Minidb: b
        FG_CYAN,    // 16. 空行
        FG_CYAN,    // 17. 底部边框
    ];
    let mut out = String::new();
    for (i, line) in lines.iter().enumerate() {
        let color = colors[i.min(colors.len() - 1)];
        out.push_str(&format!("{}{}{}\n", color, line, RESET));
    }
    out
}

/// 只打印大号 "M" 图标(极简模式)
pub fn print_m_icon() {
    if use_color() {
        print!("{}", colored_m_logo());
    } else {
        print!("{}", LOGO_M_ART);
    }
}

/// 打印完整的启动欢迎画面(详细模式 - 默认)
pub fn print_banner() {
    println!("{}", banner_text());
}

/// 返回增强版的 Banner 文本(含系统和版本信息)
pub fn banner_text() -> String {
    let version = crate::version();
    logo_with_info(version, true)
}

/// 仅打印简短的启动信息行(用于非交互式 / 管道模式)
pub fn print_info_line() {
    let version = crate::version();
    if use_color() {
        println!(
            "{}██╗  ██╗ {}RustMinidb v{}{} — Embedded Relational Database (redb, ACID)",
            FG_MAGENTA, FG_GREEN, version, RESET
        );
    } else {
        println!("M  RustMinidb v{} — Embedded Relational Database (redb, ACID)", version);
    }
}

/// 返回带系统信息的 Banner 面板
pub fn banner_text_detailed(version: &str, features: &[&str]) -> String {
    logo_with_info(version, true)
        + "\n"
        + &system_info_panel(version, features)
        + "\n"
        + &features_panel(features)
}

/// 返回简洁版的欢迎字符串(无颜色)
pub fn banner_text_compact() -> String {
    let version = crate::version();
    format!(
        r#"
{}
 RustMinidb v{}  —  Embedded Relational Database
 Homepage: https://rustminidb.dev   License: BSL-1.1
"#,
        LOGO_COMPACT, version
    )
}

// ── 内部构造器 ──

fn logo_with_info(version: &str, detailed: bool) -> String {
    let logo = if use_color() && detailed {
        colored_logo()
    } else if detailed {
        LOGO_ART.to_string()
    } else {
        LOGO_COMPACT.to_string()
    };

    if !detailed {
        return format!(
            "{}\n RustMinidb v{}  —  Embedded Relational Database\n",
            logo, version
        );
    }

    let info_line = if use_color() {
        format!(
            " {FG_MAGENTA}{RESET}{BOLD} RustMinidb v{version}{RESET}{DIM} — Embedded Relational Database{RESET}\n \
             {DIM}  Homepage: https://rustminidb.dev   License: BSL-1.1{RESET}\n \
             {DIM}  Storage: redb (single-file, ACID, MVCC){RESET}",
        )
    } else {
        format!(
            " ◈ RustMinidb v{} — Embedded Relational Database\n \
               Homepage: https://rustminidb.dev   License: BSL-1.1\n \
               Storage: redb (single-file, ACID, MVCC)",
            version
        )
    };

    format!("{}\n{}\n", logo, info_line)
}

fn system_info_panel(version: &str, features: &[&str]) -> String {
    let mut panel = String::new();
    let border = if use_color() { format!("{}━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━{}", FG_CYAN, RESET) } else { "".repeat(48) };
    panel.push_str(&format!("  {}\n", border));
    panel.push_str(&format!(
        "   {}System Information{}\n",
        if use_color() { format!("{}{}", BOLD, FG_YELLOW) } else { "".to_string() },
        RESET
    ));
    panel.push_str(&format!("  {}\n", border));
    panel.push_str(&format!("    Version         :  {}\n", version));
    panel.push_str(&format!("    Storage Engine  :  redb (single-file, ACID)\n"));
    panel.push_str(&format!("    Platform        :  {}\n", std::env::consts::OS));
    panel.push_str(&format!("    Architecture    :  {}\n", std::env::consts::ARCH));
    panel.push_str(&format!("    Features        :  {}\n", features.join(", ")));
    panel.push_str(&format!("  {}\n", border));
    panel
}

fn features_panel(features: &[&str]) -> String {
    let mut panel = String::new();
    if features.is_empty() {
        return panel;
    }
    let check = if use_color() {
        format!("{}{}", FG_GREEN, RESET)
    } else {
        "".to_string()
    };
    panel.push_str(&format!("  {}Enabled Features{}\n",
        if use_color() { BOLD } else { "" },
        RESET
    ));
    for feat in features {
        panel.push_str(&format!("    {}  {}\n", check, feat));
    }
    panel
}

// ── 全局启动时间跟踪 ──

static mut START_INSTANT: Option<Instant> = None;

/// 记录进程启动时间(应在 main() 最开头调用)
pub fn record_start_time() {
    // safe: 仅在主线程初始化时调用一次
    #[allow(static_mut_refs)]
    unsafe {
        START_INSTANT = Some(Instant::now());
    }
}

/// 返回自 record_start_time() 以来的启动耗时,单位毫秒
pub fn startup_elapsed_ms() -> u64 {
    #[allow(static_mut_refs)]
    unsafe {
        START_INSTANT
            .map(|t| t.elapsed().as_millis() as u64)
            .unwrap_or(0)
    }
}

// ── 打印带耗时统计的启动完成消息 ──

/// 打印启动完成信息(包含总耗时)
pub fn print_startup_complete(addr: Option<&str>) {
    let elapsed = startup_elapsed_ms();
    let elapsed_str = format!("{:.2}s", elapsed as f64 / 1000.0);

    if let Some(a) = addr {
        if use_color() {
            println!(
                "\n {}{} Server listening on {}{}{} (startup: {}{}{})\n",
                FG_GREEN, RESET,
                BOLD, a, RESET,
                FG_YELLOW, elapsed_str, RESET
            );
        } else {
            println!("\n ✔ Server listening on {} (startup: {})\n", a, elapsed_str);
        }
    } else {
        if use_color() {
            println!(
                "\n {}{} RustMinidb ready (startup: {}{}{})\n",
                FG_GREEN, RESET,
                FG_YELLOW, elapsed_str, RESET
            );
        } else {
            println!("\n ✔ RustMinidb ready (startup: {})\n", elapsed_str);
        }
    }
}

/// 打印运行时的 HTTP 服务信息面板
pub fn print_server_info(host: &str, port: u16, db_name: &str) {
    // 先打印大号 "M" 图标
    let version = crate::version();
    println!();
    if use_color() {
        println!(
            "  {}╔══════════════════════════════════════════════════╗{}",
            FG_MAGENTA, RESET
        );
        println!(
            "  {}{}              {}{}M{} DB Server{}               {}{}",
            FG_MAGENTA, RESET,
            BOLD, FG_CYAN, RESET, BOLD, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}     RustMinidb — Lightweight Embedded DB      {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}╠══════════════════════════════════════════════════╣{}",
            FG_MAGENTA, RESET
        );
        println!(
            "  {}{}  Version:  {:<38} {}{}",
            FG_MAGENTA, RESET,
            version,
            FG_MAGENTA, RESET
        );
        println!(
            "  {}{}  Server:   http://{}:{:<29} {}{}",
            FG_MAGENTA, RESET, host, port, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}  Database: {:<39} {}{}",
            FG_MAGENTA, RESET, db_name, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}  Storage:  redb (ACID, single-file)           {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}╠══════════════════════════════════════════════════╣{}",
            FG_MAGENTA, RESET
        );
        println!(
            "  {}{}  API Endpoints:                                  {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /              - Web Admin UI            {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    POST /v1/query      - Execute SQL             {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /v1/health     - Health check            {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /v1/tables     - List tables             {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /v1/schema/{{t}} - Table schema          {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /v1/export     - Export SQL              {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}{}    GET  /v1/metrics    - Server metrics          {}{}",
            FG_MAGENTA, RESET, FG_MAGENTA, RESET
        );
        println!(
            "  {}╚══════════════════════════════════════════════════╝{}",
            FG_MAGENTA, RESET
        );
    } else {
        println!("  ╔══════════════════════════════════════════════════╗");
        println!("  ║                M DB Server                      ║");
        println!("  ║     RustMinidb — Lightweight Embedded DB        ║");
        println!("  ╠══════════════════════════════════════════════════╣");
        println!("  ║  Version:  {:<38}║", version);
        println!("  ║  Server:   http://{}:{:<29}║", host, port);
        println!("  ║  Database: {:<39}║", db_name);
        println!("  ║  Storage:  redb (ACID, single-file)             ║");
        println!("  ╠══════════════════════════════════════════════════╣");
        println!("  ║  API Endpoints:                                  ║");
        println!("  ║    GET  /              - Web Admin UI            ║");
        println!("  ║    POST /v1/query      - Execute SQL             ║");
        println!("  ║    GET  /v1/health     - Health check            ║");
        println!("  ║    GET  /v1/tables     - List tables             ║");
        println!("  ║    GET  /v1/schema/{{t}} - Table schema          ║");
        println!("  ║    GET  /v1/export     - Export SQL              ║");
        println!("  ║    GET  /v1/metrics    - Server metrics          ║");
        println!("  ╚══════════════════════════════════════════════════╝");
    }
    println!();
}


/// 打印认证状态信息
pub fn print_auth_status(enabled: bool) {
    if enabled {
        if use_color() {
            println!(
                "  {}{} {}API Authentication: ENABLED{} (Bearer Token required)",
                FG_GREEN, RESET, BOLD, RESET
            );
        } else {
            println!("  ✓ API Authentication: ENABLED (Bearer Token required)");
        }
    } else {
        if use_color() {
            println!(
                "  {}{} {}API Authentication: DISABLED{} (set --api-token or RUSTMINIDB_API_TOKEN)",
                FG_YELLOW, RESET, DIM, RESET
            );
        } else {
            println!("  ⚠ API Authentication: DISABLED (set --api-token or RUSTMINIDB_API_TOKEN)");
        }
    }
    println!();
}

// ── 测试 ──

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_banner_contains_version() {
        let text = banner_text();
        assert!(text.contains(crate::version()));
        assert!(text.contains("RustMinidb"));
        assert!(text.contains("redb"));
    }

    #[test]
    fn test_banner_non_empty() {
        assert!(!banner_text().is_empty());
    }

    #[test]
    fn test_banner_compact_non_empty() {
        let text = banner_text_compact();
        assert!(!text.is_empty());
        assert!(text.contains(crate::version()));
    }

    #[test]
    fn test_info_line_contains_version() {
        let line = std::panic::catch_unwind(|| print_info_line());
        assert!(line.is_ok());
    }

    #[test]
    fn test_detailed_banner_contains_features() {
        let text = banner_text_detailed(env!("CARGO_PKG_VERSION"), &["server", "shell"]);
        assert!(text.contains("server"));
        assert!(text.contains("shell"));
    }

    #[test]
    fn test_use_color_no_panic() {
        let _ = use_color();
    }

    #[test]
    fn test_server_info_no_panic() {
        print_server_info("0.0.0.0", 8080, "test.db");
    }

    #[test]
    fn test_startup_elapsed() {
        record_start_time();
        assert!(startup_elapsed_ms() >= 0);
    }

    #[test]
    fn test_print_m_icon() {
        print_m_icon();
    }
}