[ECO-5056] Added test for getObjects when liveobjects plugin is not installed

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;
 
@@ -2578,6 +2579,29 @@ public void connect_should_not_rewrite_immediate_attach() throws AblyException {
         }
     }
 
+    @Test
+    public void channel_get_objects_throws_exception() throws AblyException {
+        ClientOptions opts = createOptions(testVars.keys[0].keyStr);
+        try (AblyRealtime ably = new AblyRealtime(opts)) {
+
+            /* wait until connected */
+            new ConnectionWaiter(ably.connection).waitFor(ConnectionState.connected);
+            assertEquals("Verify connected state reached", ably.connection.state, ConnectionState.connected);
+
+            /* create a channel and attach */
+            final Channel channel = ably.channels.get("channel");
+            channel.attach();
+            new ChannelWaiter(channel).waitFor(ChannelState.attached);
+            assertEquals("Verify attached state reached", channel.state, ChannelState.attached);
+
+            AblyException exception = assertThrows(AblyException.class, channel::getObjects);
+            assertNotNull(exception);
+            assertEquals(40019, exception.errorInfo.code);
+            assertEquals(400, exception.errorInfo.statusCode);
+            assertTrue(exception.errorInfo.message.contains("LiveObjects plugin hasn't been installed"));
+        }
+    }
+
     static class DetachingProtocolListener implements DebugOptions.RawProtocolListener {
 
         public Channel theChannel;

liveobjects/src/test/kotlin/io/ably/lib/objects/unit/HelpersTest.kt

@@ -76,9 +76,10 @@ class HelpersTest {
   fun testRetrieveObjectsGCGracePeriodDeferredInvokesOnConnectedWithValue() {
     val adapter = getMockObjectsAdapter()
     val connManager = adapter.connectionManager
+    val connection = adapter.connection
 
     var value: Long? = null
-    every { adapter.connection.once(ConnectionEvent.connected, any()) } answers {
+    every { connection.once(ConnectionEvent.connected, any()) } answers {
       val listener = secondArg<ConnectionStateListener>()
       connManager.setPrivateField("objectsGCGracePeriod", 456L)
       listener.onConnectionStateChanged(mockk(relaxed = true))
@@ -87,23 +88,24 @@ class HelpersTest {
     adapter.retrieveObjectsGCGracePeriod { v -> value = v }
 
     assertEquals(456L, value)
-    verify(exactly = 1) { adapter.connection.once(ConnectionEvent.connected, any()) }
+    verify(exactly = 1) { connection.once(ConnectionEvent.connected, any()) }
   }
 
   @Test
   fun testRetrieveObjectsGCGracePeriodDeferredInvokesOnConnectedWithNull() {
     val adapter = getMockObjectsAdapter()
+    val connection = adapter.connection
 
     var value: Long? = null
-    every { adapter.connection.once(ConnectionEvent.connected, any()) } answers {
+    every { connection.once(ConnectionEvent.connected, any()) } answers {
       val listener = secondArg<ConnectionStateListener>()
       listener.onConnectionStateChanged(mockk(relaxed = true))
     }
 
     adapter.retrieveObjectsGCGracePeriod { v -> value = v }
 
     assertNull(value)
-    verify(exactly = 1) { adapter.connection.once(ConnectionEvent.connected, any()) }
+    verify(exactly = 1) { connection.once(ConnectionEvent.connected, any()) }
   }
 
   @Test