bytes-radar 1.1.0

use crate::net::traits::{GitProvider, ParsedRepository, ProviderConfig};
use async_trait::async_trait;
use reqwest::Client;
use std::collections::HashMap;

pub struct BitbucketProvider {
    credentials: HashMap<String, String>,
}

impl BitbucketProvider {
    pub fn new() -> Self {
        Self {
            credentials: HashMap::new(),
        }
    }
}

#[async_trait]
impl GitProvider for BitbucketProvider {
    fn name(&self) -> &'static str {
        "bitbucket"
    }

    fn can_handle(&self, url: &str) -> bool {
        url.contains("bitbucket.org")
    }

    fn parse_url(&self, url: &str) -> Option<ParsedRepository> {
        if !self.can_handle(url) {
            return None;
        }

        let url = url.trim_end_matches('/');

        if url.contains("/commits/") {
            return self.parse_commit_url(url);
        }

        if url.contains("/branch/") {
            return self.parse_branch_url(url);
        }

        self.parse_basic_url(url)
    }

    fn build_download_urls(&self, parsed: &ParsedRepository) -> Vec<String> {
        let mut urls = Vec::new();

        if let Some(ref branch_or_commit) = parsed.branch_or_commit {
            urls.push(format!(
                "https://bitbucket.org/{}/{}/get/{}.tar.gz",
                parsed.owner, parsed.repo, branch_or_commit
            ));
        }

        urls
    }

    async fn get_default_branch(
        &self,
        _client: &Client,
        _parsed: &ParsedRepository,
    ) -> Option<String> {
        None
    }

    fn apply_config(&mut self, config: &ProviderConfig) {
        self.credentials = config.credentials.clone();
    }

    fn get_project_name(&self, url: &str) -> String {
        if let Some(parsed) = self.parse_url(url) {
            return parsed.project_name;
        }

        if let Some(filename) = url.split('/').next_back() {
            if filename.ends_with(".tar.gz") {
                return filename.trim_end_matches(".tar.gz").to_string();
            }
            if filename.ends_with(".tgz") {
                return filename.trim_end_matches(".tgz").to_string();
            }
            return filename.to_string();
        }

        "bitbucket-project".to_string()
    }
}

impl BitbucketProvider {
    fn parse_commit_url(&self, url: &str) -> Option<ParsedRepository> {
        let parts: Vec<&str> = url.split('/').collect();
        if let Some(commits_pos) = parts.iter().position(|&x| x == "commits") {
            if commits_pos + 1 < parts.len() && commits_pos >= 2 {
                let owner = parts[commits_pos - 2].to_string();
                let repo = parts[commits_pos - 1].to_string();
                let commit = parts[commits_pos + 1].to_string();

                return Some(
                    ParsedRepository::new(owner, repo)
                        .with_commit(commit)
                        .with_host("bitbucket.org".to_string()),
                );
            }
        }
        None
    }

    fn parse_branch_url(&self, url: &str) -> Option<ParsedRepository> {
        let parts: Vec<&str> = url.split('/').collect();
        if let Some(branch_pos) = parts.iter().position(|&x| x == "branch") {
            if branch_pos + 1 < parts.len() && branch_pos >= 2 {
                let owner = parts[branch_pos - 2].to_string();
                let repo = parts[branch_pos - 1].to_string();
                let branch = parts[branch_pos + 1].to_string();

                return Some(
                    ParsedRepository::new(owner, repo)
                        .with_branch(branch)
                        .with_host("bitbucket.org".to_string()),
                );
            }
        }
        None
    }

    fn parse_basic_url(&self, url: &str) -> Option<ParsedRepository> {
        let parts: Vec<&str> = url.split('/').collect();
        if let Some(bitbucket_pos) = parts.iter().position(|&x| x == "bitbucket.org") {
            if bitbucket_pos + 2 < parts.len() {
                let owner = parts[bitbucket_pos + 1].to_string();
                let repo = parts[bitbucket_pos + 2].to_string();

                return Some(
                    ParsedRepository::new(owner, repo).with_host("bitbucket.org".to_string()),
                );
            }
        }
        None
    }
}

impl Default for BitbucketProvider {
    fn default() -> Self {
        Self::new()
    }
}

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

    #[test]
    fn test_can_handle() {
        let provider = BitbucketProvider::new();
        assert!(provider.can_handle("https://bitbucket.org/user/repo"));
        assert!(provider.can_handle("https://bitbucket.org/user/repo/commits/abc123"));
        assert!(!provider.can_handle("https://github.com/user/repo"));
    }

    #[test]
    fn test_parse_basic_url() {
        let provider = BitbucketProvider::new();

        let parsed = provider
            .parse_url("https://bitbucket.org/user/repo")
            .unwrap();
        assert_eq!(parsed.owner, "user");
        assert_eq!(parsed.repo, "repo");
        assert_eq!(parsed.project_name, "repo@main");
        assert_eq!(parsed.branch_or_commit, None);
        assert!(!parsed.is_commit);
        assert_eq!(parsed.host.as_ref().unwrap(), "bitbucket.org");
    }

    #[test]
    fn test_parse_branch_url() {
        let provider = BitbucketProvider::new();

        let parsed = provider
            .parse_url("https://bitbucket.org/user/repo/branch/develop")
            .unwrap();
        assert_eq!(parsed.owner, "user");
        assert_eq!(parsed.repo, "repo");
        assert_eq!(parsed.project_name, "repo@develop");
        assert_eq!(parsed.branch_or_commit, Some("develop".to_string()));
        assert!(!parsed.is_commit);
    }

    #[test]
    fn test_parse_commit_url() {
        let provider = BitbucketProvider::new();

        let parsed = provider
            .parse_url("https://bitbucket.org/user/repo/commits/abc1234567890")
            .unwrap();
        assert_eq!(parsed.owner, "user");
        assert_eq!(parsed.repo, "repo");
        assert_eq!(parsed.project_name, "repo@abc1234");
        assert_eq!(parsed.branch_or_commit, Some("abc1234567890".to_string()));
        assert!(parsed.is_commit);
    }

    #[test]
    fn test_build_download_urls() {
        let provider = BitbucketProvider::new();

        let parsed = ParsedRepository::new("user".to_string(), "repo".to_string())
            .with_branch("main".to_string());

        let urls = provider.build_download_urls(&parsed);
        assert!(urls.contains(&"https://bitbucket.org/user/repo/get/main.tar.gz".to_string()));
    }
}