graph.go

// Copyright 2025 The Kube Resource Orchestrator Authors.
//
// Licensed under the Apache License, Version 2.0 (the "License"). You may
// not use this file except in compliance with the License. A copy of the
// License is located at
//
//	http://www.apache.org/licenses/LICENSE-2.0
//
// or in the "license" file accompanying this file. This file is distributed
// on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
// express or implied. See the License for the specific language governing
// permissions and limitations under the License.

package graph

import (
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"

	"github.com/kro-run/kro/pkg/graph/dag"
	"github.com/kro-run/kro/pkg/runtime"
)

// The Graph represents a processed resourcegraphdefinition.
// It contains the DAG representation and everything needed to "manage"
// the resources defined in the resource graph definition.
type Graph struct {
	// DAG is the directed acyclic graph representation of the resource graph definition.
	DAG *dag.DirectedAcyclicGraph[string]
	// Instance is the processed resource graph definition instance.
	Instance *Resource
	// Resources is a map of the processed resources in the resource graph definition.
	Resources map[string]*Resource
	// TopologicalOrder is the topological order of the resources in the resource graph definition.
	TopologicalOrder []string
}

// NewGraphRuntime creates a new runtime resource graph definition from the resource graph definition instance.
func (rgd *Graph) NewGraphRuntime(newInstance *unstructured.Unstructured) (*runtime.ResourceGraphDefinitionRuntime, error) {
	// we need to copy the resources to the runtime resources, mainly focusing
	// on the variables and dependencies.
	resources := make(map[string]runtime.Resource)
	for name, resource := range rgd.Resources {
		resources[name] = resource.DeepCopy()
	}

	instance := rgd.Instance.DeepCopy()
	instance.originalObject = newInstance
	rt, err := runtime.NewResourceGraphDefinitionRuntime(instance, resources, rgd.TopologicalOrder)
	if err != nil {
		return nil, err
	}
	return rt, nil
}