monochange 0.6.0

use std::collections::BTreeMap;
use std::collections::BTreeSet;
use std::fmt::Write as _;

use monochange_analysis::AnalysisConfig;
use monochange_analysis::ChangeFrame;
use monochange_core::CompatibilityAssessment;
use monochange_core::PackageRecord;

use super::*;
use crate::changeset_policy::configuration_package_records;

pub(crate) async fn diagnose_changesets(
	root: &Path,
	requested: &[String],
) -> MonochangeResult<ChangesetDiagnosticsReport> {
	let configuration = load_workspace_configuration(root)?;

	let changeset_paths = if requested.is_empty() {
		discover_changeset_paths(root, false)?
			.into_iter()
			.map(|path| root.join(path))
			.collect::<Vec<_>>()
	} else {
		let mut resolved = Vec::new();

		for path in requested {
			resolved.push(resolve_changeset_path(root, path)?);
		}

		resolved.sort();
		resolved.dedup();
		resolved
	};

	let loaded_changesets = load_diagnostic_changesets(root, &configuration, &changeset_paths)?;

	let mut changesets = build_prepared_changesets(root, loaded_changesets);

	if let Some(source) = configuration.source.as_ref() {
		hosted_sources::configured_hosted_source_adapter(source)
			.enrich_changeset_context(source, &mut changesets)
			.await;
	}

	let requested_changesets = changesets
		.iter()
		.map(|changeset| changeset.path.clone())
		.collect();

	Ok(ChangesetDiagnosticsReport {
		requested_changesets,
		changesets,
	})
}

fn load_diagnostic_changesets(
	root: &Path,
	configuration: &monochange_core::WorkspaceConfiguration,
	changeset_paths: &[PathBuf],
) -> MonochangeResult<Vec<monochange_config::LoadedChangesetFile>> {
	match load_diagnostic_changesets_with_packages(
		configuration,
		changeset_paths,
		&configuration_package_records(configuration),
	) {
		Ok(loaded_changesets)
			if !diagnostics_need_discovered_package_versions(&loaded_changesets) =>
		{
			Ok(loaded_changesets)
		}
		Ok(_) | Err(_) => {
			let discovery = discover_workspace(root)?;
			load_diagnostic_changesets_with_packages(
				configuration,
				changeset_paths,
				&discovery.packages,
			)
		}
	}
}

fn load_diagnostic_changesets_with_packages(
	configuration: &monochange_core::WorkspaceConfiguration,
	changeset_paths: &[PathBuf],
	packages: &[PackageRecord],
) -> MonochangeResult<Vec<monochange_config::LoadedChangesetFile>> {
	let changeset_load_context =
		monochange_config::build_changeset_load_context(configuration, packages);
	changeset_paths
		.iter()
		.map(|path| {
			monochange_config::load_changeset_file_with_context(path, &changeset_load_context)
		})
		.collect()
}

fn diagnostics_need_discovered_package_versions(
	loaded_changesets: &[monochange_config::LoadedChangesetFile],
) -> bool {
	loaded_changesets.iter().any(|changeset| {
		changeset
			.signals
			.iter()
			.any(|signal| signal.explicit_version.is_some() && signal.requested_bump.is_none())
	})
}

#[must_use = "the changeset path result must be checked"]
pub(crate) fn resolve_changeset_path(root: &Path, requested: &str) -> MonochangeResult<PathBuf> {
	let requested_is_absolute = Path::new(requested).is_absolute();

	let normalized = if requested_is_absolute {
		requested.to_string()
	} else {
		normalize_changed_path(requested)
	};

	if normalized.is_empty() {
		return Err(MonochangeError::Config(
			"changeset path cannot be empty".to_string(),
		));
	}

	let candidate = if requested_is_absolute {
		Path::new(requested)
	} else {
		Path::new(&normalized)
	};

	let candidates = if candidate.is_absolute() {
		vec![candidate.to_path_buf()]
	} else {
		let mut candidates = vec![root.join(candidate)];

		if !normalized.starts_with(CHANGESET_DIR) {
			candidates.push(root.join(CHANGESET_DIR).join(candidate));
		}

		candidates
	};

	for candidate in candidates {
		let Some(relative_candidate) = relative_to_root(root, &candidate) else {
			continue;
		};

		if !is_changeset_markdown_path(&relative_candidate.to_string_lossy()) {
			continue;
		}

		if candidate.exists() {
			return Ok(candidate);
		}
	}

	Err(MonochangeError::Config(format!(
		"requested changeset `{requested}` does not exist"
	)))
}

pub(crate) fn render_changeset_diagnostics(report: &ChangesetDiagnosticsReport) -> String {
	if report.changesets.is_empty() {
		return "no matching changesets found".to_string();
	}

	let mut rendered = String::new();

	for (index, changeset) in report.changesets.iter().enumerate() {
		if index > 0 {
			rendered.push('\n');
		}

		let change_summary = changeset.summary.as_deref().unwrap_or("<missing summary>");

		let _ = writeln!(&mut rendered, "changeset: {}", changeset.path.display());
		let _ = writeln!(&mut rendered, "  summary: {change_summary}");

		if let Some(details) = &changeset.details {
			let _ = writeln!(&mut rendered, "  details: {details}");
		}

		if !changeset.targets.is_empty() {
			rendered.push_str("  targets:\n");

			for target in &changeset.targets {
				let _ = match target.bump {
					Some(bump) => {
						writeln!(
							&mut rendered,
							"  - {} {} (bump: {}, origin: {})",
							target.kind, target.id, bump, target.origin,
						)
					}
					None => {
						writeln!(
							&mut rendered,
							"  - {} {} (bump: auto, origin: {})",
							target.kind, target.id, target.origin,
						)
					}
				};

				if !target.caused_by.is_empty() {
					rendered.push_str("    caused by: ");
					push_comma_separated(
						&mut rendered,
						target.caused_by.iter().map(String::as_str),
					);
					rendered.push('\n');
				}

				if !target.evidence_refs.is_empty() {
					rendered.push_str("    evidence: ");
					push_comma_separated(
						&mut rendered,
						target.evidence_refs.iter().map(String::as_str),
					);
					rendered.push('\n');
				}
			}
		}

		if let Some(context) = &changeset.context {
			push_changeset_context_lines(&mut rendered, context);
		}
	}

	rendered.pop();
	rendered
}

fn push_changeset_context_lines(rendered: &mut String, context: &ChangesetContext) {
	if let Some(introduced) = context
		.introduced
		.as_ref()
		.and_then(|revision| revision.commit.as_ref())
	{
		let _ = writeln!(rendered, "  introduced: {}", introduced.short_sha);
	}

	if let Some(last_updated) = context
		.last_updated
		.as_ref()
		.and_then(|revision| revision.commit.as_ref())
	{
		let _ = writeln!(rendered, "  last-updated: {}", last_updated.short_sha);
	}

	let review_request = context
		.introduced
		.as_ref()
		.and_then(|revision| revision.review_request.as_ref())
		.or_else(|| {
			context
				.last_updated
				.as_ref()
				.and_then(|revision| revision.review_request.as_ref())
		});

	if let Some(review_request) = review_request {
		let _ = match &review_request.url {
			Some(url) => {
				writeln!(
					rendered,
					"  review request: {} ({})",
					review_request.id, url,
				)
			}
			None => writeln!(rendered, "  review request: {}", review_request.id),
		};
	}

	if context.related_issues.is_empty() {
		return;
	}

	rendered.push_str("  related issues: ");
	push_comma_separated(
		rendered,
		context.related_issues.iter().map(|issue| issue.id.as_str()),
	);
	rendered.push('\n');
}

fn push_comma_separated<'a>(rendered: &mut String, values: impl Iterator<Item = &'a str>) {
	let mut separator = "";

	for value in values {
		rendered.push_str(separator);
		rendered.push_str(value);
		separator = ", ";
	}
}

#[must_use = "the discovery result must be checked"]
pub(crate) fn discover_changeset_paths(
	root: &Path,
	allow_empty: bool,
) -> MonochangeResult<Vec<PathBuf>> {
	let changeset_dir = root.join(CHANGESET_DIR);

	if !changeset_dir.exists() {
		if allow_empty {
			return Ok(Vec::new());
		}
		return Err(MonochangeError::Config(format!(
			"no markdown changesets found under {CHANGESET_DIR}"
		)));
	}

	let mut changeset_paths = fs::read_dir(&changeset_dir)
		.map_err(|error| {
			MonochangeError::Io(format!(
				"failed to read {}: {error}",
				changeset_dir.display()
			))
		})?
		.filter_map(Result::ok)
		.map(|entry| entry.path())
		.filter(|path| path.extension().and_then(|value| value.to_str()) == Some("md"))
		.collect::<Vec<_>>();

	changeset_paths.sort();

	if changeset_paths.is_empty() && !allow_empty {
		return Err(MonochangeError::Config(format!(
			"no markdown changesets found under {CHANGESET_DIR}"
		)));
	}

	Ok(changeset_paths)
}

pub(crate) fn build_prepared_changesets(
	root: &Path,
	loaded_changesets: Vec<monochange_config::LoadedChangesetFile>,
) -> Vec<PreparedChangeset> {
	let relative_paths = loaded_changesets
		.iter()
		.map(|changeset| root_relative(root, &changeset.path))
		.collect::<Vec<_>>();

	// Batch-load all changeset git context in a single pass instead of
	// spawning two git-log subprocesses per changeset (which was O(2N)
	// subprocess spawns and dominated release planning time).
	let mut git_contexts = batch_load_changeset_contexts(root, &relative_paths).into_iter();

	loaded_changesets
		.into_iter()
		.zip(relative_paths)
		.map(|(changeset, relative_path)| {
			PreparedChangeset {
				path: relative_path,
				summary: changeset.summary,
				details: changeset.details,
				targets: changeset
					.targets
					.into_iter()
					.map(|target| {
						let monochange_config::LoadedChangesetTarget {
							id,
							kind,
							bump,
							explicit_version: _,
							origin,
							evidence_refs,
							change_type,
							caused_by,
						} = target;

						PreparedChangesetTarget {
							id,
							kind,
							bump,
							origin,
							evidence_refs,
							change_type,
							caused_by,
						}
					})
					.collect(),
				context: git_contexts.next(),
			}
		})
		.collect()
}

/// Load git context for all changesets in two batched git-log calls instead
/// of 2*N individual subprocess spawns.
#[tracing::instrument(skip_all, fields(count = relative_paths.len()))]
fn batch_load_changeset_contexts(root: &Path, relative_paths: &[PathBuf]) -> Vec<ChangesetContext> {
	if relative_paths.is_empty() {
		return Vec::new();
	}

	// Skip git operations entirely if there's no git repository.
	if !root.join(".git").exists() {
		return relative_paths
			.iter()
			.map(|_| {
				ChangesetContext {
					provider: HostingProviderKind::GenericGit,
					host: None,
					capabilities: HostingCapabilities::default(),
					introduced: None,
					last_updated: None,
					related_issues: Vec::new(),
				}
			})
			.collect();
	}

	let (introduced_map, last_updated_map) = batch_git_log(root, relative_paths);

	relative_paths
		.iter()
		.map(|path| {
			let path_str = path.to_string_lossy();

			ChangesetContext {
				provider: HostingProviderKind::GenericGit,
				host: None,
				capabilities: HostingCapabilities::default(),
				introduced: introduced_map.get(path_str.as_ref()).cloned(),
				last_updated: last_updated_map.get(path_str.as_ref()).cloned(),
				related_issues: Vec::new(),
			}
		})
		.collect()
}

/// Run a single `git log` command covering the entire `.changeset/` directory
/// and return both the introduced and last-updated revision maps.
///
/// This replaces two independent history walks with one pass over the same git
/// log stream. The first time we see a file is its latest update; the last
/// added entry we see for the file is the commit that introduced it.
#[tracing::instrument(skip_all, fields(count = paths.len()))]
fn batch_git_log(
	root: &Path,
	paths: &[PathBuf],
) -> (
	std::collections::HashMap<String, ChangesetRevision>,
	std::collections::HashMap<String, ChangesetRevision>,
) {
	use std::collections::HashMap;

	if paths.is_empty() {
		return (HashMap::new(), HashMap::new());
	}

	let mut command = ProcessCommand::new("git");
	command
		.current_dir(root)
		.arg("log")
		.arg("--format=%H%x1f%an%x1f%ae%x1f%aI%x1f%cI")
		.arg("--name-status")
		// Existing pending changesets only need the commits that added or updated
		// them. Filtering out deletes, type changes, and other unrelated status
		// records keeps large history scans smaller without changing introduced or
		// last-updated attribution for files still present in `.changeset/`.
		.arg("--diff-filter=AM");
	command.arg("--").arg(".changeset/");

	let output = match command.output() {
		Ok(output) if output.status.success() => output,
		_ => return (HashMap::new(), HashMap::new()),
	};
	parse_batch_git_log_bytes(&output.stdout, paths)
}

fn parse_batch_git_log_bytes(
	stdout: &[u8],
	paths: &[PathBuf],
) -> (
	std::collections::HashMap<String, ChangesetRevision>,
	std::collections::HashMap<String, ChangesetRevision>,
) {
	use std::collections::HashMap;

	let Ok(stdout) = std::str::from_utf8(stdout) else {
		return (HashMap::new(), HashMap::new());
	};
	parse_batch_git_log_output(stdout, paths)
}

fn parse_batch_git_log_output(
	stdout: &str,
	paths: &[PathBuf],
) -> (
	std::collections::HashMap<String, ChangesetRevision>,
	std::collections::HashMap<String, ChangesetRevision>,
) {
	use std::collections::HashMap;

	let wanted_paths: std::collections::HashSet<String> = paths
		.iter()
		.map(|p| p.to_string_lossy().into_owned())
		.collect();

	// Parse the git log output. Format is blocks separated by blank lines:
	// <sha>\x1f<name>\x1f<email>\x1f<author_date>\x1f<commit_date>
	// <status>\t<filename>
	//
	// (blank line between commits)
	let mut introduced = HashMap::new();
	let mut last_updated = HashMap::new();

	let mut current_fields: Option<Vec<&str>> = None;
	for line in stdout.lines() {
		let trimmed = line.trim();
		if trimmed.is_empty() {
			// Blank lines separate the header from filenames AND separate
			// commits from each other. Don't reset current_fields here —
			// a new header line (containing \x1f) will replace it.
			continue;
		}
		if trimmed.contains('\u{1f}') {
			// This is a commit header line — start a new commit block.
			current_fields = Some(trimmed.split('\u{1f}').collect());
			continue;
		}
		// This is a filename line associated with the current commit.
		let Some(ref fields) = current_fields else {
			continue;
		};
		if fields.len() != 5 {
			continue;
		}
		let mut parts = trimmed.splitn(2, '\t');
		let Some(status) = parts.next() else {
			continue;
		};
		let Some(file_path) = parts.next() else {
			continue;
		};
		if !wanted_paths.contains(file_path) {
			continue;
		}
		let [sha, author_name, author_email, authored_at, committed_at] = fields.as_slice() else {
			continue;
		};
		let revision = ChangesetRevision {
			actor: Some(HostedActorRef {
				provider: HostingProviderKind::GenericGit,
				host: None,
				id: None,
				login: None,
				display_name: Some((*author_name).to_string()),
				url: None,
				source: HostedActorSourceKind::CommitAuthor,
			}),
			commit: Some(HostedCommitRef {
				provider: HostingProviderKind::GenericGit,
				host: None,
				sha: (*sha).to_string(),
				short_sha: short_commit_sha(sha),
				url: None,
				author_name: Some((*author_name).to_string()),
				author_email: Some((*author_email).to_string()),
				authored_at: Some((*authored_at).to_string()),
				committed_at: Some((*committed_at).to_string()),
			}),
			review_request: None,
		};
		last_updated
			.entry(file_path.to_string())
			.or_insert_with(|| revision.clone());
		if status == "A" {
			introduced.insert(file_path.to_string(), revision);
		}
	}

	(introduced, last_updated)
}

pub(crate) fn short_commit_sha(sha: &str) -> String {
	sha.chars().take(7).collect()
}

#[tracing::instrument(skip_all)]
pub(crate) fn build_release_plan_from_signals(
	configuration: &monochange_core::WorkspaceConfiguration,
	discovery: &DiscoveryReport,
	change_signals: &[ChangeSignal],
) -> MonochangeResult<ReleasePlan> {
	#[cfg(feature = "cargo")]
	let rust_provider = RustSemverProvider;
	#[cfg(feature = "cargo")]
	let providers: [&dyn CompatibilityProvider; 1] = [&rust_provider];
	#[cfg(feature = "cargo")]
	let compatibility_evidence = collect_assessments(&providers, &discovery.packages, change_signals);
	#[cfg(not(feature = "cargo"))]
	let compatibility_evidence = Vec::new();

	let (semantic_evidence, semantic_warnings) = semantic_compatibility_evidence(
		&discovery.workspace_root,
		&discovery.packages,
		change_signals,
	);
	let mut compatibility_evidence = compatibility_evidence;
	compatibility_evidence.extend(semantic_evidence);

	let mut plan = build_release_plan(
		&discovery.workspace_root,
		&discovery.packages,
		&discovery.dependencies,
		&discovery.version_groups,
		change_signals,
		&compatibility_evidence,
		configuration.defaults.parent_bump,
		configuration.defaults.strict_version_conflicts,
	)?;
	plan.warnings.extend(semantic_warnings);

	Ok(plan)
}

fn semantic_compatibility_evidence(
	root: &Path,
	packages: &[PackageRecord],
	change_signals: &[ChangeSignal],
) -> (Vec<CompatibilityAssessment>, Vec<String>) {
	let frame = match ChangeFrame::detect(root) {
		Ok(frame) => frame,
		Err(error) => {
			if !root.join(".git").exists() {
				return (Vec::new(), Vec::new());
			}
			return (
				Vec::new(),
				vec![format!(
					"semantic SemVer analysis was skipped because the change frame could not be detected: {error}"
				)],
			);
		}
	};
	let changed_files = frame.changed_files(root).unwrap_or_default();
	if !has_semantic_guardrail_candidate(&changed_files) {
		return (Vec::new(), Vec::new());
	}

	let analysis =
		match monochange_analysis::analyze_changes(root, &frame, &AnalysisConfig::default()) {
			Ok(analysis) => analysis,
			Err(error) => {
				return (
					Vec::new(),
					vec![format!(
						"semantic SemVer analysis was skipped because semantic analysis failed: {error}"
					)],
				);
			}
		};
	let changeset_packages = change_signals
		.iter()
		.map(|signal| signal.package_id.as_str())
		.collect::<BTreeSet<_>>();
	let semantic_package_targets = semantic_package_targets(packages, &changeset_packages);
	let mut warnings = Vec::new();
	let evidence = analysis
		.package_analyses
		.values()
		.filter_map(|package_analysis| {
			let Some(target_package_id) = semantic_package_targets
				.get(package_analysis.package_id.as_str())
				.map(String::as_str)
			else {
				if !package_analysis.semantic_changes.is_empty() {
					warnings.push(format!(
						"semantic SemVer analysis found changes for `{}` but no pending changeset targets that package",
						package_analysis.package_id
					));
				}
				return None;
			};
			let analyzer_id = package_analysis
				.analyzer_id
				.as_deref()
				.unwrap_or("semantic-analysis");
			let provider_id = format!("semantic-analysis:{analyzer_id}");
			monochange_semver::semantic_changes_assessment(
				target_package_id,
				&provider_id,
				&package_analysis.semantic_changes,
			)
		})
		.collect();

	(evidence, warnings)
}

pub(crate) fn has_semantic_guardrail_candidate(changed_files: &[PathBuf]) -> bool {
	changed_files.iter().any(|path| {
		let Some(extension) = path.extension().and_then(|extension| extension.to_str()) else {
			return false;
		};
		matches!(
			extension,
			"cjs"
				| "dart" | "js"
				| "jsx" | "json"
				| "mjs" | "rs"
				| "toml" | "ts"
				| "tsx" | "yaml"
				| "yml"
		)
	})
}

fn semantic_package_targets(
	packages: &[PackageRecord],
	changeset_packages: &BTreeSet<&str>,
) -> BTreeMap<String, String> {
	let mut targets = BTreeMap::new();
	for package in packages {
		if !changeset_packages.contains(package.id.as_str()) {
			continue;
		}
		targets.insert(package.id.clone(), package.id.clone());
		targets.insert(package.name.clone(), package.id.clone());
	}
	targets
}

pub(crate) fn canonical_change_packages(
	root: &Path,
	package_refs: &[String],
	configuration: &monochange_core::WorkspaceConfiguration,
	packages: &[PackageRecord],
) -> MonochangeResult<Vec<String>> {
	let mut canonical_packages = Vec::new();
	for package_ref in package_refs {
		let canonical_key = if configuration
			.groups
			.iter()
			.any(|group| group.id == *package_ref)
			|| configuration
				.packages
				.iter()
				.any(|package| package.id == *package_ref)
		{
			package_ref.clone()
		} else {
			let package_id = resolve_package_reference(package_ref, root, packages)?;
			let package = packages
				.iter()
				.find(|package| package.id == package_id)
				.ok_or_else(|| {
					MonochangeError::Config(format!("failed to resolve package `{package_ref}`"))
				})?;
			package
				.metadata
				.get("config_id")
				.cloned()
				.unwrap_or_else(|| package.name.clone())
		};
		if !canonical_packages.contains(&canonical_key) {
			canonical_packages.push(canonical_key);
		}
	}
	Ok(canonical_packages)
}

pub(crate) fn released_package_names(
	packages: &[PackageRecord],
	plan: &ReleasePlan,
) -> Vec<String> {
	let package_by_id = packages
		.iter()
		.map(|package| (package.id.as_str(), package))
		.collect::<BTreeMap<_, _>>();
	let mut released_packages = plan
		.decisions
		.iter()
		.filter(|decision| decision.recommended_bump.is_release())
		.filter_map(|decision| {
			package_by_id
				.get(decision.package_id.as_str())
				.map(|package| package.name.clone())
		})
		.collect::<Vec<_>>();
	released_packages.sort();
	released_packages.dedup();
	released_packages
}

pub type PackageChangelogTargets = BTreeMap<String, ChangelogTarget>;
pub type GroupChangelogTargets = BTreeMap<String, ChangelogTarget>;

pub(crate) fn resolve_changelog_targets(
	configuration: &monochange_core::WorkspaceConfiguration,
	packages: &[PackageRecord],
) -> MonochangeResult<(PackageChangelogTargets, GroupChangelogTargets)> {
	let mut package_targets = BTreeMap::new();
	let mut group_targets = BTreeMap::new();

	for package_definition in &configuration.packages {
		let Some(changelog_path) = &package_definition.changelog else {
			continue;
		};
		let package_id =
			resolve_package_reference(&package_definition.id, &configuration.root_path, packages)?;
		package_targets.insert(
			package_id,
			ChangelogTarget {
				path: resolve_config_path(&configuration.root_path, &changelog_path.path),
				format: changelog_path.format,
				initial_header: changelog_path.initial_header.clone(),
			},
		);
	}
	for group_definition in &configuration.groups {
		let Some(changelog_path) = &group_definition.changelog else {
			continue;
		};
		group_targets.insert(
			group_definition.id.clone(),
			ChangelogTarget {
				path: resolve_config_path(&configuration.root_path, &changelog_path.path),
				format: changelog_path.format,
				initial_header: changelog_path.initial_header.clone(),
			},
		);
	}

	Ok((package_targets, group_targets))
}

pub(crate) fn resolve_config_path(root: &Path, path: &Path) -> PathBuf {
	if path.is_absolute() {
		path.to_path_buf()
	} else {
		root.join(path)
	}
}

pub(crate) fn default_change_path(root: &Path, package_refs: &[String]) -> PathBuf {
	default_change_path_for_ref(root, package_refs.first().map(String::as_str))
}

pub(crate) fn default_change_path_for_ref(root: &Path, package_ref: Option<&str>) -> PathBuf {
	let timestamp = SystemTime::now()
		.duration_since(UNIX_EPOCH)
		.map_or(0, |duration| duration.as_secs());
	let slug_source = package_ref.unwrap_or("change");
	let mut slug = String::with_capacity(slug_source.len());
	for character in slug_source.chars() {
		if character.is_ascii_alphanumeric() {
			slug.push(character.to_ascii_lowercase());
		} else {
			slug.push('-');
		}
	}
	let slug = slug.trim_matches('-');
	let slug = if slug.is_empty() { "change" } else { slug };
	root.join(CHANGESET_DIR)
		.join(format!("{timestamp}-{slug}.md"))
}

#[allow(clippy::too_many_arguments)]
pub(crate) fn render_changeset_markdown(
	configuration: &monochange_core::WorkspaceConfiguration,
	package_refs: &[String],
	bump: BumpSeverity,
	version: Option<&str>,
	reason: &str,
	change_type: Option<&str>,
	caused_by: &[String],
	details: Option<&str>,
) -> MonochangeResult<String> {
	let mut rendered = String::from("---\n");
	for package in package_refs {
		push_change_target_markdown(
			&mut rendered,
			configuration,
			package,
			bump,
			version,
			change_type,
			caused_by,
		)?;
	}

	rendered.push_str("---\n\n# ");
	rendered.push_str(reason);
	rendered.push('\n');
	if let Some(details) = details.map(str::trim).filter(|value| !value.is_empty()) {
		rendered.push('\n');
		rendered.push_str(details);
		rendered.push('\n');
	}
	Ok(rendered)
}

#[cfg(test)]
#[path = "__tests__/changesets_tests.rs"]
mod tests;