benchmark-repository-rs/examples/test.rs

extern crate benchmark_repository;
extern crate pretty_env_logger;
extern crate yaml_rust;

use benchmark_repository::BenchmarkRepository;

use std::path::Path;
use yaml_rust::YamlLoader;

fn main()
{
	pretty_env_logger::init();

	let mut benchmark_repository = BenchmarkRepository::new("git@git.luehne.de:patrick/tplp-planning-benchmark.git", Path::new("storage"), "git", "Potassco Bot", "bot@potassco.org");

	let content = benchmark_repository.read_file(Path::new("configurations.yml"), "config").unwrap();
	let configurations = &YamlLoader::load_from_str(&content).unwrap()[0]["configurations"];

	let content = benchmark_repository.read_file(Path::new("instances.yml"), "config").unwrap();
	let instances = &YamlLoader::load_from_str(&content).unwrap()[0];

	for configuration in configurations.as_vec().unwrap()
	{
		for (instance_set_id, instance_set) in instances.as_hash().unwrap()
		{
			for instance in instance_set.as_vec().unwrap()
			{
				let configuration_id = configuration["id"].as_str().unwrap();
				let instance_set_id = instance_set_id.as_str().unwrap();
				let instance_ipc = instance["ipc"].as_str().unwrap();
				let instance_domain = instance["domain"].as_str().unwrap();
				let instance_number = instance["instance"].as_i64().unwrap();

				let file_name_base = format!("{}/{}/{}/{}", configuration_id, instance_ipc, instance_domain, instance_number);
				let file_name_output = format!("{}.out", file_name_base);

				if benchmark_repository.file_exists(Path::new(&file_name_output), "results")
				{
					println!("done: [{}, {}, {}/{}/{}]", configuration_id, instance_set_id, instance_ipc, instance_domain, instance_number);
					continue;
				}

				let test = benchmark_repository.create_autocommit_directory(Path::new(&file_name_base), "results").unwrap();
				println!("{}", test.display());

				println!("to do: [{}, {}, {}/{}/{}]", configuration_id, instance_set_id, instance_ipc, instance_domain, instance_number);
			}
		}
	}

	benchmark_repository.wait_for_autocommit_thread();
}