add sync rule and debug to cluster.go. also adding monitoring to test check

Author: Schmaetz

pkg/cluster/cluster.go

@@ -1455,13 +1455,16 @@ func (c *Cluster) initSystemUsers() error {
 
 	// if the monitor object has been created, a monitoring user is required.
 	if c.Spec.Monitoring != nil {
+
 		MonitoringUser := spec.PgUser{
 			Origin:    spec.RoleMonitoring,
 			Name:      constants.MonitoringUserKeyName,
 			Namespace: c.Namespace,
 			Flags:     []string{constants.RoleFlagLogin},
 			Password:  util.RandomPassword(constants.PasswordLength),
 		}
+		c.logger.Debugf("Create cpo_monitoring user with password: %s",
+			MonitoringUser.Password)
 
 		if _, exists := c.systemUsers[constants.MonitoringUserKeyName]; !exists {
 			c.systemUsers[constants.MonitoringUserKeyName] = MonitoringUser

pkg/cluster/cluster_test.go

@@ -7,8 +7,6 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/sirupsen/logrus"
-	"github.com/stretchr/testify/assert"
 	cpov1 "github.com/cybertec-postgresql/cybertec-pg-operator/pkg/apis/cpo.opensource.cybertec.at/v1"
 	fakecpov1 "github.com/cybertec-postgresql/cybertec-pg-operator/pkg/generated/clientset/versioned/fake"
 	"github.com/cybertec-postgresql/cybertec-pg-operator/pkg/spec"
@@ -17,6 +15,8 @@ import (
 	"github.com/cybertec-postgresql/cybertec-pg-operator/pkg/util/constants"
 	"github.com/cybertec-postgresql/cybertec-pg-operator/pkg/util/k8sutil"
 	"github.com/cybertec-postgresql/cybertec-pg-operator/pkg/util/teams"
+	"github.com/sirupsen/logrus"
+	"github.com/stretchr/testify/assert"
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/kubernetes/fake"
@@ -944,16 +944,20 @@ func TestServiceAnnotations(t *testing.T) {
 }
 
 func TestInitSystemUsers(t *testing.T) {
-	// reset system users, pooler and stream section
+	// reset system users, pooler, monitoring and stream section
 	cl.systemUsers = make(map[string]spec.PgUser)
 	cl.Spec.EnableConnectionPooler = boolToPointer(false)
+	cl.Spec.Monitoring = nil
 	cl.Spec.Streams = []cpov1.Stream{}
 
-	// default cluster without connection pooler and event streams
+	// default cluster without connection pooler, monitoring and event streams
 	cl.initSystemUsers()
 	if _, exist := cl.systemUsers[constants.ConnectionPoolerUserKeyName]; exist {
 		t.Errorf("%s, connection pooler user is present", t.Name())
 	}
+	if _, exist := cl.systemUsers[constants.MonitoringUserKeyName]; exist {
+		t.Errorf("%s, Monitoring user is present", t.Name())
+	}
 	if _, exist := cl.systemUsers[constants.EventStreamUserKeyName]; exist {
 		t.Errorf("%s, stream user is present", t.Name())
 	}

pkg/cluster/sync.go

@@ -1032,6 +1032,13 @@ func (c *Cluster) updateSecret(
 			userMap = c.systemUsers
 		}
 	}
+	// use system user when Monitoring is enabled and Monitoring user is specfied in manifest
+	if _, exists := c.systemUsers[constants.MonitoringUserKeyName]; exists {
+		if secretUsername == c.systemUsers[constants.MonitoringUserKeyName].Name {
+			userKey = constants.MonitoringUserKeyName
+			userMap = c.systemUsers
+		}
+	}
 	// use system user when streams are defined and fes_user is specfied in manifest
 	if _, exists := c.systemUsers[constants.EventStreamUserKeyName]; exists {
 		if secretUsername == c.systemUsers[constants.EventStreamUserKeyName].Name {