clusterserviceplan_resolver.go

package servicecatalog

import (
	"context"
	"fmt"

	"github.com/golang/glog"
	"github.com/kyma-project/kyma/components/console-backend-service/internal/domain/rafter/pretty"
	"github.com/kyma-project/kyma/components/console-backend-service/internal/domain/shared"
	"github.com/kyma-project/kyma/components/console-backend-service/internal/gqlerror"
	"github.com/kyma-project/kyma/components/console-backend-service/internal/gqlschema"
)

type ClusterServicePlanResolver struct {
	rafter shared.RafterRetriever
}

func NewClusterServicePlanResolver(r shared.RafterRetriever) *ClusterServicePlanResolver {
	return &ClusterServicePlanResolver{r}
}

func (r *ClusterServicePlanResolver) ClusterServicePlanClusterAssetGroupField(ctx context.Context, obj *gqlschema.ClusterServicePlan) (*gqlschema.ClusterAssetGroup, error) {
	if obj == nil {
		glog.Error(fmt.Errorf("while getting %s field obj is empty", pretty.ClusterAssetGroup))
		return nil, gqlerror.NewInternal()
	}

	clusterAssetGroup, err := r.rafter.ClusterAssetGroup().Find(obj.Name)
	if err != nil {
		glog.Errorf("Couldn't find %s with name %s", pretty.ClusterAssetGroup, obj.Name)
		return nil, nil
	}

	convertedAssetGroup, err := r.rafter.ClusterAssetGroupConverter().ToGQL(clusterAssetGroup)

	if err != nil {
		glog.Errorf("Couldn't convert %s with name %s to GQL", pretty.ClusterAssetGroup, obj.Name)
		return nil, nil
	}
	return convertedAssetGroup, nil
}