use crate::errors::BridgeError;
use r2x_logger as logger;
use std::fs;
use std::path::{Path, PathBuf};
#[cfg(windows)]
pub const PYTHON_LIB_DIR: &str = "Lib";
#[cfg(unix)]
pub const PYTHON_LIB_DIR: &str = "lib";
#[cfg(windows)]
const PYTHON_BIN_DIR: &str = "Scripts";
#[cfg(unix)]
const PYTHON_BIN_DIR: &str = "bin";
#[cfg(unix)]
const PYTHON_EXE_CANDIDATES: &[&str] = &["python3", "python"];
#[cfg(windows)]
const PYTHON_EXE_CANDIDATES: &[&str] = &["python.exe", "python3.exe", "python3.12.exe"];
pub fn resolve_site_package_path(venv_path: &Path) -> Result<PathBuf, BridgeError> {
logger::debug(&format!(
"Resolving site-packages path for venv: {}",
venv_path.display()
));
if !venv_path.is_dir() {
logger::debug(&format!(
"Venv path does not exist or is not a directory: {}",
venv_path.display()
));
return Err(BridgeError::VenvNotFound(venv_path.to_path_buf()));
}
#[cfg(windows)]
{
let site_packages = venv_path.join(PYTHON_LIB_DIR).join("site-packages");
logger::debug(&format!(
"Windows: Looking for site-packages at: {}",
site_packages.display()
));
if !site_packages.is_dir() {
logger::debug(&format!(
"Windows: site-packages directory not found at: {}",
site_packages.display()
));
return Err(BridgeError::Initialization(format!(
"unable to locate package directory: {}",
site_packages.display()
)));
}
logger::debug(&format!(
"Windows: Successfully resolved site-packages: {}",
site_packages.display()
));
Ok(site_packages)
}
#[cfg(not(windows))]
{
let lib_dir = venv_path.join(PYTHON_LIB_DIR);
logger::debug(&format!(
"Unix: Looking for lib directory at: {}",
lib_dir.display()
));
if !lib_dir.is_dir() {
logger::debug(&format!(
"Unix: lib directory not found at: {}",
lib_dir.display()
));
return Err(BridgeError::Initialization(format!(
"unable to locate lib directory: {}",
lib_dir.display()
)));
}
let python_version_dir = fs::read_dir(&lib_dir)
.map_err(|e| {
logger::debug(&format!("Unix: Failed to read lib directory: {}", e));
BridgeError::Initialization(format!("Failed to read lib directory: {}", e))
})?
.filter_map(|e| e.ok())
.find(|e| e.file_name().to_string_lossy().starts_with("python"))
.ok_or_else(|| {
logger::debug("Unix: No python3.X directory found in venv/lib");
BridgeError::Initialization("No python3.X directory found in venv/lib".to_string())
})?;
logger::debug(&format!(
"Unix: Found python version directory: {}",
python_version_dir.path().display()
));
let site_packages = python_version_dir.path().join("site-packages");
logger::debug(&format!(
"Unix: Looking for site-packages at: {}",
site_packages.display()
));
if !site_packages.is_dir() {
logger::debug(&format!(
"Unix: site-packages directory not found at: {}",
site_packages.display()
));
return Err(BridgeError::Initialization(format!(
"unable to locate package directory: {}",
site_packages.display()
)));
}
logger::debug(&format!(
"Unix: Successfully resolved site-packages: {}",
site_packages.display()
));
Ok(site_packages)
}
}
pub fn resolve_python_path(venv_path: &Path) -> Result<PathBuf, BridgeError> {
if !venv_path.is_dir() {
return Err(BridgeError::VenvNotFound(venv_path.to_path_buf()));
}
let bin_dir = venv_path.join(PYTHON_BIN_DIR);
if !bin_dir.is_dir() {
return Err(BridgeError::Initialization(format!(
"Python bin directory missing: {}",
bin_dir.display()
)));
}
for exe in PYTHON_EXE_CANDIDATES {
let candidate = bin_dir.join(exe);
if candidate.is_file() {
return Ok(candidate);
}
}
if let Ok(entries) = fs::read_dir(&bin_dir) {
if let Some(candidate) = entries.filter_map(|e| e.ok()).map(|e| e.path()).find(|p| {
p.file_name()
.and_then(|n| n.to_str())
.is_some_and(|name| name.contains("python"))
&& p.is_file()
}) {
return Ok(candidate);
}
}
Err(BridgeError::Initialization(format!(
"Path to python binary is not valid in {}",
venv_path.display()
)))
}
#[cfg(test)]
mod tests {
use crate::utils::*;
use std::fs;
use tempfile::TempDir;
#[allow(dead_code)]
fn create_mock_venv_unix(python_version: &str) -> Option<TempDir> {
let temp_dir = TempDir::new().ok()?;
let venv_path = temp_dir.path();
let lib_dir = venv_path.join("lib");
let python_dir = lib_dir.join(python_version);
let site_packages = python_dir.join("site-packages");
fs::create_dir_all(&site_packages).ok()?;
let bin_dir = venv_path.join("bin");
fs::create_dir_all(&bin_dir).ok()?;
fs::write(bin_dir.join("python3"), "").ok()?;
Some(temp_dir)
}
#[allow(dead_code)]
fn create_mock_venv_windows() -> Option<TempDir> {
let temp_dir = TempDir::new().ok()?;
let venv_path = temp_dir.path();
let lib_dir = venv_path.join("Lib");
let site_packages = lib_dir.join("site-packages");
fs::create_dir_all(&site_packages).ok()?;
let scripts_dir = venv_path.join("Scripts");
fs::create_dir_all(&scripts_dir).ok()?;
fs::write(scripts_dir.join("python.exe"), "").ok()?;
Some(temp_dir)
}
#[test]
#[cfg(unix)]
fn test_resolve_site_package_path_unix() {
let Some(temp_venv) = create_mock_venv_unix("python3.12") else {
return;
};
let venv_path = temp_venv.path().to_path_buf();
let result = resolve_site_package_path(&venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(|sp| sp.ends_with("lib/python3.12/site-packages") && sp.exists()));
}
#[test]
#[cfg(unix)]
fn test_resolve_site_package_path_unix_different_version() {
let Some(temp_venv) = create_mock_venv_unix("python3.11") else {
return;
};
let venv_path = temp_venv.path().to_path_buf();
let result = resolve_site_package_path(&venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(|sp| sp.ends_with("lib/python3.11/site-packages")));
}
#[test]
#[cfg(windows)]
fn test_resolve_site_package_path_windows() {
let Some(temp_venv) = create_mock_venv_windows() else {
return;
};
let venv_path = temp_venv.path().to_path_buf();
let result = resolve_site_package_path(&venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(|sp| sp.ends_with("Lib\\site-packages") && sp.exists()));
}
#[test]
fn test_resolve_site_package_path_venv_not_found() {
let non_existent_path = PathBuf::from("/tmp/non_existent_venv_12345");
let result = resolve_site_package_path(&non_existent_path);
assert!(result.is_err());
assert!(matches!(
result,
Err(BridgeError::VenvNotFound(path)) if path == non_existent_path
));
}
#[test]
#[cfg(unix)]
fn test_resolve_site_package_path_missing_python_dir() {
let Ok(temp_dir) = TempDir::new() else {
return;
};
let venv_path = temp_dir.path();
let lib_dir = venv_path.join("lib");
if fs::create_dir_all(&lib_dir).is_err() {
return;
}
let result = resolve_site_package_path(venv_path);
assert!(result.is_err());
assert!(result.is_err_and(|e| matches!(e, BridgeError::Initialization(msg) if msg.contains("No python3.X directory found"))));
}
#[test]
#[cfg(unix)]
fn test_resolve_python_path_unix() {
let Some(temp_venv) = create_mock_venv_unix("python3.12") else {
return;
};
let venv_path = temp_venv.path().to_path_buf();
let result = resolve_python_path(&venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(|pp| pp.ends_with("bin/python3")));
}
#[test]
#[cfg(windows)]
fn test_resolve_python_path_windows() {
let Some(temp_venv) = create_mock_venv_windows() else {
return;
};
let venv_path = temp_venv.path().to_path_buf();
let result = resolve_python_path(&venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(|pp| pp.ends_with("Scripts\\python.exe")));
}
#[test]
fn test_python_lib_dir_constant() {
#[cfg(unix)]
assert_eq!(PYTHON_LIB_DIR, "lib");
#[cfg(windows)]
assert_eq!(PYTHON_LIB_DIR, "Lib");
}
#[test]
fn test_python_bin_dir_constant() {
#[cfg(unix)]
assert_eq!(PYTHON_BIN_DIR, "bin");
#[cfg(windows)]
assert_eq!(PYTHON_BIN_DIR, "Scripts");
}
#[test]
#[cfg(unix)]
fn test_resolve_site_package_path_with_multiple_python_versions() {
let Ok(temp_dir) = TempDir::new() else {
return;
};
let venv_path = temp_dir.path();
let lib_dir = venv_path.join("lib");
if fs::create_dir_all(&lib_dir).is_err() {
return;
}
let python_311 = lib_dir.join("python3.11");
let site_packages_311 = python_311.join("site-packages");
if fs::create_dir_all(&site_packages_311).is_err() {
return;
}
let python_312 = lib_dir.join("python3.12");
let site_packages_312 = python_312.join("site-packages");
if fs::create_dir_all(&site_packages_312).is_err() {
return;
}
let result = resolve_site_package_path(venv_path);
assert!(result.is_ok());
assert!(result.is_ok_and(
|sp| sp.to_string_lossy().contains("python3.1") && sp.ends_with("site-packages")
));
}
}