build.rs

use std::{
	borrow::Cow,
	collections::HashSet,
	env,
	ffi::OsStr,
	fs::{self, File},
	io::{BufRead, BufReader},
	iter::{self, FromIterator},
	path::{Path, PathBuf},
	process::Command,
};

use glob::glob;
use once_cell::sync::{Lazy, OnceCell};
use semver::{Version, VersionReq};
use shlex::Shlex;

#[cfg(feature = "buildtime-bindgen")]
mod generator {
	use std::{
		env,
		ffi::OsStr,
		fs::{self, DirEntry, File, OpenOptions},
		io::{self, BufRead, BufReader, Write},
		path::{Path, PathBuf},
		process::Child,
		sync::Arc,
		thread,
		time::Instant,
	};

	use glob::glob;

	use super::{
		file_copy_to_dir,
		get_versioned_hub_dirs,
		is_core_module,
		MODULES,
		OUT_DIR,
		Result,
		SRC_CPP_DIR,
		SRC_DIR,
	};

	fn read_dir(path: &Path) -> Result<impl Iterator<Item=DirEntry>> {
		Ok(path.read_dir()?.filter_map(|e| e.ok()))
	}

	fn copy_indent(mut read: impl BufRead, mut write: impl Write, indent: &str) -> Result<()> {
		let mut line = Vec::with_capacity(100);
		while read.read_until(b'\n', &mut line)? != 0 {
			write.write(indent.as_bytes())?;
			write.write(&line)?;
			line.clear();
		}
		Ok(())
	}

	fn file_move_to_dir(src_file: &Path, target_dir: &Path) -> Result<PathBuf> {
		if !target_dir.exists() {
			fs::create_dir_all(&target_dir)?;
		}
		let src_filename = src_file.file_name()
			.ok_or_else(|| "Can't calculate filename")?;
		let target_file = target_dir.join(src_filename);
		if fs::rename(&src_file, &target_file).is_err() {
			fs::copy(&src_file, &target_file)?;
			fs::remove_file(src_file)?;
		}
		Ok(target_file)
	}

	pub fn gen_wrapper(opencv_header_dir: &Path, generator_build: Option<Child>) -> Result<()> {
		let out_dir_as_str = OUT_DIR.to_str().unwrap();
		let (rust_hub_dir, cpp_hub_dir) = get_versioned_hub_dirs();
		let module_dir = rust_hub_dir.join("hub");
		let manual_dir = SRC_DIR.join("manual");
		let opencv_dir = opencv_header_dir.join("opencv2");

		eprintln!("=== Using OpenCV headers from: {}", opencv_dir.display());
		eprintln!("=== Generating code in: {}", out_dir_as_str);
		eprintln!("=== Placing generated bindings into: {}", rust_hub_dir.display());

		let modules = MODULES.get().expect("MODULES not initialized");

		for entry in read_dir(&OUT_DIR)? {
			let path = entry.path();
			if path.is_file() && path.extension().and_then(OsStr::to_str).map_or(true, |ext| !ext.eq_ignore_ascii_case("dll")) {
				let _ = fs::remove_file(path);
			}
		}

		let version = if cfg!(feature = "opencv-32") {
			"3.2.0"
		} else if cfg!(feature = "opencv-34") {
			"3.4.10"
		} else if cfg!(feature = "opencv-4") {
			"4.3.0"
		} else {
			unreachable!();
		};

		let clang_stdlib_include_dir = Arc::new(env::var_os("OPENCV_CLANG_STDLIB_PATH")
			.map(|p| PathBuf::from(p))
		);
		let num_jobs = env::var("NUM_JOBS").ok()
			.and_then(|jobs| jobs.parse().ok())
			.unwrap_or(2);
		let job_server = jobserver::Client::new(num_jobs).expect("Can't create job server");
		let mut join_handles = Vec::with_capacity(modules.len());
		let start;
		if cfg!(feature = "clang-runtime") {
			let clang = clang::Clang::new().expect("Cannot initialize clang");
			println!("=== Clang: {}", clang::get_version());
			let gen = binding_generator::Generator::new(clang_stdlib_include_dir.as_deref(), &opencv_header_dir, &*SRC_CPP_DIR, clang);
			eprintln!("=== Clang command line args: {:#?}", gen.build_clang_command_line_args());
			start = Instant::now();
			modules.iter().for_each(|module| {
				let bindings_writer = binding_generator::writer::RustNativeBindingWriter::new(
					&*SRC_CPP_DIR,
					&*OUT_DIR,
					&module,
					version,
					false,
				);
				gen.process_opencv_module(&module, bindings_writer);
				println!("Generated: {}", module);
			});
			drop(generator_build); // fixme, prevent unused var warning
			// fixme, https://github.com/twistedfall/opencv-rust/issues/145
			// let status = generator_build.expect("Impossible").wait()?;
			// if !status.success() {
			// 	return Err("Failed to build the bindings generator".into());
			// }
			// let opencv_header_dir = Arc::new(opencv_header_dir.to_owned());
			// start = Instant::now();
			// modules.iter().for_each(|module| {
			// 	let token = job_server.acquire().expect("Can't acquire token from job server");
			// 	let join_handle = thread::spawn({
			// 		let clang_stdlib_include_dir = Arc::clone(&clang_stdlib_include_dir);
			// 		let opencv_header_dir = Arc::clone(&opencv_header_dir);
			// 		move || {
			// 			let clang_stdlib_include_dir = (*clang_stdlib_include_dir).as_ref()
			// 				.and_then(|p| p.to_str())
			// 				.unwrap_or("None");
			// 			let mut bin_generator = std::process::Command::new(OUT_DIR.join("release/binding-generator"));
			// 			bin_generator.arg(&*opencv_header_dir)
			// 				.arg(&*SRC_CPP_DIR)
			// 				.arg(&*OUT_DIR)
			// 				.arg(&module)
			// 				.arg(version)
			// 				.arg(clang_stdlib_include_dir);
			// 			let res = bin_generator.status().expect("Can't run bindings generator");
			// 			if !res.success() {
			// 				panic!("Failed to run the bindings generator");
			// 			}
			// 			println!("Generated: {}", module);
			// 			drop(token); // needed to move the token to the thread
			// 		}
			// 	});
			// 	join_handles.push(join_handle);
			// });
		} else {
			let clang = clang::Clang::new().expect("Cannot initialize clang");
			println!("=== Clang: {}", clang::get_version());
			let gen = binding_generator::Generator::new(clang_stdlib_include_dir.as_deref(), &opencv_header_dir, &*SRC_CPP_DIR, clang);
			eprintln!("=== Clang command line args: {:#?}", gen.build_clang_command_line_args());
			let gen = Arc::new(gen);
			start = Instant::now();
			modules.iter().for_each(|module| {
				let token = job_server.acquire().expect("Can't acquire token from job server");
				let join_handle = thread::spawn({
					let gen = Arc::clone(&gen);
					move || {
						let bindings_writer = binding_generator::writer::RustNativeBindingWriter::new(
							&*SRC_CPP_DIR,
							&*OUT_DIR,
							&module,
							version,
							false,
						);
						gen.process_opencv_module(&module, bindings_writer);
						println!("Generated: {}", module);
						drop(token); // needed to move the token to the thread
					}
				});
				join_handles.push(join_handle);
			});
		}
		for join_handle in join_handles {
			join_handle.join().expect("Can't join thread");
		}
		println!("Total binding generation time: {:?}", start.elapsed());

		if !module_dir.exists() {
			fs::create_dir_all(&module_dir)?;
		}

		for entry in read_dir(&module_dir)? {
			let path = entry.path();
			if path.extension().map_or(false, |e| e == "rs") {
				let _ = fs::remove_file(path);
			}
		}

		if !cpp_hub_dir.exists() {
			fs::create_dir_all(&cpp_hub_dir)?;
		}
		for entry in read_dir(&cpp_hub_dir)? {
			let path = entry.path();
			if path.is_file() {
				let _ = fs::remove_file(path);
			}
		}

		for module in modules {
			let module_cpp = OUT_DIR.join(format!("{}.cpp", module));
			if module_cpp.is_file() {
				file_copy_to_dir(&module_cpp, &cpp_hub_dir)?;
				let module_types_cpp = OUT_DIR.join(format!("{}_types.hpp", module));
				let mut module_types_file = OpenOptions::new().create(true).truncate(true).write(true).open(&module_types_cpp)?;
				let mut type_files: Vec<PathBuf> = glob(&format!("{}/???-{}-*.type.cpp", out_dir_as_str, module))?
					.collect::<Result<_, glob::GlobError>>()?;
				type_files.sort_unstable();
				for entry in type_files.into_iter() {
					io::copy(&mut File::open(entry)?, &mut module_types_file)?;
				}
				file_copy_to_dir(&module_types_cpp, &cpp_hub_dir)?;
			}
		}

		let add_manual = |file: &mut File, mod_name: &str| -> Result<bool> {
			if manual_dir.join(format!("{}.rs", mod_name)).exists() {
				writeln!(file, "pub use crate::manual::{}::*;", mod_name)?;
				Ok(true)
			} else {
				Ok(false)
			}
		};

		{
			let mut hub_rs = File::create(rust_hub_dir.join("hub.rs"))?;

			let mut types_rs = File::create(module_dir.join("types.rs"))?;
			writeln!(&mut types_rs)?;

			let mut sys_rs = File::create(module_dir.join("sys.rs"))?;
			writeln!(&mut sys_rs, "use crate::{{mod_prelude_types::*, core}};")?;
			writeln!(&mut sys_rs)?;
			for module in modules {
				let is_core_module = is_core_module(module.as_str());
				let write_if_contrib = |write: &mut File| -> Result<()> {
					if !is_core_module {
						writeln!(write, r#"#[cfg(feature = "contrib")]"#)?;
					}
					Ok(())
				};
				// hub
				write_if_contrib(&mut hub_rs)?;
				writeln!(&mut hub_rs, "pub mod {};", module)?;
				let module_filename = format!("{}.rs", module);
				let target_file = file_move_to_dir(&OUT_DIR.join(&module_filename), &module_dir)?;
				let mut f = OpenOptions::new().append(true).open(&target_file)?;
				add_manual(&mut f, module)?;

				// types
				let mut write_header = true;
				for entry in glob(&format!("{}/???-{}-*.type.rs", out_dir_as_str, module))? {
					let entry = entry?;
					if entry.metadata().map(|meta| meta.len()).unwrap_or(0) > 0 {
						if write_header {
							write_if_contrib(&mut types_rs)?;
							writeln!(&mut types_rs, "mod {}_types {{", module)?;
							writeln!(&mut types_rs, "\tuse crate::{{mod_prelude::*, core, types, sys}};")?;
							writeln!(&mut types_rs)?;
							write_header = false;
						}
						copy_indent(BufReader::new(File::open(&entry)?), &mut types_rs, "\t")?;
					}
				}
				if !write_header {
					writeln!(&mut types_rs, "}}")?;
					write_if_contrib(&mut types_rs)?;
					writeln!(&mut types_rs, "pub use {}_types::*;", module)?;
					writeln!(&mut types_rs)?;
				}

				// sys
				let path = OUT_DIR.join(format!("{}.externs.rs", module));
				write_if_contrib(&mut sys_rs)?;
				writeln!(&mut sys_rs, "mod {}_sys {{", module)?;
				writeln!(&mut sys_rs, "\tuse super::*;")?;
				writeln!(&mut sys_rs)?;
				for entry in glob(&format!("{}/{}-*.rv.rs", out_dir_as_str, module))? {
					let entry: PathBuf = entry?;
					copy_indent(BufReader::new(File::open(entry)?), &mut sys_rs, "\t")?;
				}
				copy_indent(BufReader::new(File::open(&path)?), &mut sys_rs, "\t")?;
				writeln!(&mut sys_rs, "}}")?;
				write_if_contrib(&mut sys_rs)?;
				writeln!(&mut sys_rs, "pub use {}_sys::*;", module)?;
				writeln!(&mut sys_rs)?;
			}
			writeln!(&mut hub_rs, "pub mod types;")?;
			writeln!(&mut hub_rs, "#[doc(hidden)]")?;
			writeln!(&mut hub_rs, "pub mod sys;")?;

			add_manual(&mut types_rs, "types")?;

			add_manual(&mut sys_rs, "sys")?;

			writeln!(&mut hub_rs, "pub mod hub_prelude {{")?;
			for module in modules {
				if !is_core_module(module.as_str()) {
					writeln!(&mut hub_rs, r#"	#[cfg(feature = "contrib")]"#)?;
				}
				writeln!(&mut hub_rs, r#"	pub use super::{}::prelude::*;"#, module)?;
			}
			writeln!(&mut hub_rs, "}}")?;
		}

		Ok(())
	}
}

type Result<T, E = Box<dyn std::error::Error>> = std::result::Result<T, E>;

static CORE_MODULES: Lazy<HashSet<&'static str>> = Lazy::new(|| HashSet::from_iter([
	"calib3d",
	"core",
	#[cfg(not(feature = "opencv-32"))]
	"dnn",
	#[cfg(feature = "opencv-4")]
	"dnn_superres",
	"features2d",
	"flann",
	#[cfg(feature = "opencv-4")]
	"gapi",
	"highgui",
	"imgcodecs",
	"imgproc",
	"ml",
	"objdetect",
	"photo",
	#[cfg(any(feature = "opencv-32", feature = "opencv-34"))]
	"shape",
	"stitching",
	#[cfg(any(feature = "opencv-32", feature = "opencv-34"))]
	"superres",
	"video",
	"videoio",
	#[cfg(any(feature = "opencv-32", feature = "opencv-34"))]
	"videostab",
	"viz",
].iter().copied()));

static DEBUG_MODULE: &str = "";

static MODULES: OnceCell<Vec<String>> = OnceCell::new();

static OUT_DIR: Lazy<PathBuf> = Lazy::new(|| PathBuf::from(env::var_os("OUT_DIR").expect("Can't read OUT_DIR env var")));
static MANIFEST_DIR: Lazy<PathBuf> = Lazy::new(|| PathBuf::from(env::var_os("CARGO_MANIFEST_DIR").expect("Can't read CARGO_MANIFEST_DIR env var")));
static SRC_DIR: Lazy<PathBuf> = Lazy::new(|| MANIFEST_DIR.join("src"));
static SRC_CPP_DIR: Lazy<PathBuf> = Lazy::new(|| MANIFEST_DIR.join("src_cpp"));

static ENV_VARS: [&str; 15] = [
	"OPENCV_HEADER_DIR",
	"OPENCV_PACKAGE_NAME",
	"OPENCV_PKGCONFIG_NAME",
	"OPENCV_CMAKE_NAME",
	"OPENCV_CMAKE_BIN",
	"OPENCV_VCPKG_NAME",
	"OPENCV_LINK_LIBS",
	"OPENCV_LINK_PATHS",
	"OPENCV_INCLUDE_PATHS",
	"OPENCV_DISABLE_PROBES",
	"OPENCV_CLANG_STDLIB_PATH",
	"CMAKE_PREFIX_PATH",
	"OpenCV_DIR",
	"PKG_CONFIG_PATH",
	"VCPKG_ROOT",
];

struct PackageName {}

impl PackageName {
	pub fn env() -> Option<Cow<'static, str>> {
		env::var("OPENCV_PACKAGE_NAME")
			.ok()
			.map(|x| x.into())
	}

	pub fn env_pkg_config() -> Option<Cow<'static, str>> {
		env::var("OPENCV_PKGCONFIG_NAME")
			.ok()
			.map(|x| x.into())
	}

	pub fn env_cmake() -> Option<Cow<'static, str>> {
		env::var("OPENCV_CMAKE_NAME")
			.ok()
			.map(|x| x.into())
	}

	pub fn env_vcpkg() -> Option<Cow<'static, str>> {
		env::var("OPENCV_VCPKG_NAME")
			.ok()
			.map(|x| x.into())
	}

	pub fn pkg_config() -> Cow<'static, str> {
		Self::env()
			.or_else(Self::env_pkg_config)
			.unwrap_or_else(|| if cfg!(feature = "opencv-32") || cfg!(feature = "opencv-34") {
				"opencv".into()
			} else if cfg!(feature = "opencv-4") {
				"opencv4".into()
			} else {
				unreachable!("Feature flags should have been checked in main()");
			})
	}

	pub fn cmake() -> Cow<'static, str> {
		Self::env()
			.or_else(Self::env_cmake)
			.unwrap_or_else(|| "OpenCV".into())
	}

	pub fn vcpkg() -> Cow<'static, str> {
		Self::env()
			.or_else(Self::env_vcpkg)
			.unwrap_or_else(|| if cfg!(feature = "opencv-32") || cfg!(feature = "opencv-34") {
				"opencv3".into()
			} else if cfg!(feature = "opencv-4") {
				"opencv4".into()
			} else {
				unreachable!("Feature flags should have been checked in main()");
			})
	}
}

#[derive(Debug)]
struct Library {
	pub include_paths: Vec<PathBuf>,
	pub version: String,
	pub cargo_metadata: Vec<String>,
}

impl Library {
	fn strip_lib_file_decorations(path: &mut PathBuf) {
		const LIB_EXTS: [&str; 7] = ["so", "a", "dll", "lib", "dylib", "framework", "tbd"];
		// same, but with dots therearound
		const LIB_EXTS_INNER: [&str; 7] = [".so.", ".a.", ".dll.", ".lib.", ".dylib.", ".framework.", ".tbd."];
		if let Some(extension) = path.extension().and_then(OsStr::to_str) {
			if LIB_EXTS.iter().any(|e| e.eq_ignore_ascii_case(extension)) {
				path.set_extension("");
			}
		}
		if let Some(mut file) = path.file_name().and_then(OsStr::to_str).map(str::to_owned) {
			let orig_len = file.len();
			const LIB_PREFIX: &str = "lib";
			if file.starts_with(LIB_PREFIX) {
				file.drain(..LIB_PREFIX.len());
			}
			LIB_EXTS_INNER.iter()
				.for_each(|&inner_ext| if let Some(inner_ext_idx) = file.find(inner_ext) {
					file.drain(inner_ext_idx..);
				});
			if orig_len != file.len() {
				path.set_file_name(file);
			}
		}
	}

	fn process_library_list(libs: impl IntoIterator<Item=impl Into<PathBuf>>) -> impl Iterator<Item=String> {
		libs.into_iter()
			.map(|x| {
				let mut path: PathBuf = x.into();
				let is_framework = path.extension()
					.and_then(OsStr::to_str)
					.map_or(false, |e| e.eq_ignore_ascii_case("framework"));
				Self::strip_lib_file_decorations(&mut path);
				path.file_name()
					.and_then(|f| f.to_str()
						.map(|f| if is_framework {
							format!("framework={}", f)
						} else {
							f.to_owned()
						})
					).expect("Invalid library name")
			})
	}

	fn list(link_paths: &str) -> impl Iterator<Item=&str> {
		link_paths.split(',')
			.map(str::trim)
			.filter(|&x| !x.is_empty())
	}

	fn version_from_include_paths(include_paths: impl Iterator<Item=impl AsRef<Path>>) -> Option<String> {
		include_paths
			.filter_map(|x| get_version_from_headers(x.as_ref()))
			.next()
	}

	#[inline]
	fn emit_link_search(path: &str, typ: Option<&str>) -> String {
		format!("cargo:rustc-link-search={}{}", typ.map_or("".to_string(), |t| format!("{}=", t)), path)
	}

	#[inline]
	fn emit_link_lib(path: &str, typ: Option<&str>) -> String {
		format!("cargo:rustc-link-lib={}{}", typ.map_or("".to_string(), |t| format!("{}=", t)), path)
	}

	fn process_manual_link_search(cargo_metadata: &mut Vec<String>, link_paths: &str) {
		cargo_metadata.extend(
			Self::list(link_paths)
				.map(|path| {
					let out = iter::once(Self::emit_link_search(path, None));
					#[cfg(target_os = "macos")] {
						out.chain(
							iter::once(Self::emit_link_search(path, Some("framework")))
						)
					}
					#[cfg(not(target_os = "macos"))] {
						out
					}
				})
				.flatten()
		);
	}

	fn process_manual_link_libs(cargo_metadata: &mut Vec<String>, link_libs: &str) {
		cargo_metadata.extend(
			Self::process_library_list(Self::list(&link_libs))
				.map(|l| Self::emit_link_lib(&l, None))
		);
	}

	pub fn probe_from_paths(include_paths: &str, link_paths: &str, link_libs: &str) -> Result<Self> {
		eprintln!("=== Configuring OpenCV library from the environment:");
		eprintln!("===   include_paths: {}", include_paths);
		eprintln!("===   link_paths: {}", link_paths);
		eprintln!("===   link_libs: {}", link_libs);
		let mut cargo_metadata = Vec::with_capacity(64);
		let include_paths: Vec<_> = Self::list(&include_paths)
			.map(PathBuf::from)
			.collect();

		let version = Self::version_from_include_paths(include_paths.iter());

		Self::process_manual_link_search(&mut cargo_metadata, link_paths);
		Self::process_manual_link_libs(&mut cargo_metadata, link_libs);

		Ok(Self {
			include_paths,
			version: version.unwrap_or_else(|| "0.0.0".to_owned()),
			cargo_metadata,
		})
	}

	pub fn probe_pkg_config(include_paths: Option<&str>, link_paths: Option<&str>, link_libs: Option<&str>) -> Result<Self> {
		eprintln!("=== Probing OpenCV library using pkg_config");
		let mut config = pkg_config::Config::new();
		config.cargo_metadata(false);
		let opencv = config.probe(&PackageName::pkg_config())?;
		let mut cargo_metadata = Vec::with_capacity(64);
		if let Some(link_paths) = link_paths {
			Self::process_manual_link_search(&mut cargo_metadata, link_paths);
		} else {
			cargo_metadata.extend(
				opencv.link_paths.into_iter()
					.map(|link_path|
						Self::emit_link_search(link_path.to_str().expect("Invalid link path"), Some("native"))
					)
			);
			cargo_metadata.extend(
				opencv.framework_paths.into_iter()
					.map(|fw_path|
						Self::emit_link_search(fw_path.to_str().expect("Invalid framework path"), Some("framework"))
					)
			);
		}
		if let Some(link_libs) = link_libs {
			Self::process_manual_link_libs(&mut cargo_metadata, link_libs);
		} else {
			cargo_metadata.extend(
				opencv.libs.into_iter()
					.map(|lib| Self::emit_link_lib(&lib, None))
			);
			cargo_metadata.extend(
				opencv.frameworks.into_iter()
					.map(|fw| Self::emit_link_lib(&fw, Some("framework")))
			);
		}
		let include_paths = include_paths.map_or(opencv.include_paths, |include_paths| {
			Self::list(include_paths)
				.map(PathBuf::from)
				.collect()
		});
		Ok(Self {
			include_paths,
			version: opencv.version,
			cargo_metadata,
		})
	}

	pub fn probe_cmake(include_paths: Option<&str>, link_paths: Option<&str>, link_libs: Option<&str>) -> Result<Self> {
		eprintln!("=== Probing OpenCV library using cmake");
		let cmake_pkg = PackageName::cmake();
		let cmake_bin = env::var_os("OPENCV_CMAKE_BIN").unwrap_or_else(|| "cmake".into());

		let include_paths = include_paths
			.map(|paths| Self::list(paths)
				.map(PathBuf::from)
				.collect::<Vec<_>>()
			)
			.ok_or_else(|| "Nobody is going to see that")
			.or_else(|_| Command::new(&cmake_bin)
				.current_dir(&*OUT_DIR)
				.args(&[
					"--find-package",
					"-DCOMPILER_ID=GNU",
					"-DLANGUAGE=CXX",
					"-DMODE=COMPILE",
				])
				.arg(format!("-DNAME={}", cmake_pkg))
				.output()
				.map_err(Box::<dyn std::error::Error>::from)
				.and_then(|output| {
					if output.status.success() {
						let mut include_paths = Vec::with_capacity(4);
						let stdout = String::from_utf8(output.stdout)?;
						eprintln!("=== cmake include arguments: {:#?}", stdout);
						for mut arg in Shlex::new(stdout.trim()) {
							const INCLUDE_PREFIX: &str = "-I";
							if arg.starts_with(INCLUDE_PREFIX) {
								arg.drain(..INCLUDE_PREFIX.len());
								// todo possibly handle leading whitespace
								include_paths.push(PathBuf::from(arg));
							} else {
								eprintln!("=== Unexpected cmake compile argument found: {}", arg);
							}
						}
						Ok(include_paths)
					} else {
						Err(format!(
							"cmake returned an error\n    stdout: {:?}\n    stderr: {:?}",
							String::from_utf8_lossy(&output.stdout),
							String::from_utf8_lossy(&output.stderr)
						).into())
					}
				})
			)?;

		if let Some(version) = Self::version_from_include_paths(include_paths.iter()) {
			let mut cargo_metadata = Vec::with_capacity(64);
			link_paths.map(|link_paths| Self::process_manual_link_search(&mut cargo_metadata, link_paths));
			link_libs.map(|link_libs| Self::process_manual_link_libs(&mut cargo_metadata, link_libs));
			if link_paths.is_none() || link_libs.is_none() {
				Command::new(&cmake_bin)
					.current_dir(&*OUT_DIR)
					.args(&[
						"--find-package",
						"-DCOMPILER_ID=GNU",
						"-DLANGUAGE=CXX",
						"-DMODE=LINK",
					])
					.arg(format!("-DNAME={}", cmake_pkg))
					.output()
					.map_err(Box::<dyn std::error::Error>::from)
					.and_then(|output| if output.status.success() {
						let mut cmake_link_paths = if link_paths.is_some() { HashSet::new() } else { HashSet::with_capacity(4) };
						let stdout = String::from_utf8(output.stdout)?;
						eprintln!("=== cmake link arguments: {:#?}", stdout);
						for mut arg in Shlex::new(stdout.trim()) {
							const RPATH_PREFIX: &str = "-Wl,-rpath,";
							if arg.starts_with(RPATH_PREFIX) {
								arg.drain(..RPATH_PREFIX.len());
								cmake_link_paths.insert(PathBuf::from(arg));
							} else if arg.starts_with("-") {
								eprintln!("=== Unexpected cmake link argument found: {}", arg);
							} else {
								let mut path = PathBuf::from(arg);
								if link_paths.is_none() {
									if let Some(parent) = path.parent() {
										cmake_link_paths.insert(parent.to_owned());
									}
								}
								if link_libs.is_none() {
									Self::strip_lib_file_decorations(&mut path);
									if let Some(file) = path.file_name().and_then(OsStr::to_str) {
										cargo_metadata.push(Self::emit_link_lib(file, None));
									}
								}
							}
						}
						cargo_metadata.extend(
							cmake_link_paths.into_iter()
								.map(|link_path|
									Self::emit_link_search(link_path.to_str().expect("Invalid link path"), Some("native"))
								)
						);
						Ok(())
					} else {
						Err(format!(
							"cmake returned an error\n    stdout: {:?}\n    stderr: {:?}",
							String::from_utf8_lossy(&output.stdout),
							String::from_utf8_lossy(&output.stderr)
						).into())
					})?
			};

			Ok(Self {
				include_paths,
				cargo_metadata,
				version,
			})
		} else {
			Err(format!("cmake discovery problem: OpenCV version not found in include paths: {:?}", include_paths).into())
		}
	}

	pub fn probe_vcpkg() -> Result<Self> {
		eprintln!("=== Probing OpenCV library using vcpkg");
		let mut config = vcpkg::Config::new();
		config.cargo_metadata(false);
		let opencv = config.find_package(&PackageName::vcpkg())?;

		let version = Self::version_from_include_paths(opencv.include_paths.iter());

		Ok(Self {
			include_paths: opencv.include_paths,
			version: version.unwrap_or_else(|| "0.0.0".to_owned()),
			cargo_metadata: opencv.cargo_metadata,
		})
	}

	pub fn probe_system(include_paths: Option<&str>, link_paths: Option<&str>, link_libs: Option<&str>) -> Result<Self> {
		let probe_pkg_config = || Self::probe_pkg_config(include_paths, link_paths, link_libs);
		let probe_cmake = || Self::probe_cmake(include_paths, link_paths, link_libs);
		let probe_vcpkg = || Self::probe_vcpkg();

		let explicit_pkg_config = env::var_os("PKG_CONFIG_PATH").is_some() || env::var_os("OPENCV_PKGCONFIG_NAME").is_some();
		let explicit_cmake = env::var_os("OpenCV_DIR").is_some()
			|| env::var_os("OPENCV_CMAKE_NAME").is_some()
			|| env::var_os("CMAKE_PREFIX_PATH").is_some()
			|| env::var_os("OPENCV_CMAKE_BIN").is_some();
		let explicit_vcpkg = env::var_os("VCPKG_ROOT").is_some() || cfg!(target_os = "windows");

		let disabled_probes = env::var("OPENCV_DISABLE_PROBES");
		let disabled_probes = disabled_probes.as_ref()
			.map(|s| HashSet::from_iter(Self::list(s)))
			.unwrap_or_else(|_| HashSet::new());

		let mut probes = [
			("pkg_config", &probe_pkg_config as &dyn Fn() -> Result<Self>),
			("cmake", &probe_cmake),
			("vcpkg", &probe_vcpkg),
		];

		if explicit_pkg_config {
			if explicit_vcpkg {
				probes.swap(1, 2);
			}
		} else if explicit_cmake {
			probes.swap(0, 1);
			if explicit_vcpkg {
				probes.swap(1, 2);
			}
		} else if explicit_vcpkg {
			probes.swap(1, 2);
			probes.swap(0, 1);
		}

		let mut out = None;
		for &(name, probe) in &probes {
			if !disabled_probes.contains(name) {
				match probe() {
					Ok(lib) => {
						match check_matching_version(&lib.version) {
							Ok(..) => {
								out = Some(lib);
								break;
							},
							Err(e) => {
								eprintln!("=== Wrong version: {} using {}, continuing: {:#?}", e, name, lib);
							}
						}
					}
					Err(e) => {
						eprintln!("=== Can't probe using {}, continuing with other methods, error: {}", name, e);
					}
				}
			} else {
				eprintln!("=== Skipping probe {} because of the environment configuration", name);
			}
		}
		out.ok_or_else(|| {
			let methods = probes.iter()
				.map(|&(name, _)| name)
				.filter(|&name| !disabled_probes.contains(name))
				.collect::<Vec<_>>()
				.join(", ");
			format!("Failed to find OpenCV package using probes: {}", methods).into()
		})
	}

	pub fn probe() -> Result<Self> {
		let include_paths = env::var("OPENCV_INCLUDE_PATHS").ok();
		let link_paths = env::var("OPENCV_LINK_PATHS").ok();
		let link_libs = env::var("OPENCV_LINK_LIBS").ok();
		if let (Some(include_paths), Some(link_paths), Some(link_libs)) = (&include_paths, &link_paths, &link_libs) {
			Self::probe_from_paths(include_paths, link_paths, link_libs)
		} else {
			Self::probe_system(include_paths.as_deref(), link_paths.as_deref(), link_libs.as_deref())
		}
	}

	pub fn emit_cargo_metadata(&self) {
		self.cargo_metadata.iter().for_each(|meta| {
			println!("{}", meta);
		});
	}
}

fn file_copy_to_dir(src_file: &Path, target_dir: &Path) -> Result<PathBuf> {
	if !target_dir.exists() {
		fs::create_dir_all(&target_dir)?;
	}
	let src_filename = src_file.file_name()
		.ok_or_else(|| "Can't calculate filename")?;
	let target_file = target_dir.join(src_filename);
	fs::copy(&src_file, &target_file)?;
	Ok(target_file)
}

fn get_version_from_headers(header_dir: &Path) -> Option<String> {
	let version_hpp = {
		let out = header_dir.join("opencv2/core/version.hpp");
		if out.is_file() {
			out
		} else {
			let out = header_dir.join("Headers/core/version.hpp");
			if out.is_file() {
				out
			} else {
				return None;
			}
		}
	};
	let mut major = None;
	let mut minor = None;
	let mut revision = None;
	let mut line = String::with_capacity(256);
	let mut reader = BufReader::new(File::open(version_hpp).ok()?);
	while let Ok(bytes_read) = reader.read_line(&mut line) {
		if bytes_read == 0 {
			break;
		}
		const PREFIX: &str = "#define CV_VERSION_";
		if line.starts_with(PREFIX) {
			let mut parts = line[PREFIX.len()..].split_whitespace();
			if let (Some(ver_spec), Some(version)) = (parts.next(), parts.next()) {
				match ver_spec {
					"MAJOR" => {
						major = Some(version.to_string());
					}
					"MINOR" => {
						minor = Some(version.to_string());
					}
					"REVISION" => {
						revision = Some(version.to_string());
					}
					_ => {}
				}
			}
			if major.is_some() && minor.is_some() && revision.is_some() {
				break;
			}
		}
		line.clear();
	}
	if let (Some(major), Some(minor), Some(revision)) = (major, minor, revision) {
		Some(format!("{}.{}.{}", major, minor, revision))
	} else {
		Some("0.0.0".to_string())
	}
}

fn check_matching_version(version: &str) -> Result<()> {
	#![allow(clippy::ifs_same_cond)] // false trigger
	if cfg!(feature = "opencv-32") && !VersionReq::parse("~3.2")?.matches(&Version::parse(version)?) {
		Err(format!("OpenCV version: {} must be from 3.2 branch because of the feature: opencv-32", version).into())
	} else if cfg!(feature = "opencv-34") && !VersionReq::parse("~3.4")?.matches(&Version::parse(version)?) {
		Err(format!("OpenCV version: {} must be from 3.4 branch because of the feature: opencv-34", version).into())
	} else if cfg!(feature = "opencv-4") && !VersionReq::parse("~4")?.matches(&Version::parse(version)?) {
		Err(format!("OpenCV version: {} must be from 4.x branch because of the feature: opencv-4", version).into())
	} else {
		Ok(())
	}
}

fn get_versioned_hub_dirs() -> (PathBuf, PathBuf) {
	let bindings_dir = MANIFEST_DIR.join("bindings");
	let mut rust_hub_dir = bindings_dir.join("rust");
	let mut cpp_hub_dir = bindings_dir.join("cpp");
	if cfg!(feature = "opencv-32") {
		rust_hub_dir.push("opencv_32");
		cpp_hub_dir.push("opencv_32");
	} else if cfg!(feature = "opencv-34") {
		rust_hub_dir.push("opencv_34");
		cpp_hub_dir.push("opencv_34");
	} else if cfg!(feature = "opencv-4") {
		rust_hub_dir.push("opencv_4");
		cpp_hub_dir.push("opencv_4");
	}
	(rust_hub_dir, cpp_hub_dir)
}

fn make_modules(opencv_dir_as_string: &str) -> Result<()> {
	if !DEBUG_MODULE.is_empty() {
		MODULES.set(vec![DEBUG_MODULE.to_string()]).expect("Can't set debug MODULES cache");
		return Ok(())
	}
	let ignore_modules: HashSet<&'static str> = HashSet::from_iter([
		"core_detect",
		"cudalegacy",
		"cudev",
		"gapi",
		"opencv",
		"opencv_modules",
	].iter().copied());

	let modules: Vec<String> = glob(&format!("{}/*.hpp", opencv_dir_as_string))?
		.filter_map(|entry| {
			let entry = entry.expect("Can't get path for module file");
			let module = entry.file_stem()
				.and_then(OsStr::to_str).expect("Can't calculate file stem");
			if ignore_modules.contains(module) {
				None
			} else {
				Some(module.to_string())
			}
		})
		.collect();

	MODULES.set(modules).expect("Can't set MODULES cache");
	Ok(())
}

fn is_core_module(module: &str) -> bool {
	CORE_MODULES.contains(module)
}

fn build_compiler(opencv: &Library) -> cc::Build {
	let mut out = cc::Build::new();
	out.cpp(true)
		.include(&*SRC_CPP_DIR)
		.include(&*OUT_DIR)
		.include(".")
		.flag_if_supported("-Wno-class-memaccess")
		.flag_if_supported("-Wno-deprecated-declarations")
		.flag_if_supported("-Wno-deprecated-copy")
		.flag_if_supported("-Wno-unused-variable")
		.flag_if_supported("-Wno-return-type-c-linkage")
	;
	opencv.include_paths.iter().for_each(|p| { out.include(p); });
	if cfg!(target_env = "msvc") {
		out.flag_if_supported("-std:c++latest")
			.flag_if_supported("-wd4996")
			.flag_if_supported("-wd5054") // deprecated between enumerations of different types
			.flag_if_supported("-wd4190") // has C-linkage specified, but returns UDT 'Result<cv::Rect_<int>>' which is incompatible with C
			.flag_if_supported("-EHsc")
			.flag_if_supported("-bigobj")
		;
	} else {
		out.flag("-std=c++11")
			.flag_if_supported("-Wa,-mbig-obj")
		;
	}
	out
}

fn build_wrapper(opencv: &Library) -> Result<()> {
	for &v in ENV_VARS.iter() {
		println!("cargo:rerun-if-env-changed={}", v);
	}

	let include_exts = &[OsStr::new("cpp"), OsStr::new("hpp")];
	for entry in SRC_CPP_DIR.read_dir()?.map(|e| e.unwrap()) {
		let path = entry.path();
		if path.is_file() && path.extension().map_or(false, |e| include_exts.contains(&e)) {
			if let Some(path) = path.to_str() {
				println!("cargo:rerun-if-changed={}", path);
			}
		}
	}

	let mut cc = build_compiler(opencv);
	let modules = MODULES.get().expect("MODULES not initialized");
	for module in modules.iter().filter(|m| cfg!(feature = "contrib") || is_core_module(m)) {
		cc.file(OUT_DIR.join(format!("{}.cpp", module)));
		let manual_cpp = SRC_CPP_DIR.join(format!("manual-{}.cpp", module));
		if manual_cpp.exists() {
			cc.file(manual_cpp);
		}
	}
	cc.compile("ocvrs");
	Ok(())
}

fn install_wrapper() -> Result<()> {
	let (rust_hub_dir, cpp_hub_dir) = get_versioned_hub_dirs();
	let target_hub_dir = SRC_DIR.join("opencv");
	let target_module_dir = target_hub_dir.join("hub");

	for entry in glob(&format!("{}/*.cpp", cpp_hub_dir.to_str().unwrap()))? {
		let entry = entry?;
		file_copy_to_dir(&entry, &OUT_DIR)?;
	}
	for entry in glob(&format!("{}/*.hpp", cpp_hub_dir.to_str().unwrap()))? {
		let entry = entry?;
		file_copy_to_dir(&entry, &OUT_DIR)?;
	}

	if !cfg!(feature = "docs-only") {
		for entry in glob(&format!("{}/*.rs", target_module_dir.to_str().unwrap()))? {
			let _ = fs::remove_file(entry?);
		}
		for entry in glob(&format!("{}/**/*.rs", rust_hub_dir.to_str().unwrap())).unwrap() {
			let entry = entry?;
			let target_file = target_hub_dir.join(entry.strip_prefix(&rust_hub_dir)?);
			if let Some(target_dir) = target_file.parent() {
				if !target_dir.exists() {
					fs::create_dir_all(target_dir)?;
				}
			}
			fs::copy(&entry, target_file)?;
		}
	}
	Ok(())
}

fn cleanup() -> Result<()> {
	// fixme, shouldn't be needed
	for entry in glob(&format!("{}/*.rs", OUT_DIR.to_string_lossy()))? {
		let _ = fs::remove_file(entry?);
	}
	Ok(())
}

fn main() -> Result<()> {
	let features = [cfg!(feature = "opencv-32"), cfg!(feature = "opencv-34"), cfg!(feature = "opencv-4")].iter().map(|&x| i32::from(x)).sum::<i32>();
	if features != 1 {
		panic!("Please select exactly one of the features: opencv-32, opencv-34, opencv-4");
	}

	#[cfg(feature = "buildtime-bindgen")]
	let generator_build = if cfg!(feature = "clang-runtime") { // start building binding generator as early as possible
		None
		// fixme, https://github.com/twistedfall/opencv-rust/issues/145
		// let cargo_bin = PathBuf::from(env::var_os("CARGO").unwrap_or("cargo".into()));
		// let mut cargo = Command::new(cargo_bin);
		// // generator script is quite slow in debug mode, so we force it to be built in release mode
		// cargo
		// 	.args(&["build", "--release", "--package", "opencv-binding-generator", "--bin", "binding-generator"])
		// 	.env("CARGO_TARGET_DIR", &*OUT_DIR);
		// println!("running: {:?}", &cargo);
		// Some(cargo.spawn()?)
	} else {
		None
	};

	eprintln!("=== Crate version: {:?}", env::var_os("CARGO_PKG_VERSION"));
	eprintln!("=== Environment configuration:");
	for &v in ENV_VARS.iter() {
		eprintln!("===   {} = {:?}", v, env::var_os(v));
	}
	eprintln!("=== Enabled features:");
	let features = env::vars()
		.filter_map(|(mut name, val)| {
			if val != "1" {
				return None;
			}
			const PREFIX: &str = "CARGO_FEATURE_";
			if name.starts_with(PREFIX) {
				name.drain(..PREFIX.len());
				Some(name)
			} else {
				None
			}
		});
	for feature in features {
		eprintln!("===   {}", feature);
	}
	let opencv_header_dir = if cfg!(feature = "opencv-32") {
		MANIFEST_DIR.join("headers/3.2")
	} else if cfg!(feature = "opencv-34") {
		MANIFEST_DIR.join("headers/3.4")
	} else if cfg!(feature = "opencv-4") {
		MANIFEST_DIR.join("headers/4")
	} else {
		panic!("Please select one OpenCV major version using one of the opencv-* features or specify OpenCV header path manually via OPENCV_HEADER_DIR environment var");
	};
	let opencv = if cfg!(feature = "docs-only") {
		Library::probe_from_paths(opencv_header_dir.to_string_lossy().as_ref(), "", "")?
	} else {
		Library::probe()?
	};
	eprintln!("=== OpenCV library configuration: {:#?}", opencv);
	if !cfg!(feature = "docs-only") {
		check_matching_version(&opencv.version)
			.map_err(|e| format!("{}, (version coming from the detected package/environment)", e))?;
	}
	let opencv_header_dir = env::var_os("OPENCV_HEADER_DIR").map(PathBuf::from).unwrap_or_else(|| {
		if cfg!(feature = "buildtime-bindgen") {
			opencv.include_paths.iter()
				.find(|p| p.join("opencv2/core/version.hpp").is_file() || p.join("Headers/core/version.hpp").is_file())
				.expect("Using buildtime-bindgen, but discovered OpenCV include paths is empty or contains non-existent paths").clone()
		} else {
			opencv_header_dir
		}
	});

	make_modules(&opencv_header_dir.join("opencv2").to_string_lossy())?;

	if let Some(version) = get_version_from_headers(&opencv_header_dir) {
		check_matching_version(&version).map_err(|e| format!("{}, (version coming from headers at: {})", e, opencv_header_dir.display()))?;
		eprintln!("=== Found OpenCV library version: {} in headers located at: {}", version, opencv_header_dir.display());
	} else {
		panic!("Unable to find header version in: {}", opencv_header_dir.display())
	}

	#[cfg(feature = "buildtime-bindgen")]
	generator::gen_wrapper(&opencv_header_dir, generator_build)?;
	install_wrapper()?;
	build_wrapper(&opencv)?;
	// -l linker args should be emitted after -l static
	opencv.emit_cargo_metadata();
	cleanup()?;
	Ok(())
}