fixup

Signed-off-by: Anatolii Bazko <[email protected]>
eclipse-che · Oct 8, 2024 · dff6d61 · dff6d61
1 parent eb7cb57
commit dff6d61
Show file tree

Hide file tree

Showing 8 changed files with 21 additions and 11 deletions.
diff --git a/api/v2/checluster_types.go b/api/v2/checluster_types.go
@@ -1040,6 +1040,10 @@ func (c *CheCluster) IsEmbeddedOpenVSXRegistryConfigured() bool {
 	return defaults.GetPluginRegistryOpenVSXURL() == ""
 }
 
+func (c *CheCluster) IsInternalPluginRegistryDisabled() bool {
+	return c.Spec.Components.PluginRegistry.DisableInternalRegistry || !c.IsEmbeddedOpenVSXRegistryConfigured()
+}
+
 // IsCheBeingInstalled returns true if the Che version is not set in the status.
 // Basically it means that the Che is being installed since the Che version is set only after the installation.
 func (c *CheCluster) IsCheBeingInstalled() bool {

diff --git a/pkg/deploy/dashboard/dashboard_deployment_test.go b/pkg/deploy/dashboard/dashboard_deployment_test.go
@@ -224,13 +224,6 @@ func TestDashboardDeploymentEnvVars(t *testing.T) {
 			Name:  "CHE_DASHBOARD_INTERNAL_URL",
 			Value: fmt.Sprintf("http://%s-dashboard.eclipse-che.svc:8080", defaults.GetCheFlavor()),
 		})
-	assert.Contains(
-		t,
-		deployment.Spec.Template.Spec.Containers[0].Env,
-		corev1.EnvVar{
-			Name:  "CHE_WORKSPACE_PLUGIN__REGISTRY__INTERNAL__URL",
-			Value: "http://plugin-registry.eclipse-che.svc:8080/v3",
-		})
 	assert.Contains(
 		t,
 		deployment.Spec.Template.Spec.Containers[0].Env,

diff --git a/pkg/deploy/dashboard/deployment_dashboard.go b/pkg/deploy/dashboard/deployment_dashboard.go
@@ -83,7 +83,7 @@ func (d *DashboardReconciler) getDashboardDeploymentSpec(ctx *chetypes.DeployCon
 			Value: fmt.Sprintf("http://%s.%s.svc:8080/api", deploy.CheServiceName, ctx.CheCluster.Namespace)},
 	)
 
-	if !ctx.CheCluster.Spec.Components.PluginRegistry.DisableInternalRegistry {
+	if !ctx.CheCluster.IsInternalPluginRegistryDisabled() {
 		envVars = append(envVars,
 			corev1.EnvVar{
 				Name:  "CHE_WORKSPACE_PLUGIN__REGISTRY__INTERNAL__URL",

diff --git a/pkg/deploy/gateway/gateway_test.go b/pkg/deploy/gateway/gateway_test.go
@@ -18,6 +18,8 @@ import (
 	"strings"
 	"testing"
 
+	"k8s.io/utils/pointer"
+
 	"github.com/devfile/devworkspace-operator/pkg/infrastructure"
 	chev2 "github.com/eclipse-che/che-operator/api/v2"
 	"github.com/eclipse-che/che-operator/pkg/common/chetypes"
@@ -170,6 +172,7 @@ func TestOauthProxyConfigUnauthorizedPaths(t *testing.T) {
 					Components: chev2.CheClusterComponents{
 						PluginRegistry: chev2.PluginRegistry{
 							DisableInternalRegistry: false,
+							OpenVSXURL:              pointer.String(""),
 						},
 					}},
 			}, nil)

diff --git a/pkg/deploy/gateway/oauth_proxy.go b/pkg/deploy/gateway/oauth_proxy.go
@@ -160,7 +160,7 @@ cookie_domains = "%s"
 
 func skipAuthConfig(instance *chev2.CheCluster) string {
 	var skipAuthPaths []string
-	if !instance.Spec.Components.PluginRegistry.DisableInternalRegistry {
+	if !instance.IsInternalPluginRegistryDisabled() {
 		skipAuthPaths = append(skipAuthPaths, "^/"+constants.PluginRegistryName)
 	}
 	skipAuthPaths = append(skipAuthPaths, "^/$")

diff --git a/pkg/deploy/pluginregistry/pluginregistry.go b/pkg/deploy/pluginregistry/pluginregistry.go
@@ -37,7 +37,7 @@ func NewPluginRegistryReconciler() *PluginRegistryReconciler {
 }
 
 func (p *PluginRegistryReconciler) Reconcile(ctx *chetypes.DeployContext) (reconcile.Result, bool, error) {
-	if ctx.CheCluster.Spec.Components.PluginRegistry.DisableInternalRegistry || !ctx.CheCluster.IsEmbeddedOpenVSXRegistryConfigured() {
+	if ctx.CheCluster.IsInternalPluginRegistryDisabled() {
 		_, _ = deploy.DeleteNamespacedObject(ctx, constants.PluginRegistryName, &corev1.Service{})
 		_, _ = deploy.DeleteNamespacedObject(ctx, constants.PluginRegistryName, &corev1.ConfigMap{})
 		_, _ = deploy.DeleteNamespacedObject(ctx, gateway.GatewayConfigMapNamePrefix+constants.PluginRegistryName, &corev1.ConfigMap{})

diff --git a/pkg/deploy/server/server_configmap.go b/pkg/deploy/server/server_configmap.go
@@ -142,7 +142,7 @@ func (s *CheServerReconciler) getCheConfigMapData(ctx *chetypes.DeployContext) (
 	cheAPI := "https://" + ctx.CheHost + "/api"
 	var pluginRegistryInternalURL string
 
-	if !ctx.CheCluster.Spec.Components.PluginRegistry.DisableInternalRegistry {
+	if !ctx.CheCluster.IsInternalPluginRegistryDisabled() {
 		pluginRegistryInternalURL = fmt.Sprintf("http://%s.%s.svc:8080/v3", constants.PluginRegistryName, ctx.CheCluster.Namespace)
 	}
 

diff --git a/pkg/deploy/server/server_configmap_test.go b/pkg/deploy/server/server_configmap_test.go
@@ -15,6 +15,8 @@ package server
 import (
 	"testing"
 
+	"k8s.io/utils/pointer"
+
 	"github.com/devfile/devworkspace-operator/pkg/infrastructure"
 	"github.com/eclipse-che/che-operator/pkg/common/test"
 	"github.com/stretchr/testify/assert"
@@ -349,6 +351,14 @@ func TestShouldSetUpCorrectlyPluginRegistryURL(t *testing.T) {
 				ObjectMeta: metav1.ObjectMeta{
 					Namespace: "eclipse-che",
 				},
+				Spec: chev2.CheClusterSpec{
+					Components: chev2.CheClusterComponents{
+						PluginRegistry: chev2.PluginRegistry{
+							DisableInternalRegistry: false,
+							OpenVSXURL:              pointer.String(""),
+						},
+					},
+				},
 				Status: chev2.CheClusterStatus{
 					PluginRegistryURL: "internal-plugin-registry",
 				},