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

Author: sacOO7

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

@@ -46,6 +46,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 +151,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 +164,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 +184,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 +197,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 +218,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 +230,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");