[ECO-5482] Implemented helper method to validate write api config

Author: sacOO7

lib/src/main/java/io/ably/lib/objects/Adapter.java

@@ -3,10 +3,7 @@
 import io.ably.lib.realtime.AblyRealtime;
 import io.ably.lib.realtime.ChannelState;
 import io.ably.lib.realtime.CompletionListener;
-import io.ably.lib.types.AblyException;
-import io.ably.lib.types.ChannelMode;
-import io.ably.lib.types.ChannelOptions;
-import io.ably.lib.types.ProtocolMessage;
+import io.ably.lib.types.*;
 import io.ably.lib.util.Log;
 import org.jetbrains.annotations.NotNull;
 
@@ -65,4 +62,9 @@ public ChannelState getChannelState(@NotNull String channelName) {
         Log.e(TAG, "getChannelState(): channel not found: " + channelName);
         return null;
     }
+
+    @Override
+    public @NotNull ClientOptions getClientOptions() {
+        return ably.options;
+    }
 }

lib/src/main/java/io/ably/lib/objects/LiveObjectsAdapter.java

@@ -4,6 +4,7 @@
 import io.ably.lib.realtime.CompletionListener;
 import io.ably.lib.types.AblyException;
 import io.ably.lib.types.ChannelMode;
+import io.ably.lib.types.ClientOptions;
 import io.ably.lib.types.ProtocolMessage;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -53,5 +54,14 @@ public interface LiveObjectsAdapter {
      * @return the current state of the specified channel, or null if the channel is not found
      */
     @Nullable ChannelState getChannelState(@NotNull String channelName);
+
+    /**
+     * Retrieves the client options configured for the Ably client.
+     * Used to access client configuration parameters such as echoMessages setting
+     * that affect the behavior of LiveObjects operations.
+     *
+     * @return the client options containing configuration parameters
+     */
+    @NotNull ClientOptions getClientOptions();
 }
 

live-objects/src/main/kotlin/io/ably/lib/objects/Helpers.kt

@@ -49,6 +49,12 @@ internal fun LiveObjectsAdapter.throwIfInvalidAccessApiConfiguration(channelName
   throwIfInChannelState(channelName, arrayOf(ChannelState.detached, ChannelState.failed))
 }
 
+internal fun LiveObjectsAdapter.throwIfInvalidWriteApiConfiguration(channelName: String) {
+  throwIfEchoMessagesDisabled()
+  throwIfMissingChannelMode(channelName, ChannelMode.object_publish)
+  throwIfInChannelState(channelName, arrayOf(ChannelState.detached, ChannelState.failed, ChannelState.suspended))
+}
+
 // Spec: RTO2
 internal fun LiveObjectsAdapter.throwIfMissingChannelMode(channelName: String, channelMode: ChannelMode) {
   val channelModes = getChannelModes(channelName)
@@ -65,6 +71,12 @@ internal fun LiveObjectsAdapter.throwIfInChannelState(channelName: String, chann
   }
 }
 
+internal fun LiveObjectsAdapter.throwIfEchoMessagesDisabled() {
+   if (!clientOptions.echoMessages) {
+     throw clientError("\"echoMessages\" client option must be enabled for this operation")
+   }
+}
+
 internal class Binary(val data: ByteArray) {
   override fun equals(other: Any?): Boolean {
     if (this === other) return true