// The depgraph package is used to create and model a dependency graph // of nouns. Each noun can represent a service, server, application, // network switch, etc. Nouns can depend on other nouns, and provide // versioning constraints. Nouns can also have various meta data that // may be relevant to their construction or configuration. package depgraph import ( "bytes" "fmt" "strings" "github.com/hashicorp/terraform/digraph" ) // Graph is used to represent a dependency graph. type Graph struct { Name string Meta interface{} Nouns []*Noun Root *Noun } // ValidateError implements the Error interface but provides // additional information on a validation error. type ValidateError struct { // If set, then the graph is missing a single root, on which // there are no depdendencies MissingRoot bool // Unreachable are nodes that could not be reached from // the root noun. Unreachable []*Noun // Cycles are groups of strongly connected nodes, which // form a cycle. This is disallowed. Cycles [][]*Noun } func (v *ValidateError) Error() string { return "The depedency graph is not valid" } // ConstraintError is used to return detailed violation // information from CheckConstraints type ConstraintError struct { Violations []*Violation } func (c *ConstraintError) Error() string { return fmt.Sprintf("%d constraint violations", len(c.Violations)) } // Violation is used to pass along information about // a constraint violation type Violation struct { Source *Noun Target *Noun Dependency *Dependency Constraint Constraint Err error } func (v *Violation) Error() string { return fmt.Sprintf("Constraint %v between %v and %v violated: %v", v.Constraint, v.Source, v.Target, v.Err) } // CheckConstraints walks the graph and ensures that all // user imposed constraints are satisfied. func (g *Graph) CheckConstraints() error { // Ensure we have a root if g.Root == nil { return fmt.Errorf("Graph must be validated before checking constraint violations") } // Create a constraint error cErr := &ConstraintError{} // Walk from the root digraph.DepthFirstWalk(g.Root, func(n digraph.Node) bool { noun := n.(*Noun) for _, dep := range noun.Deps { target := dep.Target for _, constraint := range dep.Constraints { ok, err := constraint.Satisfied(noun, target) if ok { continue } violation := &Violation{ Source: noun, Target: target, Dependency: dep, Constraint: constraint, Err: err, } cErr.Violations = append(cErr.Violations, violation) } } return true }) if cErr.Violations != nil { return cErr } return nil } // String generates a little ASCII string of the graph, useful in // debugging output. func (g *Graph) String() string { var buf bytes.Buffer cb := func(n *Noun, depth int) { buf.WriteString(fmt.Sprintf( "%s%s\n", strings.Repeat(" ", depth), n.Name)) } type listItem struct { n *Noun d int } nodes := []listItem{{g.Root, 0}} for len(nodes) > 0 { // Pop current node n := len(nodes) current := nodes[n-1] nodes = nodes[:n-1] // Visit cb(current.n, current.d) // Traverse for _, dep := range current.n.Deps { nodes = append(nodes, listItem{ n: dep.Target, d: current.d + 1, }) } } return buf.String() } // Validate is used to ensure that a few properties of the graph are not violated: // 1) There must be a single "root", or source on which nothing depends. // 2) All nouns in the graph must be reachable from the root // 3) The graph must be cycle free, meaning there are no cicular dependencies func (g *Graph) Validate() error { // Convert to node list nodes := make([]digraph.Node, len(g.Nouns)) for i, n := range g.Nouns { nodes[i] = n } // Create a validate erro vErr := &ValidateError{} // Search for all the sources, if we have only 1, it must be the root if sources := digraph.Sources(nodes); len(sources) != 1 { vErr.MissingRoot = true goto CHECK_CYCLES } else { g.Root = sources[0].(*Noun) } // Check reachability if unreached := digraph.Unreachable(g.Root, nodes); len(unreached) > 0 { vErr.Unreachable = make([]*Noun, len(unreached)) for i, u := range unreached { vErr.Unreachable[i] = u.(*Noun) } } CHECK_CYCLES: // Check for cycles if cycles := digraph.StronglyConnectedComponents(nodes, true); len(cycles) > 0 { vErr.Cycles = make([][]*Noun, len(cycles)) for i, cycle := range cycles { group := make([]*Noun, len(cycle)) for j, n := range cycle { group[j] = n.(*Noun) } vErr.Cycles[i] = group } } // Return the detailed error if vErr.MissingRoot || vErr.Unreachable != nil || vErr.Cycles != nil { return vErr } return nil }