Method execute_parallel

src/parallel_executor.rs:152–377

Execute Nuclei scan with parallel batching

(
        &self,
        targets: Vec<String>,
        output_dir: &Path,
        severities: &str,
    )

    /// Execute Nuclei scan with parallel batching
    pub async fn execute_parallel(
        &self,
        targets: Vec<String>,
        output_dir: &Path,
        severities: &str,
    ) -> Result<usize> {
        if targets.is_empty() {
            return Ok(0);
        }

        let total_targets = targets.len();
        self.total.store(total_targets, Ordering::SeqCst);

        let mode_indicator = if self.config.turbo_mode {
            "🔥 TURBO MODE".red().bold().to_string()
        } else if self.config.rate_limit == 0 {
            "⚡ AGGRESSIVE".yellow().bold().to_string()
        } else {
            "🎯 STANDARD".cyan().to_string()
        };

        println!("{}", format!(
            "┌───────────────────────────────────────────────────────────────────────────────┐"
        ).cyan().bold());
        if self.config.turbo_mode {
            println!("{}", format!(
                "│  🔥 PARALLEL NUCLEI EXECUTOR - TURBO MODE                                     │"
            ).red().bold());
        } else {
            println!("{}", format!(
                "│  🚀 PARALLEL NUCLEI EXECUTOR                                                  │"
            ).cyan().bold());
        }
        println!("{}", format!(
            "├───────────────────────────────────────────────────────────────────────────────┤"
        ).cyan());
        println!("{}", format!(
            "│  📊 Total targets: {:<58}│", total_targets
        ).cyan());
        println!("{}", format!(
            "│  👷 Workers: {:<64}│", self.config.nuclei_workers
        ).cyan());
        println!("{}", format!(
            "│  📦 Batch size: {:<61}│", self.config.nuclei_batch_size
        ).cyan());
        println!("{}", format!(
            "│  ⚡ Concurrency per worker: {:<50}│", self.config.nuclei_concurrency
        ).cyan());
        println!("{}", format!(
            "│  📤 Bulk size: {:<62}│", self.config.nuclei_bulk_size
        ).cyan());
        println!("{}", format!(
            "│  🎚️  Rate limit: {}/s{:<53}│",
            if self.config.rate_limit == 0 { "UNLIMITED".to_string() } else { self.config.rate_limit.to_string() },
            ""
        ).cyan());
        println!("{}", format!(
            "│  ⏱️  Timeout: {}s | Retries: {} | Max errors: {}{:<30}│",