Unify enum naming

Author: mmodzelewski

examples/simple-consumer/src/main/java/rs/iggy/SimpleConsumer.java

@@ -74,7 +74,7 @@ private static void createTopic(IggyTcpClient client) {
                 .createTopic(STREAM_ID,
                         empty(),
                         1L,
-                        CompressionAlgorithm.none,
+                        CompressionAlgorithm.None,
                         BigInteger.ZERO,
                         BigInteger.ZERO,
                         empty(),

examples/simple-producer/src/main/java/rs/iggy/SimpleProducer.java

@@ -55,7 +55,7 @@ private static void createTopic(IggyTcpClient client) {
                 .createTopic(STREAM_ID,
                         empty(),
                         1L,
-                        CompressionAlgorithm.none,
+                        CompressionAlgorithm.None,
                         BigInteger.ZERO,
                         BigInteger.ZERO,
                         empty(),

java-sdk/src/main/java/rs/iggy/consumergroup/Consumer.java

@@ -21,7 +21,8 @@ public static Consumer group(ConsumerId id) {
     }
 
     public enum Kind {
-        Consumer(1), ConsumerGroup(2);
+        Consumer(1),
+        ConsumerGroup(2);
 
         private final int code;
 

java-sdk/src/main/java/rs/iggy/topic/CompressionAlgorithm.java

@@ -1,8 +1,8 @@
 package rs.iggy.topic;
 
 public enum CompressionAlgorithm {
-    none(1),
-    gzip(2);
+    None(1),
+    Gzip(2);
 
     private final Integer code;
 

java-sdk/src/main/java/rs/iggy/user/UserStatus.java

@@ -1,8 +1,12 @@
 package rs.iggy.user;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
+
 public enum UserStatus {
-    active(1),
-    inactive(2);
+    @JsonProperty("active")
+    Active(1),
+    @JsonProperty("inactive")
+    Inactive(2);
 
     private final int code;
 

java-sdk/src/test/java/rs/iggy/clients/blocking/IntegrationTest.java

@@ -39,7 +39,7 @@ protected void setUpStreamAndTopic() {
                 .createTopic(42L,
                         of(42L),
                         1L,
-                        CompressionAlgorithm.none,
+                        CompressionAlgorithm.None,
                         BigInteger.ZERO,
                         BigInteger.ZERO,
                         empty(),

java-sdk/src/test/java/rs/iggy/clients/blocking/TopicsClientBaseTest.java

@@ -28,7 +28,7 @@ void shouldCreateAndDeleteTopic() {
         topicsClient.createTopic(42L,
                 of(42L),
                 1L,
-                CompressionAlgorithm.none,
+                CompressionAlgorithm.None,
                 BigInteger.ZERO,
                 BigInteger.ZERO,
                 empty(),
@@ -54,7 +54,7 @@ void shouldUpdateTopic() {
         var topic = topicsClient.createTopic(42L,
                 of(42L),
                 1L,
-                CompressionAlgorithm.none,
+                CompressionAlgorithm.None,
                 BigInteger.ZERO,
                 BigInteger.ZERO,
                 empty(),
@@ -64,7 +64,7 @@ void shouldUpdateTopic() {
         // when
         topicsClient.updateTopic(StreamId.of(42L),
                 TopicId.of(topic.id()),
-                CompressionAlgorithm.none,
+                CompressionAlgorithm.None,
                 BigInteger.valueOf(5000),
                 BigInteger.ZERO,
                 empty(),

java-sdk/src/test/java/rs/iggy/clients/blocking/UsersClientBaseTest.java

@@ -46,7 +46,10 @@ void shouldCreateAndDeleteUser() {
         login();
 
         // when
-        var createdUser = usersClient.createUser("test", "test", UserStatus.active, Optional.of(new Permissions(createGlobalPermissions(true), Collections.emptyMap())));
+        var createdUser = usersClient.createUser("test",
+                "test",
+                UserStatus.Active,
+                Optional.of(new Permissions(createGlobalPermissions(true), Collections.emptyMap())));
 
         // then
         assertThat(createdUser).isNotNull();
@@ -71,22 +74,22 @@ void shouldCreateAndDeleteUser() {
     void shouldUpdateUserStatus() {
         // given
         login();
-        UserInfoDetails user = usersClient.createUser("test", "test", UserStatus.active, Optional.empty());
+        UserInfoDetails user = usersClient.createUser("test", "test", UserStatus.Active, Optional.empty());
 
         // when
-        usersClient.updateUser(user.id(), Optional.empty(), Optional.of(UserStatus.inactive));
+        usersClient.updateUser(user.id(), Optional.empty(), Optional.of(UserStatus.Inactive));
 
         // then
         List<UserInfo> users = usersClient.getUsers();
-        assertThat(users).map(UserInfo::status).contains(UserStatus.inactive);
+        assertThat(users).map(UserInfo::status).contains(UserStatus.Inactive);
     }
 
     @Test
     void shouldUpdateUserPermissions() {
         // given
         var permissions = new Permissions(createGlobalPermissions(true), Collections.emptyMap());
         login();
-        UserInfoDetails user = usersClient.createUser("test", "test", UserStatus.active, Optional.of(permissions));
+        UserInfoDetails user = usersClient.createUser("test", "test", UserStatus.Active, Optional.of(permissions));
 
         // when
         usersClient.updatePermissions(user.id(), Optional.of(new Permissions(createGlobalPermissions(false), Collections.emptyMap())));