component.go

package component

import (
	"context"
	"fmt"
	"io"
	"path/filepath"
	"strings"

	"github.com/devfile/api/v2/pkg/apis/workspaces/v1alpha2"
	"github.com/devfile/api/v2/pkg/devfile"
	"github.com/devfile/library/v2/pkg/devfile/parser"
	"github.com/devfile/library/v2/pkg/devfile/parser/data"
	routev1 "github.com/openshift/api/route/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/klog/v2"

	"github.com/redhat-developer/odo/pkg/alizer"
	"github.com/redhat-developer/odo/pkg/api"
	"github.com/redhat-developer/odo/pkg/kclient"
	odolabels "github.com/redhat-developer/odo/pkg/labels"
	"github.com/redhat-developer/odo/pkg/odo/commonflags"
	"github.com/redhat-developer/odo/pkg/platform"
	"github.com/redhat-developer/odo/pkg/podman"
	"github.com/redhat-developer/odo/pkg/util"

	corev1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
)

const (
	NotAvailable = "Not available"
	UnknownValue = "Unknown"
)

// GetComponentTypeFromDevfileMetadata returns component type from the devfile metadata;
// it could either be projectType or language, if neither of them are set, return 'Not available'
func GetComponentTypeFromDevfileMetadata(metadata devfile.DevfileMetadata) string {
	var componentType string
	if metadata.ProjectType != "" {
		componentType = metadata.ProjectType
	} else if metadata.Language != "" {
		componentType = metadata.Language
	} else {
		componentType = NotAvailable
	}
	return componentType
}

// GetComponentRuntimeFromDevfileMetadata returns the Project Type defined in the Devfile metadata
// or if not set, the Language
func GetComponentRuntimeFromDevfileMetadata(metadata devfile.DevfileMetadata) string {
	if metadata.ProjectType != "" {
		return metadata.ProjectType
	}
	return metadata.Language
}

// GatherName computes and returns what should be used as name for the Devfile object specified.
//
// If a non-blank name is available in the Devfile metadata (which is optional), it is sanitized and returned.
//
// Otherwise, it uses Alizer to detect the name, from the project build tools (pom.xml, package.json, ...),
// or from the component directory name.
func GatherName(contextDir string, devfileObj *parser.DevfileObj) (string, error) {
	var name string
	if devfileObj != nil {
		name = devfileObj.GetMetadataName()
		if name == "" || strings.TrimSpace(name) == "" {
			// Use Alizer if Devfile has no (optional) metadata.name field.
			// We need to pass in the Devfile base directory (not the path to the devfile.yaml).
			// Name returned by alizer.DetectName is expected to be already sanitized.
			alizerClient := alizer.Alizer{} // TODO(feloy) fix with DI
			return alizerClient.DetectName(filepath.Dir(devfileObj.Ctx.GetAbsPath()))
		}
	} else {
		// Fallback to the context dir name
		baseDir, err := filepath.Abs(contextDir)
		if err != nil {
			return "", err
		}
		name = filepath.Base(baseDir)
	}

	// sanitize the name
	s := util.GetDNS1123Name(name)
	klog.V(3).Infof("name of component is %q, and sanitized name is %q", name, s)

	return s, nil
}

// Log returns log from component
func Log(platformClient platform.Client, componentName string, appName string, follow bool, command v1alpha2.Command) (io.ReadCloser, error) {

	pod, err := platformClient.GetRunningPodFromSelector(odolabels.GetSelector(componentName, appName, odolabels.ComponentDevMode, false))
	if err != nil {
		return nil, fmt.Errorf("a running component %s doesn't exist on the cluster: %w", componentName, err)
	}

	containerName := command.Exec.Component

	return platformClient.GetPodLogs(pod.Name, containerName, follow)
}

// ListAllClusterComponents returns a list of all "components" on a cluster
// that are both odo and non-odo components.
//
// We then return a list of "components" intended for listing / output purposes specifically for commands such as:
// `odo list`
// that are both odo and non-odo components.
func ListAllClusterComponents(client kclient.ClientInterface, namespace string) ([]api.ComponentAbstract, error) {

	// Get all the dynamic resources available
	resourceList, err := client.GetAllResourcesFromSelector("", namespace)
	if err != nil {
		return nil, fmt.Errorf("unable to list all dynamic resources required to find components: %w", err)
	}

	var components []api.ComponentAbstract

	for _, resource := range resourceList {

		// ignore "PackageManifest" as they are not components, it is just a record in OpenShift catalog.
		if resource.GetKind() == "PackageManifest" {
			continue
		}

		var labels, annotations map[string]string

		// Retrieve the labels and annotations from the unstructured resource output
		if resource.GetLabels() != nil {
			labels = resource.GetLabels()
		}
		if resource.GetAnnotations() != nil {
			annotations = resource.GetAnnotations()
		}

		// Figure out the correct name to use
		// if there is no instance label (app.kubernetes.io/instance),
		// we SKIP the resource as it is not a component essential for Kubernetes.
		name := odolabels.GetComponentName(labels)
		if name == "" {
			continue
		}

		// Get the component type (if there is any..)
		componentType, err := odolabels.GetProjectType(nil, annotations)
		if err != nil || componentType == "" {
			componentType = api.TypeUnknown
		}

		// Get the managedBy label
		// IMPORTANT. If both "managed-by" and "instance" labels are BLANK, it is most likely an operator
		// or a non-component. We do not want to show these in the list of components
		// so we skip them if there is no "managed-by" label.

		managedBy := odolabels.GetManagedBy(labels)
		if managedBy == "" && name == "" {
			continue
		}

		managedByVersion := odolabels.GetManagedByVersion(labels)

		// Generate the appropriate "component" with all necessary information
		component := api.ComponentAbstract{
			Name:             name,
			ManagedBy:        managedBy,
			Type:             componentType,
			ManagedByVersion: managedByVersion,
			//lint:ignore SA1019 we need to output the deprecated value, before to remove it in a future release
			RunningOn: commonflags.PlatformCluster,
			Platform:  commonflags.PlatformCluster,
		}
		mode := odolabels.GetMode(labels)
		componentFound := false
		for v, otherCompo := range components {
			if component.Name == otherCompo.Name {
				componentFound = true
				if mode != "" {
					if components[v].RunningIn == nil {
						components[v].RunningIn = api.NewRunningModes()
					}
					components[v].RunningIn.AddRunningMode(api.RunningMode(strings.ToLower(mode)))
				}
				if otherCompo.Type == api.TypeUnknown && component.Type != api.TypeUnknown {
					components[v].Type = component.Type
				}
				if otherCompo.ManagedBy == api.TypeUnknown && component.ManagedBy != api.TypeUnknown {
					components[v].ManagedBy = component.ManagedBy
				}
			}
		}
		if !componentFound {
			if mode != "" {
				if component.RunningIn == nil {
					component.RunningIn = api.NewRunningModes()
				}
				component.RunningIn.AddRunningMode(api.RunningMode(strings.ToLower(mode)))
			}
			components = append(components, component)
		}
	}

	return components, nil
}

func ListAllComponents(client kclient.ClientInterface, podmanClient podman.Client, namespace string, devObj *parser.DevfileObj, componentName string) ([]api.ComponentAbstract, string, error) {
	var (
		allComponents []api.ComponentAbstract
	)

	if client != nil {
		clusterComponents, err := ListAllClusterComponents(client, namespace)
		if err != nil {
			return nil, "", err
		}
		allComponents = append(allComponents, clusterComponents...)
	}

	// PdomanClient can be nil if podman platform is not accessible
	if podmanClient != nil {
		podmanComponents, err := podmanClient.ListAllComponents()
		if err != nil {
			return nil, "", err
		}
		allComponents = append(allComponents, podmanComponents...)
	}

	localComponent := api.ComponentAbstract{
		Name:      componentName,
		ManagedBy: "",
		RunningIn: api.NewRunningModes(),
	}
	if devObj != nil {
		localComponent.Type = GetComponentTypeFromDevfileMetadata(devObj.Data.GetMetadata())
	}

	componentInDevfile := ""
	if localComponent.Name != "" {
		if !Contains(localComponent, allComponents) {
			allComponents = append(allComponents, localComponent)
		}
		componentInDevfile = localComponent.Name
	}
	return allComponents, componentInDevfile, nil
}

func getResourcesForComponent(
	ctx context.Context,
	client platform.Client,
	name string,
	namespace string,
) ([]unstructured.Unstructured, error) {
	selector := odolabels.GetNameSelector(name)
	resourceList, err := client.GetAllResourcesFromSelector(selector, namespace)
	if err != nil {
		return nil, err
	}
	filteredList := []unstructured.Unstructured{}
	for _, resource := range resourceList {
		// ignore "PackageManifest" as they are not components, it is just a record in OpenShift catalog.
		if resource.GetKind() == "PackageManifest" {
			continue
		}
		filteredList = append(filteredList, resource)
	}
	return filteredList, nil
}

// GetRunningModes returns the list of modes on which a "name" component is deployed, by looking into namespace
// the resources deployed with matching labels, based on the "odo.dev/mode" label
func GetRunningModes(ctx context.Context, kubeClient kclient.ClientInterface, podmanClient podman.Client, name string) (map[platform.Client]api.RunningModes, error) {
	var hasErr bool
	var ns string
	listByPlatform := make(map[platform.Client][]unstructured.Unstructured)
	if kubeClient != nil {
		ns = kubeClient.GetCurrentNamespace()
		list, err := getResourcesForComponent(ctx, kubeClient, name, ns)
		if err != nil {
			klog.V(4).Infof("error while listing cluster components: %v", err)
			hasErr = true
		} else if len(list) > 0 {
			listByPlatform[kubeClient] = list
		}
	}

	if podmanClient != nil {
		ns = ""
		list, err := getResourcesForComponent(ctx, podmanClient, name, ns)
		if err != nil {
			klog.V(4).Infof("error while listing Podman components: %v", err)
			hasErr = true
		} else if len(list) > 0 {
			listByPlatform[podmanClient] = list
		}
	}

	if hasErr {
		return nil, nil
	}

	if len(listByPlatform) == 0 {
		return nil, NewNoComponentFoundError(name, ns)
	}

	result := make(map[platform.Client]api.RunningModes)
	for plt, list := range listByPlatform {
		mapResult := api.NewRunningModes()
		for _, resource := range list {
			resourceLabels := resource.GetLabels()
			mode := odolabels.GetMode(resourceLabels)
			if mode != "" {
				mapResult.AddRunningMode(api.RunningMode(strings.ToLower(mode)))
			}
		}
		result[plt] = mapResult
	}

	return result, nil
}

// Contains checks to see if the component exists in an array or not
// by checking the name
func Contains(component api.ComponentAbstract, components []api.ComponentAbstract) bool {
	for _, comp := range components {
		if component.Name == comp.Name {
			return true
		}
	}
	return false
}

// GetDevfileInfo extracts information from the labels and annotations of resources to rebuild a Devfile
func GetDevfileInfo(ctx context.Context, kubeClient kclient.ClientInterface, podmanClient podman.Client, name string) (parser.DevfileObj, error) {
	var ns string
	listByPlatform := make(map[platform.Client][]unstructured.Unstructured)
	if kubeClient != nil {
		ns = kubeClient.GetCurrentNamespace()
		list, err := getResourcesForComponent(ctx, kubeClient, name, ns)
		if err != nil {
			klog.V(4).Infof("error while listing cluster components: %v", err)
		} else if len(list) > 0 {
			listByPlatform[kubeClient] = list
		}
	}
	if podmanClient != nil {
		ns = ""
		list, err := getResourcesForComponent(ctx, podmanClient, name, "")
		if err != nil {
			klog.V(4).Infof("error while listing Podman components: %v", err)
		} else if len(list) > 0 {
			listByPlatform[podmanClient] = list
		}
	}

	if len(listByPlatform) == 0 {
		return parser.DevfileObj{}, NewNoComponentFoundError(name, ns)
	}

	// If a same resource is found on both platforms, make sure it has the same labels.
	// Otherwise, we don't know how to extract Devfile information from it.
	kList := listByPlatform[kubeClient]
	pList := listByPlatform[podmanClient]
	if len(kList) > 0 {
		err := checkLabelsForDevfileInfo(kList, pList)
		if err != nil {
			return parser.DevfileObj{}, err
		}
	}
	if len(pList) > 0 {
		err := checkLabelsForDevfileInfo(pList, kList)
		if err != nil {
			return parser.DevfileObj{}, err
		}
	}

	if len(kList) > 0 {
		return getDevfileInfoFromList(kList)
	}
	return getDevfileInfoFromList(pList)
}

func checkLabelsForDevfileInfo(l1 []unstructured.Unstructured, l2 []unstructured.Unstructured) error {
	for _, k := range l1 {
		var found bool
		var (
			kLabels      = k.GetLabels()
			kAnnotations = k.GetAnnotations()
			kName        = odolabels.GetComponentName(kLabels)
		)
		kProjectType, err := odolabels.GetProjectType(kLabels, kAnnotations)
		if err != nil {
			klog.V(7).Infof("error while working on cluster resource %q: %v", kName, err)
			continue
		}

		var (
			pName        string
			pProjectType string
		)
		for _, p := range l2 {
			pLabels := p.GetLabels()
			pAnnotations := p.GetAnnotations()
			pName = odolabels.GetComponentName(pLabels)
			pProjectType, err = odolabels.GetProjectType(pLabels, pAnnotations)
			if err != nil {
				klog.V(7).Infof("error while working on resource %q: %v", pName, err)
				continue
			}
			if kName == pName {
				found = true
				break
			}
		}
		if found {
			// Error out if there is a mismatch
			if kProjectType != pProjectType {
				return fmt.Errorf("found resource %q on both platforms, but with different project types: %q vs %q",
					kName, kProjectType, pProjectType)
			}
		}
	}
	return nil
}

func getDevfileInfoFromList(list []unstructured.Unstructured) (parser.DevfileObj, error) {
	devfileData, err := data.NewDevfileData(string(data.APISchemaVersion200))
	if err != nil {
		return parser.DevfileObj{}, err
	}
	metadata := devfileData.GetMetadata()
	metadata.Name = UnknownValue
	metadata.DisplayName = UnknownValue
	metadata.ProjectType = UnknownValue
	metadata.Language = UnknownValue
	metadata.Version = UnknownValue
	metadata.Description = UnknownValue

	for _, resource := range list {
		labels := resource.GetLabels()
		annotations := resource.GetAnnotations()
		name := odolabels.GetComponentName(labels)
		if len(name) > 0 && metadata.Name == UnknownValue {
			metadata.Name = name
		}
		typ, err := odolabels.GetProjectType(labels, annotations)
		if err != nil {
			continue
		}
		if len(typ) > 0 && metadata.ProjectType == UnknownValue {
			metadata.ProjectType = typ
		}
	}
	devfileData.SetMetadata(metadata)
	return parser.DevfileObj{
		Data: devfileData,
	}, nil
}

// ListRoutesAndIngresses lists routes and ingresses created by a component;
// it only returns the resources created with Deploy mode;
// it fetches resources from the cluster that match label and return.
func ListRoutesAndIngresses(client kclient.ClientInterface, componentName, appName string) (ings []api.ConnectionData, routes []api.ConnectionData, err error) {
	if client == nil {
		return nil, nil, nil
	}

	selector := odolabels.GetNameSelector(componentName)

	k8sIngresses, err := client.ListIngresses(client.GetCurrentNamespace(), selector)
	if err != nil {
		return nil, nil, err
	}
	for _, ing := range k8sIngresses.Items {
		if ownerReferences := ing.GetOwnerReferences(); ownerReferences != nil {
			klog.V(4).Infof("Skipping Ingress %q created/owned by another resource: %v", ing.GetName(), ownerReferences)
			continue
		}
		ings = append(ings, api.ConnectionData{
			Name: ing.GetName(),
			Rules: func() (rules []api.Rules) {
				for _, rule := range ing.Spec.Rules {
					var paths []string
					for _, path := range rule.HTTP.Paths {
						paths = append(paths, path.Path)
					}
					host := rule.Host
					if host == "" {
						host = "*"
					}
					rules = append(rules, api.Rules{Host: host, Paths: paths})
				}
				if len(ing.Spec.Rules) == 0 {
					rules = append(rules, api.Rules{Host: "*", Paths: []string{"/*"}})
				}
				return rules
			}(),
		})
	}
	// Return early if it is not an OpenShift cluster
	if isOC, e := client.IsProjectSupported(); !isOC {
		if e != nil {
			klog.V(4).Infof("unable to detect project support: %s", e.Error())
		}
		return ings, nil, nil
	}

	routeGVR, err := client.GetGVRFromGVK(kclient.RouteGVK)
	if err != nil {
		return nil, nil, fmt.Errorf("unable to determine GVR for %s: %w", kclient.RouteGVK.String(), err)
	}

	ocRoutes, err := client.ListDynamicResources(client.GetCurrentNamespace(), routeGVR, selector)
	if err != nil {
		return nil, nil, err
	}
	for _, u := range ocRoutes.Items {
		if ownerReferences := u.GetOwnerReferences(); ownerReferences != nil {
			klog.V(4).Infof("Skipping Route %q created/owned by another resource: %v", u.GetName(), ownerReferences)
			continue
		}
		route := routev1.Route{}
		err = runtime.DefaultUnstructuredConverter.FromUnstructured(u.UnstructuredContent(), &route)
		if err != nil {
			return nil, nil, err
		}
		routes = append(routes, api.ConnectionData{
			Name: route.GetName(),
			Rules: []api.Rules{
				{Host: route.Spec.Host, Paths: []string{route.Spec.Path}},
			},
		})
	}

	return ings, routes, nil
}

func GetContainersNames(pod *corev1.Pod) []string {
	result := make([]string, 0, len(pod.Spec.Containers))
	for _, container := range pod.Spec.Containers {
		result = append(result, container.Name)
	}
	return result
}