litvc 1.3.1

use crate::core::find_repo_root;
use crate::core::ObjectHash;
use crate::network::transport::RemoteRepo;
use crate::network::AirgapValidator;
use crate::response::PushResponse;
use crate::storage::ObjectStore;
use std::collections::HashSet;

pub fn execute(
    remote: String,
    branch: String,
    force: bool,
) -> Result<PushResponse, crate::errors::LitError> {
    let repo_root = find_repo_root()?;
    let remote_url = get_remote_url(&repo_root, &remote)?;

    let validator = AirgapValidator::new()?;
    validator.validate_transport(&remote_url)?;

    let remote_repo = RemoteRepo::open(&remote_url)?;

    // Get local branch tip
    let local_hash = crate::core::refs::read_ref(&repo_root, &format!("heads/{}", branch))
        .map_err(|_| format!("Branch '{}' not found locally", branch))?;

    let local_store = ObjectStore::new(&repo_root);

    // Check if branch exists on remote
    let remote_has_branch = remote_repo.read_branch_ref(&branch).ok();

    // Fast-forward check
    if let Some(ref remote_hash) = remote_has_branch {
        if remote_hash == &local_hash {
            return Ok(PushResponse {
                remote: remote.clone(),
                branch: branch.clone(),
                objects_transferred: 0,
                updated: false,
                message: "Everything up-to-date".to_string(),
            });
        }

        if !force {
            let remote_obj = ObjectHash::from_hex(remote_hash.clone());
            let local_obj = ObjectHash::from_hex(local_hash.clone());
            let is_ff = remote_repo.check_fast_forward(&local_store, &local_obj, &remote_obj)?;
            if !is_ff {
                return Err(
                    "Push rejected: non-fast-forward update. Use --force to override.".into(),
                );
            }
        }
    }

    // Walk local commit graph to find objects to transfer
    let remote_known: HashSet<String> = if let Some(ref rh) = remote_has_branch {
        let mut set = HashSet::new();
        set.insert(rh.clone());
        set
    } else {
        HashSet::new()
    };

    let needed = remote_repo.negotiate_upload(
        &local_store,
        std::slice::from_ref(&local_hash),
        &remote_known,
    )?;

    // Transfer objects from local to remote
    let transferred = remote_repo.upload_objects(&local_store, &needed)?;

    // Update remote's branch ref
    remote_repo.update_branch_ref(&branch, &local_hash, force)?;

    // Update local remote-tracking ref
    crate::network::transport::update_remote_tracking_ref(
        &repo_root,
        &remote,
        &branch,
        &local_hash,
    )?;

    let range = if let Some(old) = remote_has_branch {
        format!(
            "{}..{}",
            &old[..16.min(old.len())],
            &local_hash[..16.min(local_hash.len())]
        )
    } else {
        format!("[new branch] -> {}", branch)
    };

    Ok(PushResponse {
        remote: remote.clone(),
        branch: branch.clone(),
        objects_transferred: transferred,
        updated: true,
        message: format!(
            "To {}\n  {} {} objects transferred",
            remote_url, range, transferred
        ),
    })
}

fn get_remote_url(
    repo_root: &std::path::Path,
    remote_name: &str,
) -> Result<String, crate::errors::LitError> {
    use serde::{Deserialize, Serialize};
    use std::collections::HashMap;
    use std::fs;

    #[derive(Debug, Deserialize, Serialize)]
    struct Remote {
        url: String,
    }

    #[derive(Debug, Deserialize, Serialize)]
    struct RemoteConfig {
        remotes: HashMap<String, Remote>,
    }

    let config_path = repo_root.join(".lit").join("remotes");

    if !config_path.exists() {
        return Err(format!(
            "No remotes configured. Use 'lit remote add {} <url>'",
            remote_name
        )
        .into());
    }

    let content = fs::read_to_string(&config_path)
        .map_err(|e| format!("Failed to read remotes config: {}", e))?;

    let config: RemoteConfig = serde_json::from_str(&content)
        .map_err(|e| format!("Failed to parse remotes config: {}", e))?;

    config
        .remotes
        .get(remote_name)
        .map(|r| r.url.clone())
        .ok_or_else(|| format!("Remote '{}' not found", remote_name).into())
}