bytes-radar 1.1.0

A tool for analyzing code statistics from remote repositories with hyper-fast performance
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
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

#[cfg(feature = "cli")]
mod args;
#[cfg(feature = "cli")]
mod output;
#[cfg(feature = "cli")]
mod progress;
#[cfg(feature = "cli")]
mod url_parser;

#[cfg(feature = "cli")]
use crate::core::*;
#[cfg(feature = "cli")]
use crate::net::RemoteAnalyzer;
#[cfg(feature = "cli")]
use clap::Parser;
#[cfg(feature = "cli")]
use std::time::Instant;

#[cfg(feature = "cli")]
pub use args::{Cli, OutputFormat};

#[cfg(feature = "cli")]
pub async fn run() -> Result<()> {
    let cli = args::Cli::parse();

    init_logging(&cli)?;

    let mut cli = cli;
    if let Ok(token) = std::env::var("BRADAR_TOKEN") {
        if cli.token.is_none() {
            cli.token = Some(token);
        }
    }

    match &cli.url {
        Some(url) => analyze_remote_archive(url, &cli).await,
        None => {
            url_parser::show_usage_examples();
            std::process::exit(1);
        }
    }
}

#[cfg(feature = "cli")]
fn init_logging(cli: &Cli) -> Result<()> {
    let log_level = if cli.trace {
        "trace"
    } else if cli.debug {
        "debug"
    } else {
        "warn"
    };

    let mut builder =
        env_logger::Builder::from_env(env_logger::Env::default().default_filter_or(log_level));

    if let Some(log_file) = &cli.log_file {
        use std::fs::OpenOptions;

        let target = Box::new(
            OpenOptions::new()
                .create(true)
                .append(true)
                .open(log_file)
                .map_err(|e| crate::core::error::AnalysisError::file_read(log_file, e))?,
        );
        builder.target(env_logger::Target::Pipe(target));
    }

    builder.init();
    Ok(())
}

#[cfg(feature = "cli")]
async fn analyze_remote_archive(url: &str, cli: &Cli) -> Result<()> {
    let should_show_progress =
        !cli.no_progress && matches!(cli.format, OutputFormat::Table) && !cli.quiet;

    let processed_url = url_parser::expand_url(url);

    if should_show_progress && !cli.quiet {
        println!("Analyzing: {}", processed_url);
    }

    let start_time = Instant::now();
    let progress_bar = progress::create_progress_bar(should_show_progress);

    let mut analyzer = RemoteAnalyzer::new();

    if let Some(token) = &cli.token {
        let mut credentials = std::collections::HashMap::new();
        credentials.insert("token".to_string(), token.clone());
        analyzer.set_provider_credentials("github", credentials);
    }

    analyzer.set_timeout(cli.timeout);
    analyzer.set_allow_insecure(cli.allow_insecure);

    if let Some(pb) = progress_bar.clone() {
        analyzer.set_progress_hook(progress::ProgressBarHook::new(pb));
    }

    configure_analyzer_filters(&mut analyzer, cli)?;

    let project_analysis = analyzer.analyze_url(&processed_url).await?;

    let elapsed = start_time.elapsed();

    if let Some(pb) = &progress_bar {
        pb.finish_and_clear();
    }

    progress::show_completion_message(elapsed, cli.quiet);

    output_results(&project_analysis, cli)?;

    Ok(())
}

#[cfg(feature = "cli")]
fn configure_analyzer_filters(analyzer: &mut RemoteAnalyzer, cli: &Cli) -> Result<()> {
    if cli.aggressive_filter {
        analyzer.set_aggressive_filtering(true);
    } else {
        let filter = filter::IntelligentFilter {
            max_file_size: cli.max_file_size * 1024,
            ignore_test_dirs: !cli.include_tests,
            ignore_docs_dirs: !cli.include_docs,
            ..filter::IntelligentFilter::default()
        };

        analyzer.set_filter(filter);
    }

    Ok(())
}

#[cfg(feature = "cli")]
fn output_results(project_analysis: &analysis::ProjectAnalysis, cli: &Cli) -> Result<()> {
    match cli.format {
        OutputFormat::Table => {
            output::print_table_format(project_analysis, cli.detailed, cli.quiet);
        }
        OutputFormat::Json => output::print_json_format(project_analysis)?,
        OutputFormat::Csv => output::print_csv_format(project_analysis)?,
        OutputFormat::Xml => output::print_xml_format(project_analysis)?,
        OutputFormat::Yaml => output::print_yaml_format(project_analysis)?,
        OutputFormat::Toml => output::print_toml_format(project_analysis)?,
    }

    Ok(())
}