111 lines
2.9 KiB
Go
111 lines
2.9 KiB
Go
//
|
|
// Copyright (c) 2019-2023 Red Hat, Inc.
|
|
// This program and the accompanying materials are made
|
|
// available under the terms of the Eclipse Public License 2.0
|
|
// which is available at https://www.eclipse.org/legal/epl-2.0/
|
|
//
|
|
// SPDX-License-Identifier: EPL-2.0
|
|
//
|
|
// Contributors:
|
|
// Red Hat, Inc. - initial API and implementation
|
|
//
|
|
|
|
package server
|
|
|
|
import (
|
|
"github.com/devfile/devworkspace-operator/pkg/infrastructure"
|
|
"github.com/eclipse-che/che-operator/pkg/common/chetypes"
|
|
"github.com/eclipse-che/che-operator/pkg/common/constants"
|
|
"github.com/eclipse-che/che-operator/pkg/deploy"
|
|
"github.com/eclipse-che/che-operator/pkg/deploy/gateway"
|
|
routev1 "github.com/openshift/api/route/v1"
|
|
networking "k8s.io/api/networking/v1"
|
|
"sigs.k8s.io/controller-runtime/pkg/reconcile"
|
|
)
|
|
|
|
type CheHostReconciler struct {
|
|
deploy.Reconcilable
|
|
}
|
|
|
|
func NewCheHostReconciler() *CheHostReconciler {
|
|
return &CheHostReconciler{}
|
|
}
|
|
|
|
func (s *CheHostReconciler) Reconcile(ctx *chetypes.DeployContext) (reconcile.Result, bool, error) {
|
|
done, err := s.syncCheService(ctx)
|
|
if !done {
|
|
return reconcile.Result{}, false, err
|
|
}
|
|
|
|
ctx.CheHost, done, err = s.exposeCheEndpoint(ctx)
|
|
if !done {
|
|
return reconcile.Result{}, false, err
|
|
}
|
|
|
|
return reconcile.Result{}, true, nil
|
|
}
|
|
|
|
func (s *CheHostReconciler) Finalize(ctx *chetypes.DeployContext) bool {
|
|
return true
|
|
}
|
|
|
|
func (s *CheHostReconciler) syncCheService(ctx *chetypes.DeployContext) (bool, error) {
|
|
portName := []string{"http"}
|
|
portNumber := []int32{8080}
|
|
|
|
if ctx.CheCluster.Spec.Components.Metrics.Enable {
|
|
portName = append(portName, "metrics")
|
|
portNumber = append(portNumber, constants.DefaultServerMetricsPort)
|
|
}
|
|
|
|
if ctx.CheCluster.Spec.Components.CheServer.Debug != nil && *ctx.CheCluster.Spec.Components.CheServer.Debug {
|
|
portName = append(portName, "debug")
|
|
portNumber = append(portNumber, constants.DefaultServerDebugPort)
|
|
}
|
|
|
|
spec := deploy.GetServiceSpec(ctx, deploy.CheServiceName, portName, portNumber, getComponentName(ctx))
|
|
return deploy.Sync(ctx, spec, deploy.ServiceDefaultDiffOpts)
|
|
}
|
|
|
|
func (s CheHostReconciler) exposeCheEndpoint(ctx *chetypes.DeployContext) (string, bool, error) {
|
|
if !infrastructure.IsOpenShift() {
|
|
_, done, err := deploy.SyncIngressToCluster(
|
|
ctx,
|
|
getComponentName(ctx),
|
|
"",
|
|
gateway.GatewayServiceName,
|
|
8080,
|
|
getComponentName(ctx))
|
|
if !done {
|
|
return "", false, err
|
|
}
|
|
|
|
ingress := &networking.Ingress{}
|
|
exists, err := deploy.GetNamespacedObject(ctx, getComponentName(ctx), ingress)
|
|
if !exists {
|
|
return "", false, err
|
|
}
|
|
|
|
return ingress.Spec.Rules[0].Host, true, nil
|
|
}
|
|
|
|
done, err := deploy.SyncRouteToCluster(
|
|
ctx,
|
|
getComponentName(ctx),
|
|
"/",
|
|
gateway.GatewayServiceName,
|
|
8080,
|
|
getComponentName(ctx))
|
|
if !done {
|
|
return "", false, err
|
|
}
|
|
|
|
route := &routev1.Route{}
|
|
exists, err := deploy.GetNamespacedObject(ctx, getComponentName(ctx), route)
|
|
if !exists {
|
|
return "", false, err
|
|
}
|
|
|
|
return route.Spec.Host, true, nil
|
|
}
|