let isSystemUsername check all system users

zalando · Nov 29, 2023 · af3cda3 · af3cda3
1 parent 409e4c7
commit af3cda3
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/pkg/cluster/cluster_test.go b/pkg/cluster/cluster_test.go
@@ -164,6 +164,7 @@ func TestInitRobotUsers(t *testing.T) {
 			err:           nil,
 		},
 	}
+	cl.initSystemUsers()
 	for _, tt := range tests {
 		cl.Spec.Users = tt.manifestUsers
 		cl.pgUsers = tt.infraRoles

diff --git a/pkg/cluster/util.go b/pkg/cluster/util.go
@@ -78,7 +78,14 @@ func (c *Cluster) isProtectedUsername(username string) bool {
 }
 
 func (c *Cluster) isSystemUsername(username string) bool {
-	return (username == c.OpConfig.SuperUsername || username == c.OpConfig.ReplicationUsername)
+	// is there a pooler system user defined
+	for _, systemUser := range c.systemUsers {
+		if username == systemUser.Name {
+			return true
+		}
+	}
+
+	return false
 }
 
 func isValidFlag(flag string) bool {