Add reconcile logic for slack channel

Author: hazim1093

controllers/channel_controller.go

@@ -20,32 +20,143 @@ import (
 	"context"
 
 	"github.com/go-logr/logr"
+	"k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/runtime"
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	slackv1alpha1 "github.com/stakater/slack-operator/api/v1alpha1"
+	slack "github.com/stakater/slack-operator/pkg/slack"
 )
 
 // ChannelReconciler reconciles a Channel object
 type ChannelReconciler struct {
 	client.Client
-	Log    logr.Logger
-	Scheme *runtime.Scheme
+	Log          logr.Logger
+	Scheme       *runtime.Scheme
+	SlackService slack.Service
 }
 
 // +kubebuilder:rbac:groups=slack.stakater.com,resources=channels,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=slack.stakater.com,resources=channels/status,verbs=get;update;patch
 
+// Reconcile loop for the Channel resource
 func (r *ChannelReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
-	_ = context.Background()
-	_ = r.Log.WithValues("channel", req.NamespacedName)
+	ctx := context.Background()
+	log := r.Log.WithValues("channel", req.NamespacedName)
 
-	// your logic here
+	channel := &slackv1alpha1.Channel{}
+	err := r.Get(ctx, req.NamespacedName, channel)
+
+	if err != nil {
+		if errors.IsNotFound(err) {
+			// Request object not found, could have been deleted after reconcile request.
+			// Owned objects are automatically garbage collected. For additional cleanup logic use finalizers.
+			// Return and don't requeue
+			log.Info("Channel resource not found. Deleting channel")
+			//TODO: Delete slack channel here
+			return ctrl.Result{}, nil
+		}
+		// Error reading channel, requeue
+		return ctrl.Result{}, err
+	}
+
+	name := channel.Spec.Name
+	//TODO: make private immutable in validation
+	isPrivate := channel.Spec.Private
+
+	if channel.Status.ID == "" {
+		log.Info("Creating new channel", "name", name)
+
+		channelID, err := r.SlackService.CreateChannel(name, isPrivate)
+
+		if err != nil {
+			// Set error state and don't requeue
+			channel.Status.Error = err.Error()
+			return ctrl.Result{}, nil
+		}
+		channel.Status.ID = channelID.Get()
+
+		err = r.Status().Update(ctx, channel)
+		if err != nil {
+			log.Error(err, "Failed to update Channel status")
+			return ctrl.Result{}, err
+		}
+		return ctrl.Result{}, nil
+	}
+
+	return r.updateSlackChannel(ctx, channel)
+}
+
+// TODO: too verbose code for error checking
+// TODO: send request only if data is different
+func (r *ChannelReconciler) updateSlackChannel(ctx context.Context, channel *slackv1alpha1.Channel) (ctrl.Result, error) {
+	channelID := slack.NewChannelID(channel.Status.ID)
+	log := r.Log.WithValues("channelID", channelID.Get())
+
+	log.Info("Updating channel details")
+
+	name := channel.Spec.Name
+	users := channel.Spec.Users
+	topic := channel.Spec.Topic
+	description := channel.Spec.Description
+
+	err := r.SlackService.RenameChannel(channelID, name)
+	if err != nil {
+		log.Error(err, "Error renaming channel")
+		channel.Status.Error = err.Error()
+
+		err = r.Status().Update(ctx, channel)
+		if err != nil {
+			log.Error(err, "Failed to update Channel status")
+			return ctrl.Result{}, err
+		}
+		return ctrl.Result{}, nil
+	}
+
+	err = r.SlackService.SetTopic(channelID, topic)
+	if err != nil {
+		log.Error(err, "Error setting channel topic")
+		channel.Status.Error = err.Error()
+
+		err = r.Status().Update(ctx, channel)
+		if err != nil {
+			log.Error(err, "Failed to update Channel status")
+			return ctrl.Result{}, err
+		}
+		return ctrl.Result{}, nil
+	}
+
+	err = r.SlackService.SetDescription(channelID, description)
+	if err != nil {
+		log.Error(err, "Error setting channel description")
+		channel.Status.Error = err.Error()
+
+		err = r.Status().Update(ctx, channel)
+		if err != nil {
+			log.Error(err, "Failed to update Channel status")
+			return ctrl.Result{}, err
+		}
+		return ctrl.Result{}, nil
+	}
+
+	err = r.SlackService.InviteUsers(channelID, users)
+	if err != nil {
+		log.Error(err, "Error inviting users to channel")
+		channel.Status.Error = err.Error()
+
+		err = r.Status().Update(ctx, channel)
+		if err != nil {
+			log.Error(err, "Failed to update Channel status")
+			return ctrl.Result{}, err
+		}
+		return ctrl.Result{}, nil
+	}
 
 	return ctrl.Result{}, nil
 }
 
+// SetupWithManager - Controller-Manager binding configuration
 func (r *ChannelReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&slackv1alpha1.Channel{}).