Struct PipelineLoader 

pub struct PipelineLoader { /* private fields */ }

Implementations

impl PipelineLoader

pub fn new(qed_dir: impl AsRef<Path>) -> Self

Construct a loader rooted at qed_dir. Reads <qed_dir>/registries.toml + <qed_dir>/peers.toml opportunistically — missing files are fine. A malformed file surfaces on the first load* call rather than at construction so callers don’t have to handle the error twice.

pub fn with_registries(self, registries: RegistryConfig) -> Self

Replace the auto-loaded registry config. Useful in tests when the fixture qed_dir doesn’t carry a registries.toml.

pub fn with_peers(self, peers: PeerConfig) -> Self

Replace the auto-loaded peer config (R494-F2). Tests construct a fixture loader that already knows about its sibling peer camps without needing a peers.toml on disk.

pub fn load(&self, name: &str) -> Result<Pipeline, ConfigError>

Load a pipeline by name. Resolution order:

1. <qed_dir>/P{n}-<name>.toml (or legacy <name>.toml)
2. <workspace>/.github/workflows/<name>.yml (or .yaml), synthesised into a one-step StepKind::GhaWorkflow pipeline.

pub fn has_camp_file(&self, name: &str) -> bool

Returns true when a camp-level TOML file exists for name (prefixed or legacy form).

pub fn workspace_root(&self) -> PathBuf

Camp root, derived from <qed_dir>/../.. (the conventional <camp>/.yah/qed layout). Falls back to qed_dir itself when the loader is rooted somewhere unusual (test fixtures, in-memory dirs).

pub fn list_gha_workflows(&self) -> Vec<GhaWorkflowEntry>

Walk <workspace>/.github/workflows/*.yml and return parsed workflows. Files that fail to parse are skipped (logged at warn) so a single malformed workflow doesn’t blank the whole catalog.

pub fn list_all(&self) -> Result<Vec<String>, ConfigError>

List all pipeline names from <qed_dir>/*.toml, sorted by P-number prefix (unprefixed files last).

pub fn load_and_validate_graph( &self, name: &str, ) -> Result<Pipeline, ConfigError>

Load a pipeline by name AND walk its sub-pipeline graph for cycles and excessive nesting (R488-F1/F2). Use this before handing a pipeline to PipelineRunner when you want parse-time confirmation that the SubPipeline graph is well-formed; plain Self::load skips the walk so loading individual children doesn’t re-validate the whole graph repeatedly.

pub fn load_p_numbers(&self, names: &[String]) -> HashMap<String, u32>

Return P-numbers for the requested pipeline names. Numbers come from the numeric prefix of P{n}-{name}.toml files in <qed_dir>. Names with no prefixed file return no entry; callers already treat p_numbers.get(name) as Option<u32>.

pub fn list_files(&self) -> Result<Vec<String>, ConfigError>

List only custom pipeline files from .yah/qed/ (excludes built-ins), returning the pipeline name (prefix stripped).

pub fn parse_from_path(&self, path: &Path) -> Result<Pipeline, ConfigError>

Public helper: parse a pipeline directly from a file path, bypassing the <qed_dir>/P{n}-<name>.toml lookup. Used by qed plan <path>.toml to preview drafts that haven’t been moved into the camp pipeline directory yet.

Trait Implementations

impl Clone for PipelineLoader

fn clone(&self) -> PipelineLoader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.