feat: adding device sync to Nautobot Operator

go/nautobotop/api/v1alpha1/nautobot_types.go

@@ -51,6 +51,7 @@ type NautobotSpec struct {
 	RoleRef            []ConfigMapRef    `json:"roleRef,omitempty"`
 	TenantGroupRef     []ConfigMapRef    `json:"tenantGroupRef,omitempty"`
 	TenantRef          []ConfigMapRef    `json:"tenantRef,omitempty"`
+	DeviceRef          []ConfigMapRef    `json:"deviceRef,omitempty"`
 }
 
 // NautobotStatus defines the observed state of Nautobot.

go/nautobotop/config/crd/bases/sync.rax.io_nautobots.yaml

@@ -117,6 +117,31 @@ spec:
                   - configMapSelector
                   type: object
                 type: array
+              deviceRef:
+                items:
+                  description: ConfigMapRef defines a reference to a specific ConfigMap
+                  properties:
+                    configMapSelector:
+                      description: The name of the ConfigMap resource being referred
+                        to
+                      properties:
+                        key:
+                          description: The key in the ConfigMap data
+                          type: string
+                        name:
+                          description: The name of the ConfigMap
+                          minLength: 1
+                          type: string
+                        namespace:
+                          description: The namespace where the ConfigMap resides
+                          type: string
+                      required:
+                      - name
+                      type: object
+                  required:
+                  - configMapSelector
+                  type: object
+                type: array
               deviceTypeRef:
                 items:
                   description: ConfigMapRef defines a reference to a specific ConfigMap

go/nautobotop/helm/crds/clients.yaml

@@ -117,6 +117,31 @@ spec:
                   - configMapSelector
                   type: object
                 type: array
+              deviceRef:
+                items:
+                  description: ConfigMapRef defines a reference to a specific ConfigMap
+                  properties:
+                    configMapSelector:
+                      description: The name of the ConfigMap resource being referred
+                        to
+                      properties:
+                        key:
+                          description: The key in the ConfigMap data
+                          type: string
+                        name:
+                          description: The name of the ConfigMap
+                          minLength: 1
+                          type: string
+                        namespace:
+                          description: The namespace where the ConfigMap resides
+                          type: string
+                      required:
+                      - name
+                      type: object
+                  required:
+                  - configMapSelector
+                  type: object
+                type: array
               deviceTypeRef:
                 items:
                   description: ConfigMapRef defines a reference to a specific ConfigMap

go/nautobotop/internal/controller/dag.go

@@ -0,0 +1,90 @@
+package controller
+
+import (
+	"fmt"
+	"sort"
+)
+
+// ResourceNode defines a sync resource with explicit dependency declarations.
+// The topological sort uses DependsOn to determine execution order automatically.
+type ResourceNode struct {
+	Name      string
+	DependsOn []string
+}
+
+// topologicalSort using Kahn's algorithm here
+// a deterministic execution order that respects all declared dependencies.
+//
+// Returns an error if:
+//   - A cycle is detected (not a DAG)
+//   - A node references a dependency that doesn't exist in the input
+//   - Duplicate node names are provided
+func topologicalSort(nodes []ResourceNode) ([]string, error) {
+	if len(nodes) == 0 {
+		return nil, nil
+	}
+	nodeSet := make(map[string]struct{}, len(nodes))
+	for _, node := range nodes {
+		if _, exists := nodeSet[node.Name]; exists {
+			return nil, fmt.Errorf("duplicate node name: %q", node.Name)
+		}
+		nodeSet[node.Name] = struct{}{}
+	}
+
+	for _, node := range nodes {
+		for _, dep := range node.DependsOn {
+			if _, exists := nodeSet[dep]; !exists {
+				return nil, fmt.Errorf("node %q depends on %q which does not exist", node.Name, dep)
+			}
+		}
+	}
+
+	inDegree := make(map[string]int, len(nodes))
+	dependents := make(map[string][]string, len(nodes))
+
+	for _, node := range nodes {
+		inDegree[node.Name] = len(node.DependsOn)
+		for _, dep := range node.DependsOn {
+			dependents[dep] = append(dependents[dep], node.Name)
+		}
+	}
+
+	var queue []string
+	for _, node := range nodes {
+		if inDegree[node.Name] == 0 {
+			queue = append(queue, node.Name)
+		}
+	}
+	sort.Strings(queue)
+
+	result := make([]string, 0, len(nodes))
+
+	for len(queue) > 0 {
+		current := queue[0]
+		queue = queue[1:]
+		result = append(result, current)
+
+		children := dependents[current]
+		sort.Strings(children)
+		for _, child := range children {
+			inDegree[child]--
+			if inDegree[child] == 0 {
+				queue = append(queue, child)
+			}
+		}
+		sort.Strings(queue)
+	}
+
+	if len(result) != len(nodes) {
+		var cycleNodes []string
+		for name, degree := range inDegree {
+			if degree > 0 {
+				cycleNodes = append(cycleNodes, name)
+			}
+		}
+		sort.Strings(cycleNodes)
+		return nil, fmt.Errorf("dependency cycle detected involving nodes: %v", cycleNodes)
+	}
+
+	return result, nil
+}