[ECO-5553] Fixed omitted tests responsible for handling vcdiff encoding

Author: sacOO7

lib/src/test/java/io/ably/lib/test/realtime/RealtimeChannelTest.java

@@ -31,6 +31,7 @@
 import org.junit.Test;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.HashMap;
@@ -46,6 +47,7 @@
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertSame;
 import static org.junit.Assert.assertThat;
+import static org.junit.Assert.assertThrows;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
@@ -150,7 +152,7 @@ public void attach_detach() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void attach_with_channel_params_channels_get() {
         String channelName = "attach_with_channel_params_channels_get_" + testParams.name;
         AblyRealtime ably = null;
@@ -163,7 +165,7 @@ public void attach_with_channel_params_channels_get() {
             assertEquals("Verify connected state reached", ConnectionState.connected, ably.connection.state);
 
             ChannelOptions options = new ChannelOptions();
-            options.params = new HashMap<String, String>();
+            options.params = new HashMap<>();
             options.params.put("modes", "subscribe");
             options.params.put("delta", "vcdiff");
 
@@ -183,7 +185,7 @@ public void attach_with_channel_params_channels_get() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void attach_with_channel_params_set_options() {
         String channelName = "attach_with_channel_params_set_options_" + testParams.name;
         AblyRealtime ably = null;
@@ -196,6 +198,7 @@ public void attach_with_channel_params_set_options() {
             assertEquals("Verify connected state reached", ConnectionState.connected, ably.connection.state);
 
             ChannelOptions options = new ChannelOptions();
+            options.params = new HashMap<>();
             options.params.put("modes", "subscribe");
             options.params.put("delta", "vcdiff");
 
@@ -216,7 +219,7 @@ public void attach_with_channel_params_set_options() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void channels_get_should_throw_when_would_cause_reattach() {
         String channelName = "channels_get_should_throw_when_would_cause_reattach_" + testParams.name;
         AblyRealtime ably = null;
@@ -228,22 +231,25 @@ public void channels_get_should_throw_when_would_cause_reattach() {
             (new ConnectionWaiter(ably.connection)).waitFor(ConnectionState.connected);
             assertEquals("Verify connected state reached", ConnectionState.connected, ably.connection.state);
 
-            ChannelOptions options = new ChannelOptions();
-            options.params.put("modes", "subscribe");
-            options.params.put("delta", "vcdiff");
+            ChannelOptions options = new ChannelOptions() {{
+                    params = new HashMap<>();
+                    params.put("modes", "subscribe");
+                    params.put("delta", "vcdiff");
+            }};
 
             /* create a channel and attach */
             final Channel channel = ably.channels.get(channelName, options);
             channel.attach();
             (new ChannelWaiter(channel)).waitFor(ChannelState.attached);
 
-            try {
-                ably.channels.get(channelName, options);
-            } catch (AblyException e) {
-                assertEquals("Verify error code", 400, e.errorInfo.code);
-                assertEquals("Verify error status code", 40000, e.errorInfo.statusCode);
-                assertTrue("Verify error message", e.errorInfo.message.contains("setOptions"));
-            }
+            AblyRealtime finalAbly = ably;
+            AblyException exception = assertThrows(AblyException.class, () ->
+                finalAbly.channels.get(channelName, options));
+
+            assertEquals("Verify error code", 400, exception.errorInfo.code);
+            assertEquals("Verify error status code", 40000, exception.errorInfo.statusCode);
+            assertTrue("Verify error message", exception.errorInfo.message.contains("use Channel.setOptions()"));
+
         } catch (AblyException e) {
             e.printStackTrace();
             fail("init0: Unexpected exception instantiating library");
@@ -253,7 +259,7 @@ public void channels_get_should_throw_when_would_cause_reattach() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void attach_with_channel_params_modes_and_channel_modes() {
         String channelName = "attach_with_channel_params_modes_and_channel_modes_" + testParams.name;
         AblyRealtime ably = null;
@@ -289,7 +295,7 @@ public void attach_with_channel_params_modes_and_channel_modes() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void attach_with_channel_modes() {
         String channelName = "attach_with_channel_modes_" + testParams.name;
         AblyRealtime ably = null;
@@ -312,7 +318,11 @@ public void attach_with_channel_modes() {
             channel.attach();
             (new ChannelWaiter(channel)).waitFor(ChannelState.attached);
             assertEquals("Verify attached state reached", ChannelState.attached, channel.state);
-            assertEquals("Verify channel modes", channel.getModes(), options.modes);
+            assertEquals(2, channel.getModes().length);
+
+            assertThat("Verify channel modes",
+                Arrays.asList(channel.getModes()),
+                Matchers.containsInAnyOrder(ChannelMode.publish, ChannelMode.presence_subscribe));
         } catch (AblyException e) {
             e.printStackTrace();
             fail("init0: Unexpected exception instantiating library");
@@ -322,7 +332,7 @@ public void attach_with_channel_modes() {
         }
     }
 
-    /*@Test*/
+    @Test
     public void attach_with_params_delta_and_channel_modes() {
         String channelName = "attach_with_params_delta_and_channel_modes_" + testParams.name;
         AblyRealtime ably = null;
@@ -335,7 +345,7 @@ public void attach_with_params_delta_and_channel_modes() {
             assertEquals("Verify connected state reached", ConnectionState.connected, ably.connection.state);
 
             ChannelOptions options = new ChannelOptions();
-            options.params = new HashMap<String, String>();
+            options.params = new HashMap<>();
             options.params.put("delta", "vcdiff");
             options.modes = new ChannelMode[] {
                 ChannelMode.publish,
@@ -348,9 +358,11 @@ public void attach_with_params_delta_and_channel_modes() {
             channel.attach();
             (new ChannelWaiter(channel)).waitFor(ChannelState.attached);
             assertEquals("Verify attached state reached", ChannelState.attached, channel.state);
-            options.params.put("modes", "publish,subscribe,presence_subscribe");
-            assertEquals("Verify channel params", channel.getParams(), options.params);
-            assertEquals("Verify channel modes", channel.getModes(), options.modes);
+
+            assertEquals("Verify channel params", options.params, channel.getParams());
+            assertThat("Verify channel modes",
+                Arrays.asList(channel.getModes()),
+                Matchers.containsInAnyOrder(ChannelMode.publish, ChannelMode.subscribe, ChannelMode.presence_subscribe));
         } catch (AblyException e) {
             e.printStackTrace();
             fail("init0: Unexpected exception instantiating library");