Make sure all client calls are guarded by try/catch

Use retryIO to retry client calls (still missing on some places)
Better error logging
NPE fixes.

app/src/main/java/chat/rocket/android/app/RocketChatApplication.kt

@@ -18,10 +18,11 @@ import chat.rocket.android.app.migration.model.RealmUser
 import chat.rocket.android.authentication.domain.model.toToken
 import chat.rocket.android.dagger.DaggerAppComponent
 import chat.rocket.android.helper.CrashlyticsTree
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.domain.model.Account
+import chat.rocket.android.util.extensions.avatarUrl
+import chat.rocket.android.util.extensions.serverLogoUrl
 import chat.rocket.android.widget.emoji.EmojiRepository
 import chat.rocket.common.model.Token
 import chat.rocket.core.model.Value
@@ -148,12 +149,12 @@ class RocketChatApplication : Application(), HasActivityInjector, HasServiceInje
 
     private fun migrateServerInfo(url: String, authToken: String, settings: PublicSettings, user: RealmUser) {
         val userId = user._id
-        val avatar = UrlHelper.getAvatarUrl(url, user.username!!)
+        val avatar = url.avatarUrl(user.username!!)
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(url, it)
+            url.serverLogoUrl(it)
         }
         val logo = settings.wideTile()?.let {
-            UrlHelper.getServerLogoUrl(url, it)
+            url.serverLogoUrl(it)
         }
         val account = Account(url, icon, logo, user.username!!, avatar)
         launch(CommonPool) {

app/src/main/java/chat/rocket/android/authentication/login/presentation/LoginPresenter.kt

 package chat.rocket.android.authentication.login.presentation
 
-import chat.rocket.android.BuildConfig
 import chat.rocket.android.authentication.presentation.AuthenticationNavigator
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.helper.NetworkHelper
 import chat.rocket.android.helper.OauthHelper
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.domain.model.Account
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
 import chat.rocket.android.server.presentation.CheckServerPresenter
-import chat.rocket.android.util.VersionInfo
 import chat.rocket.android.util.extensions.*
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.RocketChatTwoFactorException
 import chat.rocket.common.model.Token
 import chat.rocket.common.util.ifNull
 import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.*
-import chat.rocket.core.model.Myself
 import kotlinx.coroutines.experimental.delay
 import timber.log.Timber
 import java.util.concurrent.TimeUnit
@@ -103,7 +100,7 @@ class LoginPresenter @Inject constructor(private val view: LoginView,
     private fun setupCasView() {
         if (settings.isCasAuthenticationEnabled()) {
             val token = generateRandomString(17)
-            view.setupCasButtonListener(UrlHelper.getCasUrl(settings.casLoginUrl(), currentServer, token), token)
+            view.setupCasButtonListener(settings.casLoginUrl().casUrl(currentServer, token), token)
             view.showCasButton()
         }
     }
@@ -118,7 +115,9 @@ class LoginPresenter @Inject constructor(private val view: LoginView,
     private fun setupOauthServicesView() {
         launchUI(strategy) {
             try {
-                val services = client.settingsOauth().services
+                val services = retryIO("settingsOauth()") {
+                    client.settingsOauth().services
+                }
                 if (services.isNotEmpty()) {
                     val state = "{\"loginStyle\":\"popup\",\"credentialToken\":\"${generateRandomString(40)}\",\"isCordova\":true}".encodeToBase64()
                     var totalSocialAccountsEnabled = 0
@@ -195,30 +194,32 @@ class LoginPresenter @Inject constructor(private val view: LoginView,
                 view.disableUserInput()
                 view.showLoading()
                 try {
-                    val token = when (loginType) {
-                        TYPE_LOGIN_USER_EMAIL -> {
-                            if (usernameOrEmail.isEmail()) {
-                                client.loginWithEmail(usernameOrEmail, password)
-                            } else {
-                                if (settings.isLdapAuthenticationEnabled()) {
-                                    client.loginWithLdap(usernameOrEmail, password)
+                    val token = retryIO("login") {
+                        when (loginType) {
+                            TYPE_LOGIN_USER_EMAIL -> {
+                                if (usernameOrEmail.isEmail()) {
+                                    client.loginWithEmail(usernameOrEmail, password)
                                 } else {
-                                    client.login(usernameOrEmail, password)
+                                    if (settings.isLdapAuthenticationEnabled()) {
+                                        client.loginWithLdap(usernameOrEmail, password)
+                                    } else {
+                                        client.login(usernameOrEmail, password)
+                                    }
                                 }
                             }
-                        }
-                        TYPE_LOGIN_CAS -> {
-                            delay(3, TimeUnit.SECONDS)
-                            client.loginWithCas(credentialToken)
-                        }
-                        TYPE_LOGIN_OAUTH -> {
-                            client.loginWithOauth(credentialToken, credentialSecret)
-                        }
-                        else -> {
-                            throw IllegalStateException("Expected TYPE_LOGIN_USER_EMAIL, TYPE_LOGIN_CAS or TYPE_LOGIN_OAUTH")
+                            TYPE_LOGIN_CAS -> {
+                                delay(3, TimeUnit.SECONDS)
+                                client.loginWithCas(credentialToken)
+                            }
+                            TYPE_LOGIN_OAUTH -> {
+                                client.loginWithOauth(credentialToken, credentialSecret)
+                            }
+                            else -> {
+                                throw IllegalStateException("Expected TYPE_LOGIN_USER_EMAIL, TYPE_LOGIN_CAS or TYPE_LOGIN_OAUTH")
+                            }
                         }
                     }
-                    val username = client.me().username
+                    val username = retryIO("me()") { client.me().username }
                     if (username != null) {
                         localRepository.save(LocalRepository.CURRENT_USERNAME_KEY, username)
                         saveAccount(username)
@@ -258,12 +259,12 @@ class LoginPresenter @Inject constructor(private val view: LoginView,
 
     private suspend fun saveAccount(username: String) {
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
         val logo = settings.wideTile()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
-        val thumb = UrlHelper.getAvatarUrl(currentServer, username)
+        val thumb = currentServer.avatarUrl(username)
         val account = Account(currentServer, icon, logo, username, thumb)
         saveAccountInteractor.save(account)
     }

app/src/main/java/chat/rocket/android/authentication/registerusername/presentation/RegisterUsernamePresenter.kt

@@ -3,13 +3,15 @@ package chat.rocket.android.authentication.registerusername.presentation
 import chat.rocket.android.authentication.presentation.AuthenticationNavigator
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.helper.NetworkHelper
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.domain.model.Account
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.launchUI
 import chat.rocket.android.util.extensions.registerPushToken
+import chat.rocket.android.util.extensions.serverLogoUrl
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.model.Token
 import chat.rocket.common.util.ifNull
@@ -41,7 +43,9 @@ class RegisterUsernamePresenter @Inject constructor(
                 if (NetworkHelper.hasInternetAccess()) {
                     view.showLoading()
                     try {
-                        val me = client.updateOwnBasicInformation(username = username)
+                        val me = retryIO("updateOwnBasicInformation(username = $username)") {
+                            client.updateOwnBasicInformation(username = username)
+                        }
                         val registeredUsername = me.username
                         if (registeredUsername != null) {
                             saveAccount(registeredUsername)
@@ -75,12 +79,12 @@ class RegisterUsernamePresenter @Inject constructor(
 
     private suspend fun saveAccount(username: String) {
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
         val logo = settings.wideTile()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
-        val thumb = UrlHelper.getAvatarUrl(currentServer, username)
+        val thumb = currentServer.avatarUrl(username)
         val account = Account(currentServer, icon, logo, username, thumb)
         saveAccountInteractor.save(account)
     }

app/src/main/java/chat/rocket/android/authentication/server/presentation/ServerPresenter.kt

@@ -3,10 +3,10 @@ package chat.rocket.android.authentication.server.presentation
 import chat.rocket.android.authentication.presentation.AuthenticationNavigator
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.helper.NetworkHelper
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.server.domain.GetAccountsInteractor
 import chat.rocket.android.server.domain.RefreshSettingsInteractor
 import chat.rocket.android.server.domain.SaveCurrentServerInteractor
+import chat.rocket.android.util.extensions.isValidUrl
 import chat.rocket.android.util.extensions.launchUI
 import chat.rocket.common.util.ifNull
 import javax.inject.Inject
@@ -18,7 +18,7 @@ class ServerPresenter @Inject constructor(private val view: ServerView,
                                           private val refreshSettingsInteractor: RefreshSettingsInteractor,
                                           private val getAccountsInteractor: GetAccountsInteractor) {
     fun connect(server: String) {
-        if (!UrlHelper.isValidUrl(server)) {
+        if (!server.isValidUrl()) {
             view.showInvalidServerUrlMessage()
         } else {
             launchUI(strategy) {

app/src/main/java/chat/rocket/android/authentication/signup/presentation/SignupPresenter.kt

@@ -3,20 +3,22 @@ package chat.rocket.android.authentication.signup.presentation
 import chat.rocket.android.authentication.presentation.AuthenticationNavigator
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.helper.NetworkHelper
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
-import chat.rocket.android.main.viewmodel.NavHeaderViewModel
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.domain.model.Account
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.extensions.privacyPolicyUrl
 import chat.rocket.android.util.extensions.registerPushToken
+import chat.rocket.android.util.extensions.serverLogoUrl
+import chat.rocket.android.util.extensions.termsOfServiceUrl
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.util.ifNull
 import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.login
 import chat.rocket.core.internal.rest.me
-import chat.rocket.core.internal.rest.registerPushToken
 import chat.rocket.core.internal.rest.signup
 import chat.rocket.core.model.Myself
 import javax.inject.Inject
@@ -60,10 +62,10 @@ class SignupPresenter @Inject constructor(private val view: SignupView,
 
                         try {
                             // TODO This function returns a user so should we save it?
-                            client.signup(email, name, username, password)
+                            retryIO("signup") { client.signup(email, name, username, password) }
                             // TODO This function returns a user token so should we save it?
-                            client.login(username, password)
-                            val me = client.me()
+                            retryIO("login") { client.login(username, password) }
+                            val me = retryIO("me") { client.me() }
                             localRepository.save(LocalRepository.CURRENT_USERNAME_KEY, me.username)
                             saveAccount(me)
                             registerPushToken()
@@ -88,13 +90,13 @@ class SignupPresenter @Inject constructor(private val view: SignupView,
 
     fun termsOfService() {
         serverInteractor.get()?.let {
-            navigator.toWebPage(UrlHelper.getTermsOfServiceUrl(it))
+            navigator.toWebPage(it.termsOfServiceUrl())
         }
     }
 
     fun privacyPolicy() {
         serverInteractor.get()?.let {
-            navigator.toWebPage(UrlHelper.getPrivacyPolicyUrl(it))
+            navigator.toWebPage(it.privacyPolicyUrl())
         }
     }
 
@@ -108,12 +110,12 @@ class SignupPresenter @Inject constructor(private val view: SignupView,
 
     private suspend fun saveAccount(me: Myself) {
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
         val logo = settings.wideTile()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
-        val thumb = UrlHelper.getAvatarUrl(currentServer, me.username!!)
+        val thumb = currentServer.avatarUrl(me.username!!)
         val account = Account(currentServer, icon, logo, me.username!!, thumb)
         saveAccountInteractor.save(account)
     }

app/src/main/java/chat/rocket/android/authentication/twofactor/presentation/TwoFAPresenter.kt

@@ -3,13 +3,15 @@ package chat.rocket.android.authentication.twofactor.presentation
 import chat.rocket.android.authentication.presentation.AuthenticationNavigator
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.helper.NetworkHelper
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.domain.model.Account
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.launchUI
 import chat.rocket.android.util.extensions.registerPushToken
+import chat.rocket.android.util.extensions.serverLogoUrl
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatAuthException
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.util.ifNull
@@ -50,9 +52,10 @@ class TwoFAPresenter @Inject constructor(private val view: TwoFAView,
                         view.showLoading()
                         try {
                             // The token is saved via the client TokenProvider
-                            val token =
+                            val token = retryIO("login") {
                                 client.login(usernameOrEmail, password, twoFactorAuthenticationCode)
-                            val me = client.me()
+                            }
+                            val me = retryIO("me") { client.me() }
                             saveAccount(me)
                             tokenRepository.save(server, token)
                             registerPushToken()
@@ -90,12 +93,12 @@ class TwoFAPresenter @Inject constructor(private val view: TwoFAView,
 
     private suspend fun saveAccount(me: Myself) {
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
         val logo = settings.wideTile()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
-        val thumb = UrlHelper.getAvatarUrl(currentServer, me.username!!)
+        val thumb = currentServer.avatarUrl(me.username!!)
         val account = Account(currentServer, icon, logo, me.username!!, thumb)
         saveAccountInteractor.save(account)
     }

app/src/main/java/chat/rocket/android/chatroom/presentation/ChatRoomPresenter.kt

@@ -11,12 +11,13 @@ import chat.rocket.android.chatroom.viewmodel.suggestion.ChatRoomSuggestionViewM
 import chat.rocket.android.chatroom.viewmodel.suggestion.CommandSuggestionViewModel
 import chat.rocket.android.chatroom.viewmodel.suggestion.PeopleSuggestionViewModel
 import chat.rocket.android.core.lifecycle.CancelStrategy
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
 import chat.rocket.android.server.infraestructure.ConnectionManagerFactory
 import chat.rocket.android.server.infraestructure.state
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.model.RoomType
 import chat.rocket.common.model.UserStatus
@@ -26,6 +27,7 @@ import chat.rocket.core.internal.realtime.State
 import chat.rocket.core.internal.rest.*
 import chat.rocket.core.model.Command
 import chat.rocket.core.model.Message
+import chat.rocket.core.model.Myself
 import chat.rocket.core.model.Value
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.android.UI
@@ -40,7 +42,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                                             private val navigator: ChatRoomNavigator,
                                             private val strategy: CancelStrategy,
                                             getSettingsInteractor: GetSettingsInteractor,
-                                            private val serverInteractor: GetCurrentServerInteractor,
+                                            serverInteractor: GetCurrentServerInteractor,
                                             private val getChatRoomsInteractor: GetChatRoomsInteractor,
                                             private val permissions: GetPermissionsInteractor,
                                             private val uriInteractor: UriInteractor,
@@ -68,7 +70,9 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
             view.showLoading()
             try {
                 val messages =
-                        client.messages(chatRoomId, roomTypeOf(chatRoomType), offset, 30).result
+                        retryIO(description = "messages chatRoom: $chatRoomId, type: $chatRoomType, offset: $offset") {
+                            client.messages(chatRoomId, roomTypeOf(chatRoomType), offset, 30).result
+                        }
                 messagesRepository.saveAll(messages)
 
                 val messagesViewModels = mapper.map(messages)
@@ -101,13 +105,16 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
             view.disableSendMessageButton()
             try {
                 // ignore message for now, will receive it on the stream
-                val message = if (messageId == null) {
-                    client.sendMessage(chatRoomId, text)
-                } else {
-                    client.updateMessage(chatRoomId, messageId, text)
+                val message = retryIO {
+                    if (messageId == null) {
+                        client.sendMessage(chatRoomId, text)
+                    } else {
+                        client.updateMessage(chatRoomId, messageId, text)
+                    }
                 }
                 view.clearMessageComposition()
             } catch (ex: Exception) {
+                Timber.d(ex, "Error sending message...")
                 ex.message?.let {
                     view.showMessage(it)
                 }.ifNull {
@@ -137,8 +144,10 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                     fileSize > maxFileSize -> view.showInvalidFileSize(fileSize, maxFileSize)
                     else -> {
                         Timber.d("Uploading to $roomId: $fileName - $mimeType")
-                        client.uploadFile(roomId, fileName!!, mimeType, msg, description = fileName) {
-                            uriInteractor.getInputStream(uri)
+                        retryIO("uploadFile($roomId, $fileName, $mimeType") {
+                            client.uploadFile(roomId, fileName!!, mimeType, msg, description = fileName) {
+                                uriInteractor.getInputStream(uri)
+                            }
                         }
                     }
                 }
@@ -158,7 +167,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     private fun markRoomAsRead(roomId: String) {
         launchUI(strategy) {
             try {
-                client.markAsRead(roomId)
+                retryIO(description = "markAsRead($roomId)") { client.markAsRead(roomId) }
             } catch (ex: RocketChatException) {
                 view.showMessage(ex.message!!) // TODO Remove.
                 Timber.e(ex) // FIXME: Right now we are only catching the exception with Timber.
@@ -204,23 +213,32 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 val roomType = roomTypeOf(chatRoomType!!)
                 messagesRepository.getByRoomId(chatRoomId!!)
                         .sortedByDescending { it.timestamp }.firstOrNull()?.let { lastMessage ->
-                    val instant = Instant.ofEpochMilli(lastMessage.timestamp)
-                    val messages = client.history(chatRoomId!!, roomType, count = 50,
-                            oldest = instant.toString())
-                    Timber.d("History: $messages")
+                    val instant = Instant.ofEpochMilli(lastMessage.timestamp).toString()
+                    try {
+                        val messages = retryIO(description = "history($chatRoomId, $roomType, $instant)") {
+                            client.history(chatRoomId!!, roomType, count = 50,
+                                oldest = instant)
+                        }
+                        Timber.d("History: $messages")
 
-                    if (messages.result.isNotEmpty()) {
-                        val models = mapper.map(messages.result)
-                        messagesRepository.saveAll(messages.result)
+                        if (messages.result.isNotEmpty()) {
+                            val models = mapper.map(messages.result)
+                            messagesRepository.saveAll(messages.result)
 
-                        launchUI(strategy) {
-                            view.showNewMessage(models)
-                        }
+                            launchUI(strategy) {
+                                view.showNewMessage(models)
+                            }
 
-                        if (messages.result.size == 50) {
-                            // we loade at least count messages, try one more to fetch more messages
-                            loadMissingMessages()
+                            if (messages.result.size == 50) {
+                                // we loaded at least count messages, try one more to fetch more messages
+                                loadMissingMessages()
+                            }
                         }
+                    } catch (ex: Exception) {
+                        // TODO - we need to better treat connection problems here, but no let gaps
+                        // on the messages list
+                        Timber.d(ex, "Error fetching channel history")
+                        ex.printStackTrace()
                     }
                 }
             }
@@ -249,7 +267,9 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
             //TODO: Default delete message always to true. Until we have the permissions system
             //implemented, a user will only be able to delete his own messages.
             try {
-                client.deleteMessage(roomId, id, true)
+                retryIO(description = "deleteMessage($roomId, $id)") {
+                    client.deleteMessage(roomId, id, true)
+                }
                 // if Message_ShowDeletedStatus == true an update to that message will be dispatched.
                 // Otherwise we signalize that we just want the message removed.
                 if (!permissions.showDeletedStatus()) {
@@ -272,14 +292,19 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     fun citeMessage(roomType: String, roomName: String, messageId: String, mentionAuthor: Boolean) {
         launchUI(strategy) {
             val message = messagesRepository.getById(messageId)
-            val me = client.me() //TODO: Cache this and use an interactor
-            val serverUrl = serverInteractor.get()!!
+            val me: Myself? = try {
+                retryIO("me()") { client.me() } //TODO: Cache this and use an interactor
+            } catch (ex: Exception) {
+                Timber.d(ex, "Error getting myself info.")
+                ex.printStackTrace()
+                null
+            }
             message?.let { m ->
                 val id = m.id
                 val username = m.sender?.username
                 val user = "@" + if (settings.useRealName()) m.sender?.name
                         ?: m.sender?.username else m.sender?.username
-                val mention = if (mentionAuthor && me.username != username) user else ""
+                val mention = if (mentionAuthor && me?.username != username) user else ""
                 val type = roomTypeOf(roomType)
                 val room = when (type) {
                     is RoomType.Channel -> "channel"
@@ -290,7 +315,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 }
                 view.showReplyingAction(
                         username = user,
-                        replyMarkdown = "[ ]($serverUrl/$room/$roomName?msg=$id) $mention ",
+                        replyMarkdown = "[ ]($currentServer/$room/$roomName?msg=$id) $mention ",
                         quotedMessage = mapper.map(message).last().preview?.message ?: ""
                 )
             }
@@ -338,7 +363,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 return@launchUI
             }
             try {
-                client.pinMessage(messageId)
+                retryIO("pinMessage($messageId)") { client.pinMessage(messageId) }
             } catch (e: RocketChatException) {
                 Timber.e(e)
             }
@@ -352,7 +377,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 return@launchUI
             }
             try {
-                client.unpinMessage(messageId)
+                retryIO("unpinMessage($messageId)") { client.unpinMessage(messageId) }
             } catch (e: RocketChatException) {
                 Timber.e(e)
             }
@@ -362,7 +387,9 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     fun loadActiveMembers(chatRoomId: String, chatRoomType: String, offset: Long = 0, filterSelfOut: Boolean = false) {
         launchUI(strategy) {
             try {
-                val members = client.getMembers(chatRoomId, roomTypeOf(chatRoomType), offset, 50).result
+                val members = retryIO("getMembers($chatRoomId, $chatRoomType, $offset)") {
+                    client.getMembers(chatRoomId, roomTypeOf(chatRoomType), offset, 50).result
+                }
                 usersRepository.saveAll(members)
                 val self = localRepository.get(LocalRepository.CURRENT_USERNAME_KEY)
                 // Take at most the 100 most recent messages distinguished by user. Can return less.
@@ -373,7 +400,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                     val sender = it.sender!!
                     val username = sender.username ?: ""
                     val name = sender.name ?: ""
-                    val avatarUrl = UrlHelper.getAvatarUrl(currentServer, username)
+                    val avatarUrl = currentServer.avatarUrl(username)
                     val found = members.firstOrNull { member -> member.username == username }
                     val status = if (found != null) found.status else UserStatus.Offline()
                     val searchList = mutableListOf(username, name)
@@ -390,7 +417,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 activeUsers.addAll(others.map {
                     val username = it.username ?: ""
                     val name = it.name ?: ""
-                    val avatarUrl = UrlHelper.getAvatarUrl(currentServer, username)
+                    val avatarUrl = currentServer.avatarUrl(username)
                     val searchList = mutableListOf(username, name)
                     PeopleSuggestionViewModel(avatarUrl, username, username, name, it.status, true, searchList)
                 })
@@ -405,7 +432,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     fun spotlight(query: String, @AutoCompleteType type: Int, filterSelfOut: Boolean = false) {
         launchUI(strategy) {
             try {
-                val (users, rooms) = client.spotlight(query)
+                val (users, rooms) = retryIO("spotlight($query)") { client.spotlight(query) }
                 when (type) {
                     PEOPLE -> {
                         if (users.isNotEmpty()) {
@@ -417,7 +444,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                             val name = it.name ?: ""
                             val searchList = mutableListOf(username, name)
                             it.emails?.forEach { email -> searchList.add(email.address) }
-                            PeopleSuggestionViewModel(UrlHelper.getAvatarUrl(currentServer, username),
+                            PeopleSuggestionViewModel(currentServer.avatarUrl(username),
                                     username, username, name, it.status, false, searchList)
                         }.filterNot { filterSelfOut && self != null && self == it.text })
                     }
@@ -468,7 +495,7 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     fun joinChat(chatRoomId: String) {
         launchUI(strategy) {
             try {
-                client.joinChat(chatRoomId)
+                retryIO("joinChat($chatRoomId)") { client.joinChat(chatRoomId) }
                 view.onJoined()
             } catch (ex: RocketChatException) {
                 Timber.e(ex)
@@ -482,7 +509,9 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
     fun react(messageId: String, emoji: String) {
         launchUI(strategy) {
             try {
-                client.toggleReaction(messageId, emoji.removeSurrounding(":"))
+                retryIO("toogleEmoji($messageId, $emoji)") {
+                    client.toggleReaction(messageId, emoji.removeSurrounding(":"))
+                }
             } catch (ex: RocketChatException) {
                 Timber.e(ex)
             }
@@ -497,7 +526,9 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
         launchUI(strategy) {
             try {
                 //TODO: cache the commands
-                val commands = client.commands(0, 100).result
+                val commands = retryIO("commands(0, 100)") {
+                    client.commands(0, 100).result
+                }
                 view.populateCommandSuggestions(commands.map {
                     CommandSuggestionViewModel(it.command, it.description ?: "", listOf(it.command))
                 })
@@ -516,13 +547,15 @@ class ChatRoomPresenter @Inject constructor(private val view: ChatRoomView,
                 } else {
                     val command = text.split(" ")
                     val name = command[0].substring(1)
-                    var params: String = ""
+                    var params = ""
                     command.forEachIndexed { index, param ->
                         if (index > 0) {
                             params += "$param "
                         }
                     }
-                    val result = client.runCommand(Command(name, params), roomId)
+                    val result = retryIO("runCommand($name, $params, $roomId)") {
+                        client.runCommand(Command(name, params), roomId)
+                    }
                     if (!result) {
                         // failed, command is not valid so post it
                         sendMessage(roomId, text, null)

app/src/main/java/chat/rocket/android/chatroom/viewmodel/ViewModelMapper.kt

@@ -9,9 +9,9 @@ import android.text.style.ForegroundColorSpan
 import android.text.style.StyleSpan
 import chat.rocket.android.R
 import chat.rocket.android.helper.MessageParser
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.*
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.widget.emoji.EmojiParser
 import chat.rocket.core.model.Message
 import chat.rocket.core.model.MessageType
@@ -235,7 +235,7 @@ class ViewModelMapper @Inject constructor(private val context: Context,
 
         val username = message.sender?.username ?: "?"
         return baseUrl?.let {
-            UrlHelper.getAvatarUrl(baseUrl, username)
+            baseUrl.avatarUrl(username)
         }
     }
 

app/src/main/java/chat/rocket/android/chatrooms/presentation/ChatRoomsPresenter.kt

@@ -12,6 +12,7 @@ import chat.rocket.android.server.infraestructure.ConnectionManagerFactory
 import chat.rocket.android.server.infraestructure.chatRooms
 import chat.rocket.android.server.infraestructure.state
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.model.BaseRoom
 import chat.rocket.common.model.RoomType
@@ -94,7 +95,9 @@ class ChatRoomsPresenter @Inject constructor(private val view: ChatRoomsView,
             try {
                 val roomList = getChatRoomsInteractor.getByName(currentServer, name)
                 if (roomList.isEmpty()) {
-                    val (users, rooms) = client.spotlight(name)
+                    val (users, rooms) = retryIO("spotlight($name)") {
+                        client.spotlight(name)
+                    }
                     val chatRoomsCombined = mutableListOf<ChatRoom>()
                     chatRoomsCombined.addAll(usersToChatRooms(users))
                     chatRoomsCombined.addAll(roomsToChatRooms(rooms))
@@ -161,7 +164,7 @@ class ChatRoomsPresenter @Inject constructor(private val view: ChatRoomsView,
     }
 
     private suspend fun loadRooms(): List<ChatRoom> {
-        val chatRooms = manager.chatRooms().update
+        val chatRooms = retryIO("chatRooms") { manager.chatRooms().update }
         val sortedRooms = sortRooms(chatRooms)
         Timber.d("Loaded rooms: ${sortedRooms.size}")
         saveChatRoomsInteractor.save(currentServer, sortedRooms)

app/src/main/java/chat/rocket/android/chatrooms/ui/ChatRoomsAdapter.kt

@@ -12,11 +12,11 @@ import android.view.View
 import android.view.ViewGroup
 import android.widget.TextView
 import chat.rocket.android.R
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.infrastructure.checkIfMyself
 import chat.rocket.android.server.domain.PublicSettings
 import chat.rocket.android.server.domain.useRealName
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.content
 import chat.rocket.android.util.extensions.inflate
 import chat.rocket.android.util.extensions.setVisible
@@ -75,7 +75,7 @@ class ChatRoomsAdapter(private val context: Context,
 
         private fun bindAvatar(chatRoom: ChatRoom, drawee: SimpleDraweeView) {
             val avatarId = if (chatRoom.type is RoomType.DirectMessage) chatRoom.name else "@${chatRoom.name}"
-            drawee.setImageURI(UrlHelper.getAvatarUrl(chatRoom.client.url, avatarId))
+            drawee.setImageURI(chatRoom.client.url.avatarUrl(avatarId))
         }
 
         private fun bindName(chatRoom: ChatRoom, textView: TextView) {

app/src/main/java/chat/rocket/android/chatrooms/ui/ChatRoomsFragment.kt

@@ -158,15 +158,16 @@ class ChatRoomsFragment : Fragment(), ChatRoomsView {
             listJob?.cancel()
             listJob = launch(UI) {
                 val adapter = recycler_view.adapter as SimpleSectionedRecyclerViewAdapter
-                // FIXME https://fabric.io/rocketchat3/android/apps/chat.rocket.android.dev/issues/5a90d4718cb3c2fa63b3f557?time=last-seven-days
-                // TODO - fix this bug to reenable DiffUtil
-                val diff = async(CommonPool) {
+                // FIXME https://fabric.io/rocketchat3/android/apps/chat.rocket.android/issues/5ac2916c36c7b235275ccccf
+                // TODO - fix this bug to re-enable DiffUtil
+                /*val diff = async(CommonPool) {
                     DiffUtil.calculateDiff(RoomsDiffCallback(adapter.baseAdapter.dataSet, newDataSet))
-                }.await()
+                }.await()*/
 
                 if (isActive) {
                     adapter.baseAdapter.updateRooms(newDataSet)
-                    diff.dispatchUpdatesTo(adapter)
+                    // TODO - fix crash to re-enable diff.dispatchUpdatesTo(adapter)
+                    adapter.notifyDataSetChanged()
 
                     //Set sections always after data set is updated
                     setSections()

app/src/main/java/chat/rocket/android/helper/OauthHelper.kt

 package chat.rocket.android.helper
 
+import chat.rocket.android.util.extensions.removeTrailingSlash
+
 object OauthHelper {
 
     /**
@@ -27,7 +29,7 @@ object OauthHelper {
     fun getGoogleOauthUrl(clientId: String, serverUrl: String, state: String): String {
         return "https://accounts.google.com/o/oauth2/v2/auth" +
                 "?client_id=$clientId" +
-                "&redirect_uri=${UrlHelper.removeTrailingSlash(serverUrl)}/_oauth/google?close" +
+                "&redirect_uri=${serverUrl.removeTrailingSlash()}/_oauth/google?close" +
                 "&state=$state" +
                 "&response_type=code" +
                 "&scope=email%20profile"
@@ -44,7 +46,7 @@ object OauthHelper {
     fun getLinkedinOauthUrl(clientId: String, serverUrl: String, state: String): String {
         return "https://linkedin.com/oauth/v2/authorization" +
                 "?client_id=$clientId" +
-                "&redirect_uri=${UrlHelper.removeTrailingSlash(serverUrl)}/_oauth/linkedin?close" +
+                "&redirect_uri=${serverUrl.removeTrailingSlash()}/_oauth/linkedin?close" +
                 "&state=$state" +
                 "&response_type=code"
     }
@@ -60,7 +62,7 @@ object OauthHelper {
     fun getGitlabOauthUrl(clientId: String, serverUrl: String, state: String): String {
         return  "https://gitlab.com/oauth/authorize" +
                 "?client_id=$clientId" +
-                "&redirect_uri=${UrlHelper.removeTrailingSlash(serverUrl)}/_oauth/gitlab?close" +
+                "&redirect_uri=${serverUrl.removeTrailingSlash()}/_oauth/gitlab?close" +
                 "&state=$state" +
                 "&response_type=code" +
                 "&scope=read_user"

app/src/main/java/chat/rocket/android/helper/UrlHelper.kt

-package chat.rocket.android.helper
-
-import android.util.Patterns
-
-object UrlHelper {
-
-    /**
-     * Returns the avatar URL.
-     *
-     * @param serverUrl The server URL.
-     * @param avatarName The avatar name.
-     * @return The avatar URL.
-     */
-    fun getAvatarUrl(serverUrl: String, avatarName: String, format: String = "jpeg"): String =
-        removeTrailingSlash(serverUrl) + "/avatar/" + removeTrailingSlash(avatarName) + "?format=$format"
-
-    /**
-     * Returns the server logo URL.
-     *
-     * @param serverUrl The server URL.
-     * @param favicon The faviconLarge from the server settings.
-     * @return The server logo URL.
-     */
-    fun getServerLogoUrl(serverUrl: String, favicon: String): String =
-        removeTrailingSlash(serverUrl) + "/$favicon"
-
-    /**
-     * Returns the CAS URL.
-     *
-     * @param casLoginUrl The CAS login URL from the server settings.
-     * @param serverUrl The server URL.
-     * @param token The token to be send to the CAS server.
-     * @return The avatar URL.
-     */
-    fun getCasUrl(casLoginUrl: String, serverUrl: String, token: String): String =
-        removeTrailingSlash(casLoginUrl) + "?service=" + removeTrailingSlash(serverUrl) + "/_cas/" + token
-
-    /**
-     * Returns the server's Terms of Service URL.
-     *
-     * @param serverUrl The server URL.
-     * @return The server's Terms of Service URL.
-     */
-    fun getTermsOfServiceUrl(serverUrl: String) = removeTrailingSlash(serverUrl) + "/terms-of-service"
-
-    /**
-     * Returns the server's Privacy Policy URL.
-     *
-     * @param serverUrl The server URL.
-     * @return The server's Privacy Policy URL.
-     */
-    fun getPrivacyPolicyUrl(serverUrl: String) = removeTrailingSlash(serverUrl) + "/privacy-policy"
-
-    /**
-     * Returns an URL without trailing slash.
-     *
-     * @param serverUrl The URL to remove the trailing slash (if exists).
-     * @return An URL without trailing slash.
-     */
-    fun removeTrailingSlash(serverUrl: String): String {
-        return if (serverUrl[serverUrl.length - 1] == '/') {
-            serverUrl.replace("/+$", "")
-        } else {
-            serverUrl
-        }
-    }
-
-    /**
-     * Checks if the given URL is valid or not.
-     * @param url The url to check its valid.
-     * @return True if url is valid, false otherwise.
-     */
-    fun isValidUrl(url: String): Boolean = Patterns.WEB_URL.matcher(url).matches()
-}
\ No newline at end of file

app/src/main/java/chat/rocket/android/main/presentation/MainPresenter.kt

 package chat.rocket.android.main.presentation
 
 import chat.rocket.android.core.lifecycle.CancelStrategy
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.main.viewmodel.NavHeaderViewModel
 import chat.rocket.android.main.viewmodel.NavHeaderViewModelMapper
@@ -12,6 +11,8 @@ import chat.rocket.android.server.infraestructure.RocketChatClientFactory
 import chat.rocket.android.server.presentation.CheckServerPresenter
 import chat.rocket.android.util.extensions.launchUI
 import chat.rocket.android.util.extensions.registerPushToken
+import chat.rocket.android.util.extensions.serverLogoUrl
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatAuthException
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.util.ifNull
@@ -52,7 +53,7 @@ class MainPresenter @Inject constructor(
         checkServerInfo()
         launchUI(strategy) {
             try {
-                val me = client.me()
+                val me = retryIO("me") { client.me() }
                 val model = navHeaderMapper.mapToViewModel(me)
 
                 saveAccount(model)
@@ -77,7 +78,7 @@ class MainPresenter @Inject constructor(
 
     private suspend fun saveAccount(me: NavHeaderViewModel) {
         val icon = settings.favicon()?.let {
-            UrlHelper.getServerLogoUrl(currentServer, it)
+            currentServer.serverLogoUrl(it)
         }
         val account = Account(currentServer, icon, me.serverLogo, me.username, me.avatar)
         saveAccountInteractor.save(account)
@@ -90,7 +91,7 @@ class MainPresenter @Inject constructor(
         launchUI(strategy) {
             try {
                 clearTokens()
-                client.logout()
+                retryIO("logout") { client.logout() }
             } catch (exception: RocketChatException) {
                 Timber.d(exception, "Error calling logout")
                 exception.message?.let {
@@ -117,7 +118,11 @@ class MainPresenter @Inject constructor(
         serverInteractor.clear()
         val pushToken = localRepository.get(LocalRepository.KEY_PUSH_TOKEN)
         if (pushToken != null) {
-            client.unregisterPushToken(pushToken)
+            try {
+                retryIO("unregisterPushToken") { client.unregisterPushToken(pushToken) }
+            } catch (ex: Exception) {
+                Timber.d(ex, "Error unregistering push token")
+            }
         }
         localRepository.clearAllFromServer(currentServer)
     }

app/src/main/java/chat/rocket/android/main/viewmodel/NavHeaderViewModelMapper.kt

 package chat.rocket.android.main.viewmodel
 
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.server.domain.*
+import chat.rocket.android.util.extensions.avatarUrl
+import chat.rocket.android.util.extensions.serverLogoUrl
 import chat.rocket.core.model.Myself
 import javax.inject.Inject
 
@@ -12,9 +13,9 @@ class NavHeaderViewModelMapper @Inject constructor(serverInteractor: GetCurrentS
 
     fun mapToViewModel(me: Myself): NavHeaderViewModel {
         val username = mapUsername(me)
-        val thumb = me.username?.let { UrlHelper.getAvatarUrl(currentServer, it) }
+        val thumb = me.username?.let { currentServer.avatarUrl(it) }
         val image = settings.wideTile() ?: settings.faviconLarge()
-        val logo = image?.let { UrlHelper.getServerLogoUrl(currentServer, it) }
+        val logo = image?.let { currentServer.serverLogoUrl(it) }
 
         return NavHeaderViewModel(username, currentServer, thumb, logo)
     }

app/src/main/java/chat/rocket/android/members/presentation/MembersPresenter.kt

@@ -6,6 +6,7 @@ import chat.rocket.android.members.viewmodel.MemberViewModelMapper
 import chat.rocket.android.server.domain.GetCurrentServerInteractor
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.model.roomTypeOf
 import chat.rocket.common.util.ifNull
@@ -26,7 +27,9 @@ class MembersPresenter @Inject constructor(private val view: MembersView,
             try {
                 view.showLoading()
 
-                val members = client.getMembers(chatRoomId, roomTypeOf(chatRoomType), offset, 60)
+                val members = retryIO("getMembers($chatRoomId, $chatRoomType, $offset)") {
+                    client.getMembers(chatRoomId, roomTypeOf(chatRoomType), offset, 60)
+                }
                 val memberViewModels = mapper.mapToViewModelList(members.result)
                 view.showMembers(memberViewModels, members.total)
             } catch (ex: RocketChatException) {

app/src/main/java/chat/rocket/android/members/viewmodel/MemberViewModel.kt

 package chat.rocket.android.members.viewmodel
 
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.server.domain.useRealName
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.common.model.User
 import chat.rocket.core.model.Value
 
@@ -25,7 +25,7 @@ class MemberViewModel(private val member: User, private val settings: Map<String
     private fun getUserAvatar(): String? {
         val username = member.username ?: "?"
         return baseUrl?.let {
-            UrlHelper.getAvatarUrl(baseUrl, username, "png")
+            baseUrl.avatarUrl(username,"png")
         }
     }
 

app/src/main/java/chat/rocket/android/profile/presentation/ProfilePresenter.kt

 package chat.rocket.android.profile.presentation
 
 import chat.rocket.android.core.lifecycle.CancelStrategy
-import chat.rocket.android.helper.UrlHelper
 import chat.rocket.android.server.domain.GetCurrentServerInteractor
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
+import chat.rocket.android.util.extensions.avatarUrl
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.common.util.ifNull
 import chat.rocket.core.RocketChatClient
@@ -25,9 +26,9 @@ class ProfilePresenter @Inject constructor(private val view: ProfileView,
         launchUI(strategy) {
             view.showLoading()
             try {
-                val myself = client.me()
+                val myself = retryIO("me") { client.me() }
                 myselfId = myself.id
-                val avatarUrl = UrlHelper.getAvatarUrl(serverUrl, myself.username!!)
+                val avatarUrl = serverUrl.avatarUrl(myself.username!!)
                 view.showProfile(
                         avatarUrl,
                         myself.name ?: "",
@@ -51,9 +52,9 @@ class ProfilePresenter @Inject constructor(private val view: ProfileView,
             view.showLoading()
             try {
                 if(avatarUrl!="") {
-                    client.setAvatar(avatarUrl)
+                    retryIO { client.setAvatar(avatarUrl) }
                 }
-                val user = client.updateProfile(myselfId, email, name, username)
+                val user = retryIO { client.updateProfile(myselfId, email, name, username) }
                 view.showProfileUpdateSuccessfullyMessage()
                 loadUserProfile()
             } catch (exception: RocketChatException) {

app/src/main/java/chat/rocket/android/push/FirebaseTokenService.kt

@@ -5,7 +5,6 @@ import chat.rocket.android.infrastructure.LocalRepository
 import chat.rocket.android.server.domain.GetCurrentServerInteractor
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
 import chat.rocket.common.RocketChatException
-import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.registerPushToken
 import com.google.android.gms.gcm.GoogleCloudMessaging
 import com.google.android.gms.iid.InstanceID

app/src/main/java/chat/rocket/android/server/presentation/CheckServerPresenter.kt

@@ -5,6 +5,7 @@ import chat.rocket.android.authentication.server.presentation.VersionCheckView
 import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.util.VersionInfo
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.serverInfo
 import timber.log.Timber
@@ -14,21 +15,25 @@ abstract class CheckServerPresenter constructor(private val strategy: CancelStra
                                                 private val view: VersionCheckView) {
     internal fun checkServerInfo() {
         launchUI(strategy) {
-            val serverInfo = client.serverInfo()
-            val thisServerVersion = serverInfo.version
-            val isRequiredVersion = isRequiredServerVersion(thisServerVersion)
-            val isRecommendedVersion = isRecommendedServerVersion(thisServerVersion)
-            if (isRequiredVersion) {
-                if (isRecommendedVersion) {
-                    Timber.i("Your version is nice! (Requires: 0.62.0, Yours: $thisServerVersion)")
+            try {
+                val serverInfo = retryIO(description = "serverInfo", times = 5) { client.serverInfo() }
+                val thisServerVersion = serverInfo.version
+                val isRequiredVersion = isRequiredServerVersion(thisServerVersion)
+                val isRecommendedVersion = isRecommendedServerVersion(thisServerVersion)
+                if (isRequiredVersion) {
+                    if (isRecommendedVersion) {
+                        Timber.i("Your version is nice! (Requires: 0.62.0, Yours: $thisServerVersion)")
+                    } else {
+                        view.alertNotRecommendedVersion()
+                    }
                 } else {
-                    view.alertNotRecommendedVersion()
-                }
-            } else {
-                if (!isRecommendedVersion) {
-                    view.blockAndAlertNotRequiredVersion()
-                    Timber.i("Oops. Looks like your server is out-of-date! Minimum server version required ${BuildConfig.REQUIRED_SERVER_VERSION}!")
+                    if (!isRecommendedVersion) {
+                        view.blockAndAlertNotRequiredVersion()
+                        Timber.i("Oops. Looks like your server is out-of-date! Minimum server version required ${BuildConfig.REQUIRED_SERVER_VERSION}!")
+                    }
                 }
+            } catch (ex: Exception) {
+                Timber.d(ex, "Error getting server info")
             }
         }
     }

app/src/main/java/chat/rocket/android/settings/password/presentation/PasswordPresenter.kt

@@ -4,6 +4,7 @@ import chat.rocket.android.core.lifecycle.CancelStrategy
 import chat.rocket.android.server.domain.GetCurrentServerInteractor
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
 import chat.rocket.android.util.extensions.launchUI
+import chat.rocket.android.util.retryIO
 import chat.rocket.common.RocketChatException
 import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.me
@@ -22,7 +23,10 @@ class PasswordPresenter @Inject constructor (private val view: PasswordView,
             try {
                 view.showLoading()
 
-                client.updateProfile(client.me().id, null, null, password, null)
+                val me = retryIO("me") { client.me() }
+                retryIO("updateProfile(${me.id})") {
+                    client.updateProfile(me.id, null, null, password, null)
+                }
 
                 view.showPasswordSuccessfullyUpdatedMessage()
                 view.hideLoading()

app/src/main/java/chat/rocket/android/util/extensions/RocketChatClient.kt

@@ -2,6 +2,7 @@ package chat.rocket.android.util.extensions
 
 import chat.rocket.android.server.domain.model.Account
 import chat.rocket.android.server.infraestructure.RocketChatClientFactory
+import chat.rocket.android.util.retryIO
 import chat.rocket.core.RocketChatClient
 import chat.rocket.core.internal.rest.registerPushToken
 import kotlinx.coroutines.experimental.CommonPool
@@ -16,7 +17,9 @@ suspend fun RocketChatClient.registerPushToken(
     launch(CommonPool) {
         accounts.forEach { account ->
             try {
-                factory.create(account.serverUrl).registerPushToken(token)
+                retryIO(description = "register push token: ${account.serverUrl}") {
+                    factory.create(account.serverUrl).registerPushToken(token)
+                }
             } catch (ex: Exception) {
                 Timber.d(ex, "Error registering Push token for ${account.serverUrl}")
                 ex.printStackTrace()

app/src/main/java/chat/rocket/android/util/extensions/Uri.kt

@@ -29,14 +29,14 @@ fun Uri.getFileName(context: Context): String? {
 fun Uri.getFileSize(context: Context): Int {
     val cursor = context.contentResolver.query(this, null, null, null, null, null)
 
-    var fileSize: String? = null
-    cursor.use { cursor ->
+    val fileSize = cursor?.use {
         val sizeIndex = cursor.getColumnIndex(OpenableColumns.SIZE)
-        if (cursor != null && cursor.moveToFirst()) {
+        if (cursor.moveToFirst()) {
             if (!cursor.isNull(sizeIndex)) {
-                fileSize = cursor.getString(sizeIndex)
+                return@use cursor.getString(sizeIndex)
             }
         }
+        return@use null
     }
     return fileSize?.toIntOrNull() ?: -1
 }