Merge pull request #1223 from ably/feature/liveobjects-kotlin-implementation

[AIT-934] feat(liveobjects): `LiveObjects` implementation to new path-based API (Kotlin)

Author: sacOO7

android/proguard.txt

@@ -1,8 +1,28 @@
 -keep public class io.ably.lib.transport.WebSocketTransport$Factory {*;}
 -keep class io.ably.lib.types.** {*;}
--keep class io.ably.lib.objects.*LiveObjectsPlugin {*;}
--keep class io.ably.lib.objects.serialization.*Serializer {*;}
--keep class io.ably.lib.objects.ObjectsJsonSerializer {*;}
+
+# LiveObjects implementations are resolved at runtime via Class.forName(...) +
+# getDeclaredConstructor(...).newInstance(...) against hard-coded class-name strings
+# (see LiveObjectsPlugin.Factory, ObjectSerializer.Holder, LiveCounter#create and
+# LiveMap#create). R8 must not rename or strip these classes or their reflectively
+# invoked constructors.
+-keep class io.ably.lib.liveobjects.DefaultLiveObjectsPlugin { <init>(...); }
+-keep class io.ably.lib.liveobjects.serialization.DefaultObjectsSerializer { <init>(...); }
+-keep class io.ably.lib.liveobjects.value.livecounter.DefaultLiveCounter { <init>(...); }
+-keep class io.ably.lib.liveobjects.value.livemap.DefaultLiveMap { <init>(...); }
+
+# ObjectJsonSerializer and WireObjectDataJsonSerializer are instantiated reflectively
+# by Gson via @JsonAdapter annotations (on ProtocolMessage and WireObjectData
+# respectively); keep their no-arg constructors.
+-keep class io.ably.lib.liveobjects.serialization.ObjectJsonSerializer { <init>(...); }
+-keep class io.ably.lib.liveobjects.serialization.WireObjectDataJsonSerializer { <init>(...); }
+
+# The Wire* object model is (de)serialized to/from JSON by Gson via field-name
+# reflection (DefaultObjectsSerializer -> JsonSerialization.gson.fromJson/toJsonTree).
+# R8 must not rename or strip these fields or JSON transport silently breaks. Mirrors
+# the io.ably.lib.types.** rule above. (The MessagePack path uses explicit string keys
+# and is unaffected.)
+-keep class io.ably.lib.liveobjects.message.** { *; }
 
 -keep class org.msgpack.core.** {*;}
 -keepclasseswithmembers class io.ably.lib.rest.Auth** {*;}

lib/src/main/java/io/ably/lib/liveobjects/message/ObjectsMapEntry.java

@@ -5,7 +5,7 @@
 /**
  * Represents the value at a given key in a {@code LiveMap} object.
  *
- * <p>Spec: ME1
+ * <p>Spec: OME1
  */
 public interface ObjectsMapEntry {
 

lib/src/main/java/io/ably/lib/liveobjects/value/LiveCounter.java

@@ -23,7 +23,7 @@
  */
 public abstract class LiveCounter {
 
-    private static final String IMPLEMENTATION_CLASS = "io.ably.lib.liveobjects.value.DefaultLiveCounter";
+    private static final String IMPLEMENTATION_CLASS = "io.ably.lib.liveobjects.value.livecounter.DefaultLiveCounter";
 
     /**
      * Extended by the LiveObjects implementation; not intended for

lib/src/main/java/io/ably/lib/liveobjects/value/LiveMap.java

@@ -26,7 +26,7 @@
  */
 public abstract class LiveMap {
 
-    private static final String IMPLEMENTATION_CLASS = "io.ably.lib.liveobjects.value.DefaultLiveMap";
+    private static final String IMPLEMENTATION_CLASS = "io.ably.lib.liveobjects.value.livemap.DefaultLiveMap";
 
     /**
      * Extended by the LiveObjects implementation; not intended for

liveobjects/src/main/kotlin/io/ably/lib/liveobjects/DefaultLiveObjectsPlugin.kt

@@ -0,0 +1,36 @@
+package io.ably.lib.liveobjects
+
+import io.ably.lib.liveobjects.adapter.AblyClientAdapter
+import io.ably.lib.realtime.ChannelState
+import io.ably.lib.types.ProtocolMessage
+import java.util.concurrent.ConcurrentHashMap
+
+public class DefaultLiveObjectsPlugin(private val adapter: AblyClientAdapter) : LiveObjectsPlugin {
+
+  private val objects = ConcurrentHashMap<String, DefaultRealtimeObject>()
+
+  override fun getInstance(channelName: String): RealtimeObject {
+    return objects.getOrPut(channelName) { DefaultRealtimeObject(channelName, adapter) }
+  }
+
+  override fun handle(msg: ProtocolMessage) {
+    val channelName = msg.channel
+    objects[channelName]?.handle(msg)
+  }
+
+  override fun handleStateChange(channelName: String, state: ChannelState, hasObjects: Boolean) {
+    objects[channelName]?.handleStateChange(state, hasObjects)
+  }
+
+  override fun dispose(channelName: String) {
+    objects.remove(channelName)
+      ?.dispose(clientError("Channel has been released using channels.release()"))
+  }
+
+  override fun dispose() {
+    objects.values.forEach {
+      it.dispose(clientError("AblyClient has been closed using client.close()"))
+    }
+    objects.clear()
+  }
+}