Method scan_cloud_assets

src/parallel_executor.rs:420–489

Scan for cloud storage assets in parallel

(&self, urls: Vec<String>)

pub struct CloudAsset {
    pub provider: String,
    pub url: String,
    pub bucket_name: String,
    pub is_public: bool,
    pub allows_listing: bool,
    pub status_code: u16,
}

impl ParallelCloudScanner {
    pub fn new(config: ParallelConfig) -> Self {
        let client = Client::builder()
            .timeout(Duration::from_secs(config.timeout_secs))
            .danger_accept_invalid_certs(true)
            .build()
            .unwrap_or_default();

        let workers = config.cloud_workers;
        Self {
            config,
            client,
            semaphore: Arc::new(Semaphore::new(workers)),
        }
    }

    /// Scan for cloud storage assets in parallel
    pub async fn scan_cloud_assets(&self, urls: Vec<String>) -> Vec<CloudAsset> {
        if urls.is_empty() {
            return Vec::new();
        }

        println!("{}", format!(
            "┌───────────────────────────────────────────────────────────────────────────────┐"
        ).cyan().bold());
        println!("{}", format!(
            "│  ☁️  PARALLEL CLOUD SCANNER                                                   │"
        ).cyan().bold());
        println!("{}", format!(
            "├───────────────────────────────────────────────────────────────────────────────┤"
        ).cyan());
        println!("{}", format!(
            "│  📊 URLs to scan: {:<59}│", urls.len()
        ).cyan());
        println!("{}", format!(
            "│  👷 Workers: {:<64}│", self.config.cloud_workers
        ).cyan());
        println!("{}", format!(
            "└───────────────────────────────────────────────────────────────────────────────┘"
        ).cyan().bold());
        println!();

        // Extract potential cloud storage URLs
        let cloud_urls = self.extract_cloud_urls(&urls);

        if cloud_urls.is_empty() {
            println!("{}", "   ℹ️  No cloud storage URLs found".yellow());
            return Vec::new();
        }

        println!("{}", format!("   🔍 Found {} potential cloud URLs", cloud_urls.len()).yellow());