diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/api/session/crypto/MXCryptoError.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/api/session/crypto/MXCryptoError.kt index c4ffd8bdb8..0b14fecf0a 100644 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/api/session/crypto/MXCryptoError.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/api/session/crypto/MXCryptoError.kt @@ -81,6 +81,7 @@ class MXCryptoError(var code: String, /** * Error codes */ + const val UNKNOWN_ERROR_CODE = "UNKNOWN_ERROR_CODE" const val ENCRYPTING_NOT_ENABLED_ERROR_CODE = "ENCRYPTING_NOT_ENABLED" const val UNABLE_TO_ENCRYPT_ERROR_CODE = "UNABLE_TO_ENCRYPT" const val UNABLE_TO_DECRYPT_ERROR_CODE = "UNABLE_TO_DECRYPT" diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/CryptoManager.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/CryptoManager.kt index 70ef17f410..154bfbc96b 100755 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/CryptoManager.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/CryptoManager.kt @@ -388,12 +388,12 @@ internal class CryptoManager @Inject constructor( var isUpdated = false val deviceIds = devicesIdListByUserId[userId] - for (deviceId in deviceIds!!) { + deviceIds?.forEach { deviceId -> val device = storedDeviceIDs[deviceId] // assume if the device is either verified or blocked // it means that the device is known - if (null != device && device.isUnknown) { + if (device?.isUnknown == true) { device.verified = MXDeviceInfo.DEVICE_VERIFICATION_UNVERIFIED isUpdated = true } @@ -445,7 +445,7 @@ internal class CryptoManager @Inject constructor( val encryptingClass = MXCryptoAlgorithms.hasEncryptorClassForAlgorithm(algorithm) if (!encryptingClass) { - Timber.e("## setEncryptionInRoom() : Unable to encrypt with " + algorithm!!) + Timber.e("## setEncryptionInRoom() : Unable to encrypt room ${roomId} with $algorithm") return false } @@ -560,7 +560,7 @@ internal class CryptoManager @Inject constructor( .fold( { callback.onFailure(it) }, { - Timber.v("## encryptEventContent() : succeeds after " + (System.currentTimeMillis() - t0) + " ms") + Timber.v("## encryptEventContent() : succeeds after ${System.currentTimeMillis() - t0} ms") callback.onSuccess(MXEncryptEventContentResult(it, EventType.ENCRYPTED)) } ) @@ -615,16 +615,17 @@ internal class CryptoManager @Inject constructor( * @param timeline the id of the timeline where the event is decrypted. It is used to prevent replay attack. * @return the MXEventDecryptionResult data, or null in case of error wrapped into [Try] */ - private suspend fun internalDecryptEvent(event: Event, timeline: String): Try { + private suspend fun internalDecryptEvent(event: Event, timeline: String): Try { return Try { val eventContent = event.content if (eventContent == null) { Timber.e("## decryptEvent : empty event content") - return@Try null + throw MXDecryptionException(MXCryptoError(MXCryptoError.UNKNOWN_ERROR_CODE, MXCryptoError.UNKNOWN_ERROR_CODE)) } - val alg = roomDecryptorProvider.getOrCreateRoomDecryptor(event.roomId, eventContent["algorithm"] as String) + val algorithm = eventContent["algorithm"]?.toString() + val alg = roomDecryptorProvider.getOrCreateRoomDecryptor(event.roomId, algorithm) if (alg == null) { - val reason = String.format(MXCryptoError.UNABLE_TO_DECRYPT_REASON, event.eventId, eventContent["algorithm"] as String) + val reason = String.format(MXCryptoError.UNABLE_TO_DECRYPT_REASON, event.eventId, algorithm) Timber.e("## decryptEvent() : $reason") throw MXDecryptionException(MXCryptoError(MXCryptoError.UNABLE_TO_DECRYPT_ERROR_CODE, MXCryptoError.UNABLE_TO_DECRYPT, reason)) } else { @@ -676,7 +677,7 @@ internal class CryptoManager @Inject constructor( } val alg = roomDecryptorProvider.getOrCreateRoomDecryptor(roomKeyContent.roomId, roomKeyContent.algorithm) if (alg == null) { - Timber.e("## onRoomKeyEvent() : Unable to handle keys for " + roomKeyContent.algorithm) + Timber.e("## onRoomKeyEvent() : Unable to handle keys for ${roomKeyContent.algorithm}") return } alg.onRoomKeyEvent(event, keysBackup) @@ -692,9 +693,9 @@ internal class CryptoManager @Inject constructor( val params = LoadRoomMembersTask.Params(roomId) loadRoomMembersTask .execute(params) - .map { allLoaded -> + .map { _ -> val userIds = getRoomUserIds(roomId) - setEncryptionInRoom(roomId, event.content!!["algorithm"] as String, true, userIds) + setEncryptionInRoom(roomId, event.content?.get("algorithm")?.toString(), true, userIds) } } } @@ -839,7 +840,7 @@ internal class CryptoManager @Inject constructor( val roomKeys = MXMegolmExportEncryption.decryptMegolmKeyFile(roomKeysAsArray, password) val t1 = System.currentTimeMillis() - Timber.v("## importRoomKeys : decryptMegolmKeyFile done in " + (t1 - t0) + " ms") + Timber.v("## importRoomKeys : decryptMegolmKeyFile done in ${t1 - t0} ms") val importedSessions = MoshiProvider.providesMoshi() .adapter>(Types.newParameterizedType(List::class.java, MegolmSessionData::class.java)) @@ -847,7 +848,7 @@ internal class CryptoManager @Inject constructor( val t2 = System.currentTimeMillis() - Timber.v("## importRoomKeys : JSON parsing " + (t2 - t1) + " ms") + Timber.v("## importRoomKeys : JSON parsing ${t2 - t1} ms") if (importedSessions == null) { throw Exception("Error") @@ -931,11 +932,8 @@ internal class CryptoManager @Inject constructor( */ // TODO add this info in CryptoRoomEntity? override fun isRoomBlacklistUnverifiedDevices(roomId: String?): Boolean { - return if (null != roomId) { - cryptoStore.getRoomsListBlacklistUnverifiedDevices().contains(roomId) - } else { - false - } + return roomId?.let { cryptoStore.getRoomsListBlacklistUnverifiedDevices().contains(it) } + ?: false } /** @@ -993,18 +991,18 @@ internal class CryptoManager @Inject constructor( * @param event the event to decrypt again. */ override fun reRequestRoomKeyForEvent(event: Event) { - val wireContent = event.content!! - - val algorithm = wireContent["algorithm"].toString() - val senderKey = wireContent["sender_key"].toString() - val sessionId = wireContent["session_id"].toString() + val wireContent = event.content + if (wireContent == null) { + Timber.e("## reRequestRoomKeyForEvent Failed to re-request key, null content") + return + } val requestBody = RoomKeyRequestBody() requestBody.roomId = event.roomId - requestBody.algorithm = algorithm - requestBody.senderKey = senderKey - requestBody.sessionId = sessionId + requestBody.algorithm = wireContent["algorithm"]?.toString() + requestBody.senderKey = wireContent["sender_key"]?.toString() + requestBody.sessionId = wireContent["session_id"]?.toString() outgoingRoomKeyRequestManager.resendRoomKeyRequest(requestBody) } @@ -1038,12 +1036,12 @@ internal class CryptoManager @Inject constructor( val userIds = devicesInRoom.userIds for (userId in userIds) { val deviceIds = devicesInRoom.getUserDeviceIds(userId) - for (deviceId in deviceIds!!) { - val deviceInfo = devicesInRoom.getObject(userId, deviceId) - - if (deviceInfo?.isUnknown == true) { - unknownDevices.setObject(userId, deviceId, deviceInfo) - } + deviceIds?.forEach { deviceId -> + devicesInRoom.getObject(userId, deviceId) + ?.takeIf { it.isUnknown } + ?.let { + unknownDevices.setObject(userId, deviceId, it) + } } } diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/MXOlmDevice.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/MXOlmDevice.kt index 243ddea66e..39cbd5e071 100755 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/MXOlmDevice.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/MXOlmDevice.kt @@ -29,12 +29,7 @@ import im.vector.matrix.android.internal.di.MoshiProvider import im.vector.matrix.android.internal.session.SessionScope import im.vector.matrix.android.internal.util.convertFromUTF8 import im.vector.matrix.android.internal.util.convertToUTF8 -import org.matrix.olm.OlmAccount -import org.matrix.olm.OlmInboundGroupSession -import org.matrix.olm.OlmMessage -import org.matrix.olm.OlmOutboundGroupSession -import org.matrix.olm.OlmSession -import org.matrix.olm.OlmUtility +import org.matrix.olm.* import timber.log.Timber import java.net.URLEncoder import java.util.* @@ -119,13 +114,13 @@ internal class MXOlmDevice @Inject constructor( try { deviceCurve25519Key = olmAccount!!.identityKeys()[OlmAccount.JSON_KEY_IDENTITY_KEY] } catch (e: Exception) { - Timber.e(e, "## MXOlmDevice : cannot find " + OlmAccount.JSON_KEY_IDENTITY_KEY + " with error") + Timber.e(e, "## MXOlmDevice : cannot find ${OlmAccount.JSON_KEY_IDENTITY_KEY} with error") } try { deviceEd25519Key = olmAccount!!.identityKeys()[OlmAccount.JSON_KEY_FINGER_PRINT_KEY] } catch (e: Exception) { - Timber.e(e, "## MXOlmDevice : cannot find " + OlmAccount.JSON_KEY_FINGER_PRINT_KEY + " with error") + Timber.e(e, "## MXOlmDevice : cannot find ${OlmAccount.JSON_KEY_FINGER_PRINT_KEY} with error") } } @@ -297,13 +292,13 @@ internal class MXOlmDevice @Inject constructor( val res = HashMap() - if (!TextUtils.isEmpty(payloadString)) { - res["payload"] = payloadString!! + if (!payloadString.isNullOrEmpty()) { + res["payload"] = payloadString } val sessionIdentifier = olmSession.sessionIdentifier() - if (!TextUtils.isEmpty(sessionIdentifier)) { + if (!sessionIdentifier.isNullOrEmpty()) { res["session_id"] = sessionIdentifier } @@ -525,9 +520,7 @@ internal class MXOlmDevice @Inject constructor( //If our existing session is better we keep it if (newKnownFirstIndex != null && existingFirstKnown <= newKnownFirstIndex) { - if (session.olmInboundGroupSession != null) { - session.olmInboundGroupSession!!.releaseSession() - } + session.olmInboundGroupSession?.releaseSession() return false } } @@ -545,7 +538,7 @@ internal class MXOlmDevice @Inject constructor( return false } } catch (e: Exception) { - session.olmInboundGroupSession!!.releaseSession() + session.olmInboundGroupSession?.releaseSession() Timber.e(e, "## addInboundGroupSession : sessionIdentifier() failed") return false } @@ -584,13 +577,13 @@ internal class MXOlmDevice @Inject constructor( } // sanity check - if (null == session || null == session.olmInboundGroupSession) { + if (session?.olmInboundGroupSession == null) { Timber.e("## importInboundGroupSession : invalid session") continue } try { - if (!TextUtils.equals(session.olmInboundGroupSession!!.sessionIdentifier(), sessionId)) { + if (!TextUtils.equals(session.olmInboundGroupSession?.sessionIdentifier(), sessionId)) { Timber.e("## importInboundGroupSession : ERROR: Mismatched group session ID from senderKey: " + senderKey!!) if (session.olmInboundGroupSession != null) session.olmInboundGroupSession!!.releaseSession() continue @@ -678,7 +671,7 @@ internal class MXOlmDevice @Inject constructor( val reason = String.format(MXCryptoError.DUPLICATE_MESSAGE_INDEX_REASON, decryptResult.mIndex) Timber.e("## decryptGroupMessage() : $reason") throw MXDecryptionException(MXCryptoError(MXCryptoError.DUPLICATED_MESSAGE_INDEX_ERROR_CODE, - MXCryptoError.UNABLE_TO_DECRYPT, reason)) + MXCryptoError.UNABLE_TO_DECRYPT, reason)) } inboundGroupSessionMessageIndexes[timeline]!!.put(messageIndexKey, true) @@ -711,7 +704,7 @@ internal class MXOlmDevice @Inject constructor( val reason = String.format(MXCryptoError.INBOUND_SESSION_MISMATCH_ROOM_ID_REASON, roomId, session.roomId) Timber.e("## decryptGroupMessage() : $reason") throw MXDecryptionException(MXCryptoError(MXCryptoError.INBOUND_SESSION_MISMATCH_ROOM_ID_ERROR_CODE, - MXCryptoError.UNABLE_TO_DECRYPT, reason)) + MXCryptoError.UNABLE_TO_DECRYPT, reason)) } } else { Timber.e("## decryptGroupMessage() : Cannot retrieve inbound group session $sessionId") @@ -767,9 +760,9 @@ internal class MXOlmDevice @Inject constructor( */ private fun getSessionForDevice(theirDeviceIdentityKey: String, sessionId: String): OlmSessionWrapper? { // sanity check - return if (!TextUtils.isEmpty(theirDeviceIdentityKey) && !TextUtils.isEmpty(sessionId)) { + return if (theirDeviceIdentityKey.isEmpty() || sessionId.isEmpty()) null else { store.getDeviceSession(sessionId, theirDeviceIdentityKey) - } else null + } } @@ -785,7 +778,8 @@ internal class MXOlmDevice @Inject constructor( fun getInboundGroupSession(sessionId: String?, senderKey: String?, roomId: String?): OlmInboundGroupSessionWrapper? { inboundGroupSessionWithIdError = null - val session = store.getInboundGroupSession(sessionId!!, senderKey!!) + if (sessionId.isNullOrBlank() || senderKey.isNullOrBlank()) return null + val session = store.getInboundGroupSession(sessionId, senderKey) if (null != session) { // Check that the room id matches the original one for the session. This stops @@ -794,12 +788,12 @@ internal class MXOlmDevice @Inject constructor( val errorDescription = String.format(MXCryptoError.INBOUND_SESSION_MISMATCH_ROOM_ID_REASON, roomId, session.roomId) Timber.e("## getInboundGroupSession() : $errorDescription") inboundGroupSessionWithIdError = MXCryptoError(MXCryptoError.INBOUND_SESSION_MISMATCH_ROOM_ID_ERROR_CODE, - MXCryptoError.UNABLE_TO_DECRYPT, errorDescription) + MXCryptoError.UNABLE_TO_DECRYPT, errorDescription) } } else { Timber.e("## getInboundGroupSession() : Cannot retrieve inbound group session $sessionId") inboundGroupSessionWithIdError = MXCryptoError(MXCryptoError.UNKNOWN_INBOUND_SESSION_ID_ERROR_CODE, - MXCryptoError.UNKNOWN_INBOUND_SESSION_ID_REASON, null) + MXCryptoError.UNKNOWN_INBOUND_SESSION_ID_REASON, null) } return session } diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/ObjectSigner.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/ObjectSigner.kt index 8ca33ea4a9..7b8e01994c 100644 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/ObjectSigner.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/ObjectSigner.kt @@ -44,7 +44,9 @@ internal class ObjectSigner @Inject constructor(private val credentials: Credent val content = HashMap() - content["ed25519:" + credentials.deviceId] = olmDevice.signMessage(strToSign)!! + + content["ed25519:" + credentials.deviceId] = olmDevice.signMessage(strToSign) + ?: "" //null reported by rageshake if happens during logout result[credentials.userId] = content diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/IMXDecrypting.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/IMXDecrypting.kt index a44cd61e70..c21ccbdb8b 100644 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/IMXDecrypting.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/IMXDecrypting.kt @@ -37,7 +37,7 @@ internal interface IMXDecrypting { * @throws MXDecryptionException the decryption failure reason */ @Throws(MXDecryptionException::class) - suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult? + suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult /** * Handle a key event. diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/megolm/MXMegolmDecryption.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/megolm/MXMegolmDecryption.kt index 8bedba1904..177754b051 100644 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/megolm/MXMegolmDecryption.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/megolm/MXMegolmDecryption.kt @@ -43,6 +43,7 @@ import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.launch import timber.log.Timber import java.util.* +import kotlin.collections.HashMap internal class MXMegolmDecryption(private val credentials: Credentials, private val olmDevice: MXOlmDevice, @@ -64,19 +65,18 @@ internal class MXMegolmDecryption(private val credentials: Credentials, private var pendingEvents: MutableMap>> = HashMap() @Throws(MXDecryptionException::class) - override suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult? { + override suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult { return decryptEvent(event, timeline, true) } @Throws(MXDecryptionException::class) - private fun decryptEvent(event: Event, timeline: String, requestKeysOnFail: Boolean): MXEventDecryptionResult? { + private fun decryptEvent(event: Event, timeline: String, requestKeysOnFail: Boolean): MXEventDecryptionResult { val encryptedEventContent = event.content.toModel()!! if (TextUtils.isEmpty(encryptedEventContent.senderKey) || TextUtils.isEmpty(encryptedEventContent.sessionId) || TextUtils.isEmpty(encryptedEventContent.ciphertext)) { throw MXDecryptionException(MXCryptoError(MXCryptoError.MISSING_FIELDS_ERROR_CODE, MXCryptoError.UNABLE_TO_DECRYPT, MXCryptoError.MISSING_FIELDS_REASON)) } - var eventDecryptionResult: MXEventDecryptionResult? = null var cryptoError: MXCryptoError? = null var decryptGroupMessageResult: MXDecryptionResult? = null @@ -86,17 +86,19 @@ internal class MXMegolmDecryption(private val credentials: Credentials, cryptoError = e.cryptoError } // the decryption succeeds - if (decryptGroupMessageResult?.payload != null && cryptoError == null) { - eventDecryptionResult = MXEventDecryptionResult() + if (decryptGroupMessageResult?.payload != null) { + val eventDecryptionResult = MXEventDecryptionResult() eventDecryptionResult.clearEvent = decryptGroupMessageResult.payload eventDecryptionResult.senderCurve25519Key = decryptGroupMessageResult.senderKey if (null != decryptGroupMessageResult.keysClaimed) { - eventDecryptionResult.claimedEd25519Key = decryptGroupMessageResult.keysClaimed!!["ed25519"] + eventDecryptionResult.claimedEd25519Key = decryptGroupMessageResult.keysClaimed?.get("ed25519") } - eventDecryptionResult.forwardingCurve25519KeyChain = decryptGroupMessageResult.forwardingCurve25519KeyChain!! + eventDecryptionResult.forwardingCurve25519KeyChain = decryptGroupMessageResult.forwardingCurve25519KeyChain + ?: emptyList() + return eventDecryptionResult } else if (cryptoError != null) { if (cryptoError.isOlmError) { if (MXCryptoError.UNKNOWN_MESSAGE_INDEX == cryptoError.message) { @@ -118,13 +120,13 @@ internal class MXMegolmDecryption(private val credentials: Credentials, if (requestKeysOnFail) { requestKeysForEvent(event) } + throw MXDecryptionException(cryptoError) } - throw MXDecryptionException(cryptoError) } - - return eventDecryptionResult + throw MXDecryptionException(MXCryptoError(MXCryptoError.UNKNOWN_ERROR_CODE, MXCryptoError.UNKNOWN_ERROR_CODE)) } + /** * Helper for the real decryptEvent and for _retryDecryption. If * requestKeysOnFail is true, we'll send an m.room_key_request when we fail @@ -172,6 +174,7 @@ internal class MXMegolmDecryption(private val credentials: Credentials, val encryptedEventContent = event.content.toModel() ?: return val pendingEventsKey = "${encryptedEventContent.senderKey}|${encryptedEventContent.sessionId}" + if (!pendingEvents.containsKey(pendingEventsKey)) { pendingEvents[pendingEventsKey] = HashMap() } @@ -197,21 +200,19 @@ internal class MXMegolmDecryption(private val credentials: Credentials, var senderKey: String? = event.getSenderKey() var keysClaimed: MutableMap = HashMap() - var forwardingCurve25519KeyChain: MutableList = ArrayList() + val forwardingCurve25519KeyChain: MutableList = ArrayList() if (TextUtils.isEmpty(roomKeyContent.roomId) || TextUtils.isEmpty(roomKeyContent.sessionId) || TextUtils.isEmpty(roomKeyContent.sessionKey)) { Timber.e("## onRoomKeyEvent() : Key event is missing fields") return } if (event.getClearType() == EventType.FORWARDED_ROOM_KEY) { - Timber.v("## onRoomKeyEvent(), forward adding key : roomId " + roomKeyContent.roomId + " sessionId " + roomKeyContent.sessionId - + " sessionKey " + roomKeyContent.sessionKey) // from " + event); + Timber.v("## onRoomKeyEvent(), forward adding key : roomId ${roomKeyContent.roomId} sessionId ${roomKeyContent.sessionId} sessionKey ${roomKeyContent.sessionKey}") // from " + event); val forwardedRoomKeyContent = event.getClearContent().toModel() ?: return - forwardingCurve25519KeyChain = if (forwardedRoomKeyContent.forwardingCurve25519KeyChain == null) { - ArrayList() - } else { - ArrayList(forwardedRoomKeyContent.forwardingCurve25519KeyChain) + + forwardedRoomKeyContent.forwardingCurve25519KeyChain?.let { + forwardingCurve25519KeyChain.addAll(it) } if (senderKey == null) { @@ -284,8 +285,10 @@ internal class MXMegolmDecryption(private val credentials: Credentials, } override fun hasKeysForKeyRequest(request: IncomingRoomKeyRequest): Boolean { - return (null != request.requestBody - && olmDevice.hasInboundSessionKeys(request.requestBody!!.roomId!!, request.requestBody!!.senderKey!!, request.requestBody!!.sessionId!!)) + val roomId = request.requestBody?.roomId ?: return false + val senderKey = request.requestBody?.senderKey ?: return false + val sessionId = request.requestBody?.sessionId ?: return false + return olmDevice.hasInboundSessionKeys(roomId, senderKey, sessionId) } override fun shareKeysWithDevice(request: IncomingRoomKeyRequest) { @@ -293,13 +296,13 @@ internal class MXMegolmDecryption(private val credentials: Credentials, if (request.requestBody == null) { return } - val userId = request.userId!! + val userId = request.userId ?: return CoroutineScope(coroutineDispatchers.crypto).launch { deviceListManager .downloadKeys(listOf(userId), false) .flatMap { val deviceId = request.deviceId - val deviceInfo = cryptoStore.getUserDevice(deviceId!!, userId) + val deviceInfo = cryptoStore.getUserDevice(deviceId ?: "", userId) if (deviceInfo == null) { throw RuntimeException() } else { @@ -315,9 +318,8 @@ internal class MXMegolmDecryption(private val credentials: Credentials, // were no one-time keys. Try.just(Unit) } - Timber.v("## shareKeysWithDevice() : sharing keys for session " + body!!.senderKey + "|" + body.sessionId - + " with device " + userId + ":" + deviceId) - val inboundGroupSession = olmDevice.getInboundGroupSession(body.sessionId, body.senderKey, body.roomId) + Timber.v("""## shareKeysWithDevice() : sharing keys for session ${body?.senderKey}|${body?.sessionId} with device $userId:$deviceId""") + val inboundGroupSession = olmDevice.getInboundGroupSession(body?.sessionId, body?.senderKey, body?.roomId) val payloadJson = HashMap() payloadJson["type"] = EventType.FORWARDED_ROOM_KEY diff --git a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/olm/MXOlmDecryption.kt b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/olm/MXOlmDecryption.kt index 1a00188c58..90a1015a25 100644 --- a/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/olm/MXOlmDecryption.kt +++ b/matrix-sdk-android/src/main/java/im/vector/matrix/android/internal/crypto/algorithms/olm/MXOlmDecryption.kt @@ -43,7 +43,7 @@ internal class MXOlmDecryption( : IMXDecrypting { @Throws(MXDecryptionException::class) - override suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult? { + override suspend fun decryptEvent(event: Event, timeline: String): MXEventDecryptionResult { val olmEventContent = event.content.toModel()!! if (null == olmEventContent.ciphertext) { diff --git a/vector/src/main/java/im/vector/riotx/core/platform/VectorViewModel.kt b/vector/src/main/java/im/vector/riotx/core/platform/VectorViewModel.kt index 0bd823d271..7a79bf377a 100644 --- a/vector/src/main/java/im/vector/riotx/core/platform/VectorViewModel.kt +++ b/vector/src/main/java/im/vector/riotx/core/platform/VectorViewModel.kt @@ -21,4 +21,4 @@ import com.airbnb.mvrx.MvRxState import im.vector.riotx.BuildConfig abstract class VectorViewModel(initialState: S) - : BaseMvRxViewModel(initialState, debugMode = BuildConfig.DEBUG) \ No newline at end of file + : BaseMvRxViewModel(initialState, false) \ No newline at end of file