mirror of
https://github.com/Novaloop-AG/element-x-android.git
synced 2026-11-04 19:10:43 +00:00
Fix code quality.
This commit is contained in:
+5
-3
@@ -59,9 +59,11 @@ class IdentityChangeStatePresenter @Inject constructor(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun CoroutineScope.observeRoomMemberIdentityStateChange(roomMemberIdentityStateChange: MutableState<PersistentList<RoomMemberIdentityStateChange>>) {
|
private fun CoroutineScope.observeRoomMemberIdentityStateChange(
|
||||||
combine(room.identityStateChangesFlow, room.membersStateFlow) { IdentityStateChanges, membersState ->
|
roomMemberIdentityStateChange: MutableState<PersistentList<RoomMemberIdentityStateChange>>
|
||||||
IdentityStateChanges.map { identityStateChange ->
|
) {
|
||||||
|
combine(room.identityStateChangesFlow, room.membersStateFlow) { identityStateChanges, membersState ->
|
||||||
|
identityStateChanges.map { identityStateChange ->
|
||||||
val member = membersState.roomMembers()
|
val member = membersState.roomMembers()
|
||||||
?.firstOrNull { roomMember -> roomMember.userId == identityStateChange.userId }
|
?.firstOrNull { roomMember -> roomMember.userId == identityStateChange.userId }
|
||||||
?: createDefaultRoomMemberForIdentityChange(identityStateChange.userId)
|
?: createDefaultRoomMemberForIdentityChange(identityStateChange.userId)
|
||||||
|
|||||||
+1
-1
@@ -8,7 +8,7 @@
|
|||||||
package io.element.android.libraries.matrix.api.encryption.identity
|
package io.element.android.libraries.matrix.api.encryption.identity
|
||||||
|
|
||||||
enum class IdentityState {
|
enum class IdentityState {
|
||||||
/** The user is verified with us */
|
/** The user is verified with us. */
|
||||||
Verified,
|
Verified,
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
+1
-1
@@ -205,7 +205,7 @@ internal class RustEncryptionService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
override suspend fun pinUserIdentity(userId: UserId): Result<Unit> = runCatching {
|
override suspend fun pinUserIdentity(userId: UserId): Result<Unit> = runCatching {
|
||||||
val userIdentity = service.getUserIdentity(userId.value) ?: throw IllegalStateException("User identity not found")
|
val userIdentity = service.getUserIdentity(userId.value) ?: error("User identity not found")
|
||||||
userIdentity.pin()
|
userIdentity.pin()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user