[Chat][Bug] Fix the crash when network is disconnected. (#687)

azure-communication-ui/chat/src/androidTest/java/com/azure/android/communication/ui/chat/mocking/TestChatSDK.kt

@@ -35,12 +35,18 @@ internal class TestChatSDK(
         chatStatusStateFlow.value = status
     }
 
-    override fun initialization() {
+    override fun initialization(): CompletableFuture<Void> {
+        val future = CompletableFuture<Void>()
+        // coroutine to make sure requests are not blocking
+        coroutineScope.launch {
+            future.complete(null)
+        }
+        return future
     }
 
     override fun destroy() {}
 
-    override fun getAdminUserId(): String? {
+    override fun getAdminUserId(): String {
         return ""
     }
 

azure-communication-ui/chat/src/main/java/com/azure/android/communication/ui/chat/redux/middleware/sdk/ChatActionHandler.kt

@@ -178,14 +178,22 @@ internal class ChatActionHandler(private val chatService: ChatService) {
     }
 
     private fun initialization(dispatch: Dispatch, threadId: String) {
-        try {
-            chatService.initialize()
-            chatService.getAdminUserId()?.let {
-                dispatch.invoke(ParticipantAction.ParticipantToHideReceived(it))
+        chatService.initialize().whenComplete { _, error ->
+            if (error != null) {
+                // TODO: lets use only one action and state to fire error for timing
+                // TODO: while working on error stories, we can create separate states for every error
+                dispatch(
+                    ErrorAction.ChatStateErrorOccurred(
+                        chatCompositeErrorEvent = ChatCompositeErrorEvent(
+                            threadId,
+                            ChatCompositeErrorCode.JOIN_FAILED,
+                            error,
+                        )
+                    )
+                )
+            } else {
+                dispatch.invoke(ParticipantAction.ParticipantToHideReceived(chatService.getAdminUserId()))
             }
-        } catch (ex: Exception) {
-            val error = ChatCompositeErrorEvent(threadId, ChatCompositeErrorCode.JOIN_FAILED, ex)
-            dispatch(ErrorAction.ChatStateErrorOccurred(chatCompositeErrorEvent = error))
         }
     }
 

azure-communication-ui/chat/src/main/java/com/azure/android/communication/ui/chat/service/sdk/ChatSDK.kt

@@ -15,9 +15,9 @@ import kotlinx.coroutines.flow.StateFlow
 import org.threeten.bp.OffsetDateTime
 
 internal interface ChatSDK {
-    fun initialization()
+    fun initialization(): CompletableFuture<Void>
     fun destroy()
-    fun getAdminUserId(): String?
+    fun getAdminUserId(): String
     fun requestPreviousPage()
     fun requestChatParticipants()
 

azure-communication-ui/chat/src/main/java/com/azure/android/communication/ui/chat/service/sdk/ChatSDKWrapper.kt

@@ -74,6 +74,7 @@ internal class ChatSDKWrapper(
 
     private val options = ListChatMessagesOptions().apply { maxPageSize = PAGE_MESSAGES_SIZE }
     private var pagingContinuationToken: String? = null
+    private var adminUserId: String = ""
 
     @Volatile
     private var allPagesFetched: Boolean = false
@@ -90,24 +91,33 @@ internal class ChatSDKWrapper(
     override fun getChatEventSharedFlow(): SharedFlow<ChatEventModel> =
         chatEventModelSharedFlow
 
-    override fun initialization() {
-        chatStatusStateFlow.value = ChatStatus.INITIALIZATION
-        createChatClient()
-        createChatThreadClient()
-        // TODO: initialize polling or try to get first message here to make sure SDK can establish connection with thread
-        // TODO: above will make sure, network is connected as well
-        onChatEventReceived(
-            infoModel = ChatEventModel(
-                eventType = ChatEventType.CHAT_THREAD_PROPERTIES_UPDATED,
-                ChatThreadInfoModel(
-                    topic = threadClient.properties.topic,
-                    receivedOn = threadClient.properties.createdOn
-                ),
-                eventReceivedOffsetDateTime = null
+    override fun initialization(): CompletableFuture<Void> {
+        val future = CompletableFuture<Void>()
+        try {
+            chatStatusStateFlow.value = ChatStatus.INITIALIZATION
+            createChatClient()
+            createChatThreadClient()
+            // TODO: initialize polling or try to get first message here to make sure SDK can establish connection with thread
+            // TODO: above will make sure, network is connected as well
+            onChatEventReceived(
+                infoModel = ChatEventModel(
+                    eventType = ChatEventType.CHAT_THREAD_PROPERTIES_UPDATED,
+                    ChatThreadInfoModel(
+                        topic = threadClient.properties.topic,
+                        receivedOn = threadClient.properties.createdOn
+                    ),
+                    eventReceivedOffsetDateTime = null
+                )
             )
-        )
 
-        chatStatusStateFlow.value = ChatStatus.INITIALIZED
+            adminUserId = threadClient.properties.createdByCommunicationIdentifier.into().id
+            chatStatusStateFlow.value = ChatStatus.INITIALIZED
+            future.complete(null)
+        } catch (ex: Exception) {
+            future.completeExceptionally(ex)
+            logger.debug("sendMessage failed.", ex)
+        }
+        return future
     }
 
     override fun destroy() {
@@ -118,9 +128,8 @@ internal class ChatSDKWrapper(
         chatFetchNotificationHandler.stop()
     }
 
-    override fun getAdminUserId(): String? {
-        if (!this::threadClient.isInitialized) return null
-        return threadClient.properties.createdByCommunicationIdentifier.into().id
+    override fun getAdminUserId(): String {
+        return adminUserId
     }
 
     override fun requestPreviousPage() {