From d829cdb9375bb369753b1a97ecc4c116d5022ae0 Mon Sep 17 00:00:00 2001
From: Rafal Korepta <rafal@vectorized.io>
Date: Sat, 4 Jun 2022 23:42:37 +0200
Subject: [PATCH] (split) k8s: Add update functionality to ClusterRole

Almost all resources are reconciled with update functionality, so that
ClusterRole kubernetes resource will be corrected if changed outside of
operator reconcilied loop.
---
 pkg/resources/cluster_role.go | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/pkg/resources/cluster_role.go b/pkg/resources/cluster_role.go
index 861e89968f8f..e9c811b57c59 100644
--- a/pkg/resources/cluster_role.go
+++ b/pkg/resources/cluster_role.go
@@ -11,6 +11,7 @@ package resources
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/go-logr/logr"
 	redpandav1alpha1 "github.com/redpanda-data/redpanda/src/go/k8s/apis/redpanda/v1alpha1"
@@ -53,7 +54,19 @@ func (r *ClusterRoleResource) Ensure(ctx context.Context) error {
 	if r.pandaCluster.ExternalListener() == nil {
 		return nil
 	}
-	_, err := CreateIfNotExists(ctx, r, r.obj(), r.logger)
+
+	obj := r.obj()
+	created, err := CreateIfNotExists(ctx, r, obj, r.logger)
+	if err != nil || created {
+		return err
+	}
+	var cr v1.ClusterRole
+	err = r.Get(ctx, r.Key(), &cr)
+	if err != nil {
+		return fmt.Errorf("error while fetching ClusterRole resource: %w", err)
+	}
+
+	_, err = Update(ctx, &cr, obj, r.Client, r.logger)
 	return err
 }