Function validate

crates/flowtrace-core/src/validate.rs:119–144

(r: &Trace)

}

pub fn validate(r: &Trace) -> Result<()> {
    validate_trace_id(&r.id)?;
    let ident = ident_re();
    for (k, step) in &r.steps {
        if !ident.is_match(k) {
            return Err(TraceError::Validation(format!(
                "step id `{}` invalid",
                k
            )));
        }
        for fs in &step.from_steps {
            if !r.steps.contains_key(fs) {
                return Err(TraceError::Validation(format!(
                    "step `{}` references unknown step `{}`",
                    k, fs
                )));
            }
        }
    }
    if has_cycle(r) {
        return Err(TraceError::Validation(
            "DAG cycle detected in from_steps".into(),
        ));
    }
    Ok(())
}

fn has_cycle(r: &Trace) -> bool {
    use std::collections::HashSet;