[ECO-5137][CHA-RL9] Updated DefaultRoom class

1. Updated DefaultRoom constructor params as internal properties
2. Updated room features contructors to accept only `room` as a arg
3. Added spec documentation for ensureAttached method
4. Fixed unit/integration tests/test helpers for Room and Room features
5. Updated Sandbox.kt to retry request on remaining timeout exceptions

chat-android/src/main/java/com/ably/chat/Occupancy.kt

@@ -4,7 +4,6 @@ package com.ably.chat
 
 import com.google.gson.JsonObject
 import com.google.gson.JsonPrimitive
-import io.ably.lib.realtime.AblyRealtime
 import io.ably.lib.realtime.Channel
 import java.util.concurrent.CopyOnWriteArrayList
 import kotlinx.coroutines.CoroutineScope
@@ -73,20 +72,21 @@ data class OccupancyEvent(
 )
 
 internal class DefaultOccupancy(
-    realtimeChannels: AblyRealtime.Channels,
-    private val chatApi: ChatApi,
-    private val roomId: String,
-    private val logger: Logger,
-) : Occupancy, ContributesToRoomLifecycleImpl(logger) {
+    private val room: DefaultRoom,
+) : Occupancy, ContributesToRoomLifecycleImpl(room.roomLogger) {
 
     override val featureName: String = "occupancy"
 
     override val attachmentErrorCode: ErrorCode = ErrorCode.OccupancyAttachmentFailed
 
     override val detachmentErrorCode: ErrorCode = ErrorCode.OccupancyDetachmentFailed
 
+    private val realtimeChannels = room.realtimeClient.channels
+
+    private val logger = room.roomLogger.withContext(tag = "Occupancy")
+
     // (CHA-O1)
-    private val messagesChannelName = "$roomId::\$chat::\$chatMessages"
+    private val messagesChannelName = "${room.roomId}::\$chat::\$chatMessages"
 
     override val channel: Channel = realtimeChannels.get(
         messagesChannelName,
@@ -142,7 +142,7 @@ internal class DefaultOccupancy(
     // (CHA-O3)
     override suspend fun get(): OccupancyEvent {
         logger.trace("Occupancy.get()")
-        return chatApi.getOccupancy(roomId)
+        return room.chatApi.getOccupancy(room.roomId)
     }
 
     override fun release() {

chat-android/src/main/java/com/ably/chat/Presence.kt

@@ -6,7 +6,6 @@ import com.google.gson.JsonElement
 import com.google.gson.JsonObject
 import io.ably.lib.realtime.Channel
 import io.ably.lib.types.PresenceMessage
-import io.ably.lib.realtime.Presence as PubSubPresence
 import io.ably.lib.realtime.Presence.PresenceListener as PubSubPresenceListener
 
 typealias PresenceData = JsonElement
@@ -134,19 +133,23 @@ data class PresenceEvent(
 )
 
 internal class DefaultPresence(
-    private val clientId: String,
-    override val channel: Channel,
-    private val presence: PubSubPresence,
-    private val logger: Logger,
-) : Presence, ContributesToRoomLifecycleImpl(logger) {
+    private val room: DefaultRoom,
+) : Presence, ContributesToRoomLifecycleImpl(room.roomLogger) {
 
     override val featureName = "presence"
 
     override val attachmentErrorCode: ErrorCode = ErrorCode.PresenceAttachmentFailed
 
     override val detachmentErrorCode: ErrorCode = ErrorCode.PresenceDetachmentFailed
 
+    override val channel: Channel = room.messages.channel
+
+    private val logger = room.roomLogger.withContext(tag = "Presence")
+
+    private val presence = channel.presence
+
     override suspend fun get(waitForSync: Boolean, clientId: String?, connectionId: String?): List<PresenceMember> {
+        room.ensureAttached()
         return presence.getCoroutine(waitForSync, clientId, connectionId).map { user ->
             PresenceMember(
                 clientId = user.clientId,
@@ -160,15 +163,18 @@ internal class DefaultPresence(
     override suspend fun isUserPresent(clientId: String): Boolean = presence.getCoroutine(clientId = clientId).isNotEmpty()
 
     override suspend fun enter(data: PresenceData?) {
-        presence.enterClientCoroutine(clientId, wrapInUserCustomData(data))
+        room.ensureAttached()
+        presence.enterClientCoroutine(room.clientId, wrapInUserCustomData(data))
     }
 
     override suspend fun update(data: PresenceData?) {
-        presence.updateClientCoroutine(clientId, wrapInUserCustomData(data))
+        room.ensureAttached()
+        presence.updateClientCoroutine(room.clientId, wrapInUserCustomData(data))
     }
 
     override suspend fun leave(data: PresenceData?) {
-        presence.leaveClientCoroutine(clientId, wrapInUserCustomData(data))
+        room.ensureAttached()
+        presence.leaveClientCoroutine(room.clientId, wrapInUserCustomData(data))
     }
 
     override fun subscribe(listener: Presence.Listener): Subscription {

chat-android/src/main/java/com/ably/chat/Room.kt

@@ -112,12 +112,12 @@ interface Room {
 internal class DefaultRoom(
     override val roomId: String,
     override val options: RoomOptions,
-    private val realtimeClient: RealtimeClient,
-    chatApi: ChatApi,
-    clientId: String,
+    internal val realtimeClient: RealtimeClient,
+    internal val chatApi: ChatApi,
+    internal val clientId: String,
     logger: Logger,
 ) : Room {
-    private val roomLogger = logger.withContext("Room", mapOf("roomId" to roomId))
+    internal val roomLogger = logger.withContext("Room", mapOf("roomId" to roomId))
 
     /**
      * RoomScope is a crucial part of the Room lifecycle. It manages sequential and atomic operations.
@@ -186,46 +186,25 @@ internal class DefaultRoom(
         val roomFeatures = mutableListOf<ContributesToRoomLifecycle>(messages)
 
         options.presence?.let {
-            val presenceContributor = DefaultPresence(
-                clientId = clientId,
-                channel = messages.channel,
-                presence = messages.channel.presence,
-                logger = roomLogger.withContext(tag = "Presence"),
-            )
+            val presenceContributor = DefaultPresence(room = this)
             roomFeatures.add(presenceContributor)
             _presence = presenceContributor
         }
 
         options.typing?.let {
-            val typingContributor = DefaultTyping(
-                roomId = roomId,
-                realtimeClient = realtimeClient,
-                clientId = clientId,
-                options = options.typing,
-                logger = roomLogger.withContext(tag = "Typing"),
-            )
+            val typingContributor = DefaultTyping(room = this)
             roomFeatures.add(typingContributor)
             _typing = typingContributor
         }
 
         options.reactions?.let {
-            val reactionsContributor = DefaultRoomReactions(
-                roomId = roomId,
-                clientId = clientId,
-                realtimeChannels = realtimeClient.channels,
-                logger = roomLogger.withContext(tag = "Reactions"),
-            )
+            val reactionsContributor = DefaultRoomReactions(room = this)
             roomFeatures.add(reactionsContributor)
             _reactions = reactionsContributor
         }
 
         options.occupancy?.let {
-            val occupancyContributor = DefaultOccupancy(
-                roomId = roomId,
-                realtimeChannels = realtimeClient.channels,
-                chatApi = chatApi,
-                logger = roomLogger.withContext(tag = "Occupancy"),
-            )
+            val occupancyContributor = DefaultOccupancy(room = this)
             roomFeatures.add(occupancyContributor)
             _occupancy = occupancyContributor
         }
@@ -256,6 +235,11 @@ internal class DefaultRoom(
         lifecycleManager.release()
     }
 
+    /**
+     * Ensures that the room is attached before performing any realtime room operation.
+     * @throws roomInvalidStateException if room is not in ATTACHING/ATTACHED state.
+     * Spec: CHA-RL9
+     */
     internal suspend fun ensureAttached() {
         if (statusLifecycle.status == RoomStatus.Attached) {
             return
@@ -269,15 +253,20 @@ internal class DefaultRoom(
                         if (it.current == RoomStatus.Attached) {
                             attachDeferred.complete(Unit)
                         } else {
-                            attachDeferred.completeExceptionally(roomInvalidStateException(statusLifecycle.status))
+                            val invalidStateException =
+                                roomInvalidStateException(statusLifecycle.status, HttpStatusCode.InternalServerError)
+                            attachDeferred.completeExceptionally(invalidStateException)
                         }
                     }
-                    else -> attachDeferred.completeExceptionally(roomInvalidStateException(statusLifecycle.status))
+                    else -> {
+                        val invalidStateException = roomInvalidStateException(statusLifecycle.status, HttpStatusCode.InternalServerError)
+                        attachDeferred.completeExceptionally(invalidStateException)
+                    }
                 }
             }
             attachDeferred.await()
             return
         }
-        throw roomInvalidStateException(statusLifecycle.status)
+        throw roomInvalidStateException(statusLifecycle.status, HttpStatusCode.BadRequest)
     }
 }

chat-android/src/main/java/com/ably/chat/RoomReactions.kt

@@ -3,7 +3,6 @@
 package com.ably.chat
 
 import com.google.gson.JsonObject
-import io.ably.lib.realtime.AblyRealtime
 import io.ably.lib.types.AblyException
 import io.ably.lib.types.ErrorInfo
 import io.ably.lib.types.MessageExtras
@@ -104,22 +103,21 @@ data class SendReactionParams(
 )
 
 internal class DefaultRoomReactions(
-    roomId: String,
-    private val clientId: String,
-    private val realtimeChannels: AblyRealtime.Channels,
-    private val logger: Logger,
-) : RoomReactions, ContributesToRoomLifecycleImpl(logger) {
+    private val room: DefaultRoom,
+) : RoomReactions, ContributesToRoomLifecycleImpl(room.roomLogger) {
 
     override val featureName = "reactions"
 
-    private val roomReactionsChannelName = "$roomId::\$chat::\$reactions"
+    private val roomReactionsChannelName = "${room.roomId}::\$chat::\$reactions"
 
-    override val channel: AblyRealtimeChannel = realtimeChannels.get(roomReactionsChannelName, ChatChannelOptions())
+    override val channel: AblyRealtimeChannel = room.realtimeClient.channels.get(roomReactionsChannelName, ChatChannelOptions())
 
     override val attachmentErrorCode: ErrorCode = ErrorCode.ReactionsAttachmentFailed
 
     override val detachmentErrorCode: ErrorCode = ErrorCode.ReactionsDetachmentFailed
 
+    private val logger = room.roomLogger.withContext(tag = "Reactions")
+
     // (CHA-ER3) Ephemeral room reactions are sent to Ably via the Realtime connection via a send method.
     // (CHA-ER3a) Reactions are sent on the channel using a message in a particular format - see spec for format.
     override suspend fun send(params: SendReactionParams) {
@@ -137,6 +135,7 @@ internal class DefaultRoomReactions(
                 )
             }
         }
+        room.ensureAttached() // TODO - This check might be removed in the future due to core spec change
         channel.publishCoroutine(pubSubMessage)
     }
 
@@ -154,7 +153,7 @@ internal class DefaultRoomReactions(
                 clientId = pubSubMessage.clientId,
                 metadata = data.get("metadata")?.toMap() ?: mapOf(),
                 headers = pubSubMessage.extras?.asJsonObject()?.get("headers")?.toMap() ?: mapOf(),
-                isSelf = pubSubMessage.clientId == clientId,
+                isSelf = pubSubMessage.clientId == room.clientId,
             )
             listener.onReaction(reaction)
         }
@@ -163,6 +162,6 @@ internal class DefaultRoomReactions(
     }
 
     override fun release() {
-        realtimeChannels.release(channel.name)
+        room.realtimeClient.channels.release(channel.name)
     }
 }

chat-android/src/main/java/com/ably/chat/Typing.kt

@@ -91,28 +91,26 @@ interface Typing : EmitsDiscontinuities {
 data class TypingEvent(val currentlyTyping: Set<String>)
 
 internal class DefaultTyping(
-    roomId: String,
-    private val realtimeClient: RealtimeClient,
-    private val clientId: String,
-    private val options: TypingOptions?,
-    private val logger: Logger,
-) : Typing, ContributesToRoomLifecycleImpl(logger) {
-    private val typingIndicatorsChannelName = "$roomId::\$chat::\$typingIndicators"
+    private val room: DefaultRoom,
+) : Typing, ContributesToRoomLifecycleImpl(room.roomLogger) {
+    private val typingIndicatorsChannelName = "${room.roomId}::\$chat::\$typingIndicators"
 
     override val featureName = "typing"
 
     override val attachmentErrorCode: ErrorCode = ErrorCode.TypingAttachmentFailed
 
     override val detachmentErrorCode: ErrorCode = ErrorCode.TypingDetachmentFailed
 
+    private val logger = room.roomLogger.withContext(tag = "Typing")
+
     private val typingScope = CoroutineScope(Dispatchers.Default.limitedParallelism(1) + SupervisorJob())
 
     private val eventBus = MutableSharedFlow<Unit>(
         extraBufferCapacity = 1,
         onBufferOverflow = BufferOverflow.DROP_OLDEST,
     )
 
-    override val channel: Channel = realtimeClient.channels.get(typingIndicatorsChannelName, ChatChannelOptions())
+    override val channel: Channel = room.realtimeClient.channels.get(typingIndicatorsChannelName, ChatChannelOptions())
 
     private var typingJob: Job? = null
 
@@ -155,6 +153,7 @@ internal class DefaultTyping(
 
     override suspend fun get(): Set<String> {
         logger.trace("DefaultTyping.get()")
+        room.ensureAttached()
         return channel.presence.getCoroutine().map { it.clientId }.toSet()
     }
 
@@ -169,7 +168,8 @@ internal class DefaultTyping(
                 startTypingTimer()
             } else {
                 startTypingTimer()
-                channel.presence.enterClientCoroutine(clientId)
+                room.ensureAttached()
+                channel.presence.enterClientCoroutine(room.clientId)
             }
         }.join()
     }
@@ -178,18 +178,19 @@ internal class DefaultTyping(
         logger.trace("DefaultTyping.stop()")
         typingScope.launch {
             typingJob?.cancel()
-            channel.presence.leaveClientCoroutine(clientId)
+            room.ensureAttached()
+            channel.presence.leaveClientCoroutine(room.clientId)
         }.join()
     }
 
     override fun release() {
         presenceSubscription.unsubscribe()
         typingScope.cancel()
-        realtimeClient.channels.release(channel.name)
+        room.realtimeClient.channels.release(channel.name)
     }
 
     private fun startTypingTimer() {
-        val timeout = options?.timeoutMs ?: throw AblyException.fromErrorInfo(
+        val timeout = room.options.typing?.timeoutMs ?: throw AblyException.fromErrorInfo(
             ErrorInfo(
                 "Typing options hasn't been initialized",
                 ErrorCode.BadRequest.code,

chat-android/src/main/java/com/ably/chat/Utils.kt

@@ -221,8 +221,8 @@ fun lifeCycleException(
     cause: Throwable? = null,
 ): AblyException = createAblyException(errorInfo, cause)
 
-fun roomInvalidStateException(roomStatus: RoomStatus) =
-    ablyException("Can't perform operation, room is in an invalid state: $roomStatus", ErrorCode.RoomInInvalidState)
+fun roomInvalidStateException(roomStatus: RoomStatus, statusCode: Int) =
+    ablyException("Can't perform operation, room is in an invalid state: $roomStatus", ErrorCode.RoomInInvalidState, statusCode)
 
 fun ablyException(
     errorMessage: String,