feat: set domain automatically in Openshift cluster, fixes RHOAIENG-5123

Makefile

@@ -197,7 +197,7 @@ $(ENVTEST): $(LOCALBIN)
 .PHONY: certificates
 certificates:
 	# generate TLS certs
-	scripts/generate_certs.sh $(DOMAIN)
+	scripts/generate_certs.sh $(or $(DOMAIN),$(shell oc get ingresses.config/cluster -o jsonpath='{.spec.domain}'))
 	# create secrets from TLS certs
 	$(KUBECTL) create secret -n istio-system generic modelregistry-sample-rest-credential \
       --from-file=tls.key=certs/modelregistry-sample-rest.domain.key \

README.md

@@ -38,7 +38,7 @@ If Authorino provider is from a non Open Data Hub cluster, configure its selecto
 To use the Istio model registry samples the following configuration data is needed in the [istio.env](config/samples/istio/components/istio.env) file:
 
 * AUTH_PROVIDER - name of the authorino external auth provider configured in the Istio control plane (defaults to `opendatahub-auth-provider` for Open Data Hub data science cluster with OpenShift Service Mesh enabled).
-* DOMAIN - hostname domain suffix for gateway endpoints. 
+* DOMAIN - hostname domain suffix for gateway endpoints. This field is optional in an OpenShift cluster and set automatically if left empty.
 This depends upon your cluster's external load balancer config. In OpenShift clusters, it can be obtained with the command:
 ```shell
 oc get ingresses.config/cluster -o jsonpath='{.spec.domain}'

api/v1alpha1/modelregistry_types.go

@@ -224,10 +224,12 @@ type ServerConfig struct {
 }
 
 type GatewayConfig struct {
-	//+kubebuilder:required
+	//+optional
 
-	// Domain name for Gateway configuration
-	Domain string `json:"domain"`
+	// Domain name for Gateway configuration.
+	// If not provided, it is set automatically using model registry operator env variable DEFAULT_DOMAIN.
+	// If the env variable is not set, it is set to the OpenShift `cluster` ingress domain in an OpenShift cluster.
+	Domain string `json:"domain,omitempty"`
 
 	//+kubebuilder:default=ingressgateway
 

cmd/main.go

@@ -32,6 +32,7 @@ import (
 	_ "k8s.io/client-go/plugin/pkg/client/auth"
 
 	oapi "github.com/openshift/api"
+	oapiconfig "github.com/openshift/api/config/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
@@ -53,12 +54,14 @@ var (
 const (
 	EnableWebhooks      = "ENABLE_WEBHOOKS"
 	CreateAuthResources = "CREATE_AUTH_RESOURCES"
+	DefaultDomain       = "DEFAULT_DOMAIN"
 )
 
 func init() {
 	utilruntime.Must(clientgoscheme.AddToScheme(scheme))
 	// openshift scheme
 	utilruntime.Must(oapi.Install(scheme))
+	utilruntime.Must(oapiconfig.Install(scheme))
 	// authorino scheme
 	utilruntime.Must(authorino.AddToScheme(scheme))
 	// istio security scheme
@@ -154,6 +157,7 @@ func main() {
 
 	enableWebhooks := os.Getenv(EnableWebhooks) != "false"
 	createAuthResources := os.Getenv(CreateAuthResources) != "false"
+	defaultDomain := os.Getenv(DefaultDomain)
 
 	if err = (&controller.ModelRegistryReconciler{
 		Client:              client,
@@ -166,6 +170,7 @@ func main() {
 		HasIstio:            hasAuthorino && hasIstio,
 		Audiences:           tokenReview.Status.Audiences,
 		CreateAuthResources: createAuthResources,
+		DefaultDomain:       defaultDomain,
 	}).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "ModelRegistry")
 		os.Exit(1)

config/crd/bases/modelregistry.opendatahub.io_modelregistries.yaml

@@ -161,7 +161,11 @@ spec:
                         description: Maistra/OpenShift Servicemesh control plane name
                         type: string
                       domain:
-                        description: Domain name for Gateway configuration
+                        description: Domain name for Gateway configuration. If not
+                          provided, it is set automatically using model registry operator
+                          env variable DEFAULT_DOMAIN. If the env variable is not
+                          set, it is set to the OpenShift `cluster` ingress domain
+                          in an OpenShift cluster.
                         type: string
                       grpc:
                         description: gRPC  gateway server config
@@ -317,7 +321,6 @@ spec:
                             type: object
                         type: object
                     required:
-                    - domain
                     - grpc
                     - rest
                     type: object

config/manager/manager.yaml

@@ -81,6 +81,8 @@ spec:
             value: "false"
           - name: CREATE_AUTH_RESOURCES
             value: "true"
+          - name: DEFAULT_DOMAIN
+            value: ""
         securityContext:
           allowPrivilegeEscalation: false
           capabilities:

config/rbac/role.yaml

@@ -28,6 +28,14 @@ rules:
   - patch
   - update
   - watch
+- apiGroups:
+  - config.openshift.io
+  resources:
+  - ingresses
+  verbs:
+  - get
+  - list
+  - watch
 - apiGroups:
   - ""
   resources:

config/samples/istio/components/istio.env

@@ -1,5 +1,5 @@
 AUTH_PROVIDER=opendatahub-auth-provider
-DOMAIN=my-domain
+DOMAIN=
 ISTIO_INGRESS=ingressgateway
 REST_CREDENTIAL_NAME=modelregistry-sample-rest-credential
 GRPC_CREDENTIAL_NAME=modelregistry-sample-grpc-credential

internal/controller/modelregistry_controller.go

@@ -25,6 +25,7 @@ import (
 	authorino "github.com/kuadrant/authorino/api/v1beta2"
 	modelregistryv1alpha1 "github.com/opendatahub-io/model-registry-operator/api/v1alpha1"
 	"github.com/opendatahub-io/model-registry-operator/internal/controller/config"
+	configv1 "github.com/openshift/api/config/v1"
 	routev1 "github.com/openshift/api/route/v1"
 	userv1 "github.com/openshift/api/user/v1"
 	networking "istio.io/client-go/pkg/apis/networking/v1beta1"
@@ -69,6 +70,7 @@ type ModelRegistryReconciler struct {
 	HasIstio            bool
 	Audiences           []string
 	CreateAuthResources bool
+	DefaultDomain       string
 }
 
 // Reconcile is part of the main kubernetes reconciliation loop which aims to
@@ -299,6 +301,7 @@ func (r *ModelRegistryReconciler) GetRegistryForRoute(ctx context.Context, objec
 // +kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=core,resources=pods,verbs=get;list;watch
 // +kubebuilder:rbac:groups=core,resources=services;serviceaccounts,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups=config.openshift.io,resources=ingresses,verbs=get;list;watch
 // +kubebuilder:rbac:groups=route.openshift.io,resources=routes,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=route.openshift.io,resources=routes/custom-host,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=user.openshift.io,resources=groups,verbs=get;list;watch;create;update;patch;delete
@@ -598,7 +601,21 @@ func (r *ModelRegistryReconciler) handleGatewayRoute(ctx context.Context, params
 
 func (r *ModelRegistryReconciler) createOrUpdateGateway(ctx context.Context, params *ModelRegistryParams,
 	registry *modelregistryv1alpha1.ModelRegistry, templateName string) (result OperationResult, err error) {
+
 	result = ResourceUnchanged
+
+	// autoconfigure domain if needed
+	domainUpdated := false
+	if len(registry.Spec.Istio.Gateway.Domain) == 0 {
+		err = r.setClusterDomain(ctx, registry)
+		if err != nil {
+			return result, err
+		}
+		// update current reconcile spec
+		params.Spec = registry.Spec
+		domainUpdated = true
+	}
+
 	var gateway networking.Gateway
 	if err = r.Apply(params, templateName, &gateway); err != nil {
 		return result, err
@@ -611,7 +628,12 @@ func (r *ModelRegistryReconciler) createOrUpdateGateway(ctx context.Context, par
 	if err != nil {
 		return result, err
 	}
-	return result, nil
+
+	if !domainUpdated {
+		return result, nil
+	} else {
+		return ResourceUpdated, nil
+	}
 }
 
 func (r *ModelRegistryReconciler) createOrUpdateAuthConfig(ctx context.Context, params *ModelRegistryParams,
@@ -961,3 +983,25 @@ func (r *ModelRegistryReconciler) logResultAsEvent(registry *modelregistryv1alph
 		// ignore
 	}
 }
+
+func (r *ModelRegistryReconciler) setClusterDomain(ctx context.Context, registry *modelregistryv1alpha1.ModelRegistry) (err error) {
+	if len(r.DefaultDomain) != 0 {
+		registry.Spec.Istio.Gateway.Domain = r.DefaultDomain
+	} else if r.IsOpenShift {
+		ingress := configv1.Ingress{}
+		namespacedName := types.NamespacedName{Name: "cluster"}
+		err = r.Client.Get(context.Background(), namespacedName, &ingress)
+		if err != nil {
+			return err
+		}
+
+		// remember default domain for next time
+		r.DefaultDomain = ingress.Spec.Domain
+		registry.Spec.Istio.Gateway.Domain = r.DefaultDomain
+	} else {
+		return fmt.Errorf("model registry %s is missing gateway domain and default domain is not configured",
+			registry.Name)
+	}
+	// update domain in model registry resource
+	return r.Client.Update(ctx, registry)
+}