fix: check for existing superuser (#564)

apache · May 3, 2024 · abf8328 · abf8328
1 parent 3243fea
commit abf8328
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/org/apache/pulsar/manager/controller/UsersController.java b/src/main/java/org/apache/pulsar/manager/controller/UsersController.java
@@ -218,6 +218,11 @@ public ResponseEntity<Map<String, Object>> createSuperUser(@RequestBody UserInfo
             result.put("error", "Please provider password");
             return ResponseEntity.ok(result);
         }
+        Optional<UserInfoEntity> optionalUserEntity =  usersRepository.findByUserName(userInfoEntity.getName());
+        if (optionalUserEntity.isPresent()) {
+            result.put("error", "Superuser already exists");
+            return ResponseEntity.ok(result);
+        }
 
         userInfoEntity.setPassword(DigestUtils.sha256Hex(userInfoEntity.getPassword()));
         usersRepository.save(userInfoEntity);