import json
import pathlib
import shutil
import subprocess

from . import logger, util


def is_valid_repo(repo: pathlib.Path) -> bool:
    # We don't care about failures (we consider it False)
    ret = subprocess.run(
        ['git', '-C', str(repo / '.git'), 'rev-parse', '--is-inside-git-dir'],
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,  # Just to kill the output in case of error
    )
    return ret.stdout.strip() == b'true'


def fetch_rust_repo() -> pathlib.Path:
    repo_path = util.cache_dir() / 'rust'
    if not is_valid_repo(repo_path):
        subprocess.check_call(
            [
                'git',
                'clone',
                'https://github.com/rust-lang/rust.git',
                '--filter=blob:none',
                '--no-checkout',
                str(repo_path),
            ],
        )
        assert is_valid_repo(repo_path)

    return repo_path


commit_cache_path = util.cache_dir() / 'rust-git-tags.json'
_commit_to_tags = {}
if commit_cache_path.exists():
    try:
        with open(commit_cache_path, 'r') as inp:
            _commit_to_tags = json.load(inp)
    except json.JSONDecodeError:
        logger.error(f'Failed to load {commit_cache_path}')
    else:
        logger.debug(f'Loaded {commit_cache_path}')
else:
    commit_cache_path = util.package_dir() / 'rust-git-tags.json'
    if commit_cache_path.exists():
        try:
            with open(commit_cache_path, 'r') as inp:
                _commit_to_tags = json.load(inp)
        except json.JSONDecodeError:
            logger.error(f'Failed to load {commit_cache_path}')
        else:
            logger.debug(f'Loaded {commit_cache_path}')

if len(_commit_to_tags) == 0:
    logger.error(f'No tags found in {commit_cache_path}. Please run `python3 -m feeds.cli.rust_tags` to generate tags.')

def commit_to_tag(commit_hash: str) -> str:
    return _commit_to_tags.get(commit_hash)

def remove_suffix(input_string, suffix):
    if suffix and input_string.endswith(suffix):
        return input_string[:-len(suffix)]
    return input_string

def remove_prefix(input_string, prefix):
    if prefix and input_string.startswith(prefix):
        return input_string[len(prefix):]
    return input_string

def create_tags_json() -> pathlib.Path:
    try:
        repo = fetch_rust_repo()

        output = subprocess.check_output(
            ["git", "-C", str(repo), "show-ref", "--tags", "-d"],
            text=True
        )
        commits_with_tags = {}

        for line in output.splitlines():
            commit_hash, tag = line.split(" ", 1)
            tag = remove_suffix(tag, '^{}')
            tag = remove_prefix(tag, 'refs/tags/')
            commits_with_tags[commit_hash] = tag

        with open(commit_cache_path, 'w') as outfile:
            json.dump(commits_with_tags, outfile)
            logger.info(f'Created {commit_cache_path}')

        logger.info(f'Removing git clone from {repo}')
        shutil.rmtree(repo)

        return commit_cache_path
    except subprocess.CalledProcessError as e:
        print(f"Error executing git command: {e}")
    except Exception as e:
        print(f"An error occurred: {e}")