X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=xappKubernetesOperator%2Finternal%2Fcontroller%2Fxappdep_controller.go;h=74bb87a8cf4139c03ef25918198d23498eb96c1b;hb=refs%2Fchanges%2F27%2F12027%2F1;hp=ec9a60cff448e78babf2ab891ccffd7164cb2852;hpb=57551b79b2581cdc32416b6816199d23f15fda5a;p=ric-plt%2Fricdms.git

diff --git a/xappKubernetesOperator/internal/controller/xappdep_controller.go b/xappKubernetesOperator/internal/controller/xappdep_controller.go
index ec9a60c..74bb87a 100644
--- a/xappKubernetesOperator/internal/controller/xappdep_controller.go
+++ b/xappKubernetesOperator/internal/controller/xappdep_controller.go
@@ -15,3 +15,94 @@ limitations under the License.
 */
 
 package controller
+
+import (
+	"context"
+
+	"k8s.io/apimachinery/pkg/api/errors"
+	"k8s.io/apimachinery/pkg/runtime"
+	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
+	"sigs.k8s.io/controller-runtime/pkg/log"
+
+	depxappv1 "depxapp/api/v1"
+)
+
+// XappDepReconciler reconciles a XappDep object
+type XappDepReconciler struct {
+	client.Client
+	Scheme *runtime.Scheme
+}
+
+func (r *XappDepReconciler) handle_deploy_using_generated_go_code(usage string) {
+	// return
+	if usage == "create" {
+		r.CreateAll()
+}
+
+//+kubebuilder:rbac:groups=depxapp.xapp.com,resources=xappdeps,verbs=get;list;watch;create;update;patch;delete
+//+kubebuilder:rbac:groups=depxapp.xapp.com,resources=xappdeps/status,verbs=get;update;patch
+//+kubebuilder:rbac:groups=depxapp.xapp.com,resources=xappdeps/finalizers,verbs=update
+
+// Reconcile is part of the main kubernetes reconciliation loop which aims to
+// move the current state of the cluster closer to the desired state.
+// TODO(user): Modify the Reconcile function to compare the state specified by
+// the XappDep object against the actual cluster state, and then
+// perform operations to make the cluster state reflect the state specified by
+// the user.
+//
+// For more details, check Reconcile and its Result here:
+// - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile
+func (r *XappDepReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
+	logger := log.FromContext(ctx)
+	logger.Info("Reconcilling xapp")
+	instance := &depxappv1.XappDep{}
+	err := r.Get(context.TODO(), req.NamespacedName, instance)
+	if err != nil {
+		if errors.IsNotFound(err) {
+			// object not found, could have been deleted after reconcile request, hence don't requeue
+			return ctrl.Result{}, nil
+		}
+		// error reading the object, requeue the request
+		return ctrl.Result{}, err
+	}
+
+	// name of our custom finalizer
+	myFinalizerName := "batch.tutorial.kubebuilder.io/finalizer"
+	// examine DeletionTimestamp to determine if object is under deletion
+	if instance.ObjectMeta.DeletionTimestamp.IsZero() {
+		// Adding a Finaliser also adds the DeletionTimestamp while deleting
+		if !controllerutil.ContainsFinalizer(instance, myFinalizerName) {
+			// Would Be Called only during CR-Creation
+			logger.Info("--- Job is in Creation state")
+			r.handle_deploy_using_generated_go_code("create")
+			logger.Info("--- Job has been Created")
+			controllerutil.AddFinalizer(instance, myFinalizerName)
+			if err := r.Update(ctx, instance); err != nil {
+				return ctrl.Result{}, err
+			}
+		}
+	} else {
+		// The object is being deleted
+		if controllerutil.ContainsFinalizer(instance, myFinalizerName) {
+			// remove our finalizer from the list and update it.
+			controllerutil.RemoveFinalizer(instance, myFinalizerName)
+			if err := r.Update(ctx, instance); err != nil {
+				return ctrl.Result{}, err
+			}
+		}
+
+		// Stop reconciliation as the item is being deleted
+		return ctrl.Result{}, nil
+	}
+	return ctrl.Result{}, nil
+
+}
+
+// SetupWithManager sets up the controller with the Manager.
+func (r *XappDepReconciler) SetupWithManager(mgr ctrl.Manager) error {
+	return ctrl.NewControllerManagedBy(mgr).
+		For(&depxappv1.XappDep{}).
+		Complete(r)
+}