Add Service creation and reconciliation to ScalityUIComponent controller

Author: ZiyangLinScality

internal/controller/scalityuicomponent_controller.go

@@ -85,6 +85,37 @@ func (r *ScalityUIComponentReconciler) Reconcile(ctx context.Context, req ctrl.R
 
 	logger.Info("Deployment reconciled", "result", deploymentResult)
 
+	// Service
+	service := &corev1.Service{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      scalityUIComponent.Name,
+			Namespace: scalityUIComponent.Namespace,
+		},
+	}
+
+	serviceResult, err := ctrl.CreateOrUpdate(ctx, r.Client, service, func() error {
+		service.Spec = corev1.ServiceSpec{
+			Selector: map[string]string{
+				"app": scalityUIComponent.Name,
+			},
+			Ports: []corev1.ServicePort{
+				{
+					Name:     "http",
+					Protocol: corev1.ProtocolTCP,
+					Port:     80,
+				},
+			},
+		}
+		return nil
+	})
+
+	if err != nil {
+		logger.Error(err, "Failed to create or update Service")
+		return ctrl.Result{}, err
+	}
+
+	logger.Info("Service reconciled", "result", serviceResult)
+
 	return ctrl.Result{}, nil
 }
 
@@ -93,5 +124,6 @@ func (r *ScalityUIComponentReconciler) SetupWithManager(mgr ctrl.Manager) error
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&uiv1alpha1.ScalityUIComponent{}).
 		Owns(&appsv1.Deployment{}).
+		Owns(&corev1.Service{}).
 		Complete(r)
 }

internal/controller/scalityuicomponent_controller_test.go

@@ -26,6 +26,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 
 	appsv1 "k8s.io/api/apps/v1"
+	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
 	uiv1alpha1 "github.com/scality/ui-operator/api/v1alpha1"
@@ -94,6 +95,17 @@ var _ = Describe("ScalityUIComponent Controller", func() {
 
 			Expect(deployment.Spec.Template.ObjectMeta.Labels["app"]).To(Equal(resourceName))
 			Expect(deployment.Spec.Selector.MatchLabels["app"]).To(Equal(resourceName))
+
+			By("Checking if Service was created with correct specifications")
+			service := &corev1.Service{}
+			err = k8sClient.Get(ctx, typeNamespacedName, service)
+			Expect(err).NotTo(HaveOccurred())
+
+			Expect(service.Spec.Selector["app"]).To(Equal(resourceName))
+			Expect(service.Spec.Ports).To(HaveLen(1))
+			Expect(service.Spec.Ports[0].Name).To(Equal("http"))
+			Expect(service.Spec.Ports[0].Protocol).To(Equal(corev1.ProtocolTCP))
+			Expect(service.Spec.Ports[0].Port).To(Equal(int32(80)))
 		})
 	})
 })