chore: refactored kcp api imports

On-behalf-of: SAP aleh.yarshou@sap.com

Author: OlegErshov

cmd/operator.go

@@ -10,7 +10,7 @@ import (
 	// to ensure that exec-entrypoint and run can make use of them.
 	"github.com/kcp-dev/logicalcluster/v3"
 	"github.com/kcp-dev/multicluster-provider/apiexport"
-	apisv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
+	kcpapisv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
 	kcpcorev1alpha1 "github.com/kcp-dev/sdk/apis/core/v1alpha1"
 	openfgav1 "github.com/openfga/api/proto/openfga/v1"
 	accountsv1alpha1 "github.com/platform-mesh/account-operator/api/v1alpha1"
@@ -220,7 +220,7 @@ func init() {
 
 	utilruntime.Must(kcptenancyv1alphav1.AddToScheme(scheme))
 	utilruntime.Must(corev1alpha1.AddToScheme(scheme))
-	utilruntime.Must(apisv1alpha1.AddToScheme(scheme))
+	utilruntime.Must(kcpapisv1alpha1.AddToScheme(scheme))
 	utilruntime.Must(kcpcorev1alpha1.AddToScheme(scheme))
 	utilruntime.Must(accountsv1alpha1.AddToScheme(scheme))
 	// +kubebuilder:scaffold:scheme

internal/controller/apibinding_controller.go

@@ -6,7 +6,7 @@ import (
 	"strings"
 
 	"github.com/kcp-dev/logicalcluster/v3"
-	apisv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
+	kcpapisv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
 	platformeshconfig "github.com/platform-mesh/golang-commons/config"
 	"github.com/platform-mesh/golang-commons/controller/lifecycle/builder"
 	lifecyclesubroutine "github.com/platform-mesh/golang-commons/controller/lifecycle/subroutine"
@@ -76,9 +76,9 @@ type APIBindingReconciler struct {
 
 func (r *APIBindingReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (ctrl.Result, error) {
 	ctxWithCluster := mccontext.WithCluster(ctx, req.ClusterName)
-	return r.mclifecycle.Reconcile(ctxWithCluster, req, &apisv1alpha1.APIBinding{})
+	return r.mclifecycle.Reconcile(ctxWithCluster, req, &kcpapisv1alpha1.APIBinding{})
 }
 
 func (r *APIBindingReconciler) SetupWithManager(mgr mcmanager.Manager, cfg *platformeshconfig.CommonServiceConfig, evp ...predicate.Predicate) error {
-	return r.mclifecycle.SetupWithManager(mgr, cfg.MaxConcurrentReconciles, "apibinding-controller", &apisv1alpha1.APIBinding{}, cfg.DebugLabelValue, r, r.log, evp...)
+	return r.mclifecycle.SetupWithManager(mgr, cfg.MaxConcurrentReconciles, "apibinding-controller", &kcpapisv1alpha1.APIBinding{}, cfg.DebugLabelValue, r, r.log, evp...)
 }

internal/subroutine/authorization_model_generation.go

@@ -8,7 +8,7 @@ import (
 	"text/template"
 
 	"github.com/kcp-dev/logicalcluster/v3"
-	kcpv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
+	kcpapisv1alpha1 "github.com/kcp-dev/sdk/apis/apis/v1alpha1"
 	accountv1alpha1 "github.com/platform-mesh/account-operator/api/v1alpha1"
 	lifecyclecontrollerruntime "github.com/platform-mesh/golang-commons/controller/lifecycle/runtimeobject"
 	lifecyclesubroutine "github.com/platform-mesh/golang-commons/controller/lifecycle/subroutine"
@@ -87,14 +87,14 @@ type modelInput struct {
 func (a *AuthorizationModelGenerationSubroutine) Finalize(ctx context.Context, instance lifecyclecontrollerruntime.RuntimeObject) (ctrl.Result, errors.OperatorError) {
 	log := logger.LoadLoggerFromContext(ctx)
 
-	bindingToDelete := instance.(*kcpv1alpha1.APIBinding)
+	bindingToDelete := instance.(*kcpapisv1alpha1.APIBinding)
 
 	bindingCluster, err := a.mgr.ClusterFromContext(ctx)
 	if err != nil {
 		return ctrl.Result{}, errors.NewOperatorError(fmt.Errorf("unable to get cluster from context: %w", err), true, false)
 	}
 
-	var bindings kcpv1alpha1.APIBindingList
+	var bindings kcpapisv1alpha1.APIBindingList
 	err = a.allClient.List(ctx, &bindings)
 	if err != nil {
 		return ctrl.Result{}, errors.NewOperatorError(err, true, true)
@@ -149,15 +149,15 @@ func (a *AuthorizationModelGenerationSubroutine) Finalize(ctx context.Context, i
 	}
 	apiExportClient := apiExportCluster.GetClient()
 
-	var apiExport kcpv1alpha1.APIExport
+	var apiExport kcpapisv1alpha1.APIExport
 	err = apiExportClient.Get(ctx, types.NamespacedName{Name: bindingToDelete.Spec.Reference.Export.Name}, &apiExport)
 	if err != nil {
 		log.Error().Err(err).Msg("failed to get apiexport for binding deletion")
 		return ctrl.Result{}, errors.NewOperatorError(err, true, true)
 	}
 
 	for _, latestResourceSchema := range apiExport.Spec.LatestResourceSchemas {
-		var resourceSchema kcpv1alpha1.APIResourceSchema
+		var resourceSchema kcpapisv1alpha1.APIResourceSchema
 		err := apiExportClient.Get(ctx, types.NamespacedName{Name: latestResourceSchema}, &resourceSchema)
 		if err != nil {
 			log.Error().Err(err).Msg("failed to get resource schema for binding deletion")
@@ -198,7 +198,7 @@ func (a *AuthorizationModelGenerationSubroutine) GetName() string {
 
 // Process implements lifecycle.Subroutine.
 func (a *AuthorizationModelGenerationSubroutine) Process(ctx context.Context, instance lifecyclecontrollerruntime.RuntimeObject) (ctrl.Result, errors.OperatorError) {
-	binding := instance.(*kcpv1alpha1.APIBinding)
+	binding := instance.(*kcpapisv1alpha1.APIBinding)
 
 	cluster, err := a.mgr.ClusterFromContext(ctx)
 	if err != nil {
@@ -225,14 +225,14 @@ func (a *AuthorizationModelGenerationSubroutine) Process(ctx context.Context, in
 		return ctrl.Result{}, errors.NewOperatorError(err, true, true)
 	}
 
-	var apiExport kcpv1alpha1.APIExport
+	var apiExport kcpapisv1alpha1.APIExport
 	err = apiExportCluster.GetClient().Get(ctx, types.NamespacedName{Name: binding.Spec.Reference.Export.Name}, &apiExport)
 	if err != nil {
 		return ctrl.Result{}, errors.NewOperatorError(err, true, true)
 	}
 
 	for _, latestResourceSchema := range apiExport.Spec.LatestResourceSchemas {
-		var resourceSchema kcpv1alpha1.APIResourceSchema
+		var resourceSchema kcpapisv1alpha1.APIResourceSchema
 		err := apiExportCluster.GetClient().Get(ctx, types.NamespacedName{Name: latestResourceSchema}, &resourceSchema)
 		if err != nil {
 			return ctrl.Result{}, errors.NewOperatorError(err, true, true)