Function synchronize

src/sync/mod.rs:61–133

(maybe_config: Result<Config, AppError>, only_new: bool, ff_merge: bool, tags: &BTreeSet<String>, worker: i32)

}

pub fn synchronize(maybe_config: Result<Config, AppError>, only_new: bool, ff_merge: bool, tags: &BTreeSet<String>, worker: i32) -> Result<(), AppError> {
	eprintln!("Synchronizing everything");
	if !ssh_agent_running() {
		eprintln!("SSH Agent not running. Process may hang.")
	}
	let config = Arc::new(maybe_config?);

	let projects: Vec<Project> = config.projects.values().map(ToOwned::to_owned).collect();
	let q: Arc<SegQueue<Project>> = Arc::new(SegQueue::new());
	let projects_count = projects.len() as u64;

	projects
		.into_iter()
		.filter(|p| tags.is_empty() || p.tags.clone().unwrap_or_default().intersection(tags).count() > 0)
		.for_each(|p| q.push(p));

	let spinner_style = ProgressStyle::default_spinner()
		.tick_chars("⣾⣽⣻⢿⡿⣟⣯⣷⣿")
		.template("{prefix:.bold.dim} {spinner} {wide_msg}")
		.map_err(|e| AppError::RuntimeError(format!("Invalid Template: {}", e)))?;

	let m = MultiProgress::new();
	m.set_draw_target(ProgressDrawTarget::stderr());

	let job_results: Arc<SegQueue<Result<(), AppError>>> = Arc::new(SegQueue::new());
	let progress_bars = (1..=worker).map(|i| {
		let pb = m.add(ProgressBar::new(projects_count));
		pb.set_style(spinner_style.clone());
		pb.set_prefix(format!("[{: >2}/{}]", i, worker));
		pb.set_message("initializing...");
		pb.tick();
		pb.enable_steady_tick(Duration::from_millis(250));
		pb
	});
	let mut thread_handles: Vec<thread::JoinHandle<()>> = Vec::new();
	for pb in progress_bars {
		let job_q = Arc::clone(&q);
		let job_config = Arc::clone(&config);
		let job_result_queue = Arc::clone(&job_results);
		thread_handles.push(thread::spawn(move || {
			let mut job_result: Result<(), AppError> = Result::Ok(());
			loop {
				if let Some(project) = job_q.pop() {
					pb.set_message(project.name.to_string());
					let sync_result = sync_project(&job_config, &project, only_new, ff_merge);
					let msg = match sync_result {
						Ok(_) => format!("DONE: {}", project.name),
						Err(ref e) => format!("FAILED: {} - {}", project.name, e),
					};
					pb.println(&msg);
					job_result = job_result.and(sync_result);
				} else {
					pb.finish_and_clear();
					break;
				}
			}
			job_result_queue.push(job_result);
		}));