ehealthsolutions/element-x-android
3
0
Fork 0
mirror of https://github.com/Novaloop-AG/element-x-android.git synced 2026-11-02 21:32:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Sending queue : code quality

Browse Source
This commit is contained in:
ganfra
2024-06-11 17:05:12 +02:00
parent 60de33b8c6
commit a603855933
5 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
appnav/src/main/kotlin/io/element/android/appnav/loggedin/SendingQueue.kt
-1
View File
@@ -41,7 +41,6 @@ class SendingQueue @Inject constructor(
private val matrixClient: MatrixClient, private val matrixClient: MatrixClient,
private val networkMonitor: NetworkMonitor, private val networkMonitor: NetworkMonitor,
) { ) {
private val retryCount = AtomicInteger(0) private val retryCount = AtomicInteger(0)
fun launchIn(coroutineScope: CoroutineScope) { fun launchIn(coroutineScope: CoroutineScope) {
appnav/src/test/kotlin/io/element/android/appnav/loggedin/SendingQueueTest.kt
-2
View File
@@ -29,7 +29,6 @@ import kotlinx.coroutines.test.runTest
import org.junit.Test import org.junit.Test
@OptIn(ExperimentalCoroutinesApi::class) class SendingQueueTest { @OptIn(ExperimentalCoroutinesApi::class) class SendingQueueTest {
private val matrixClient = FakeMatrixClient() private val matrixClient = FakeMatrixClient()
private val networkMonitor = FakeNetworkMonitor() private val networkMonitor = FakeNetworkMonitor()
private val sut = SendingQueue(matrixClient, networkMonitor) private val sut = SendingQueue(matrixClient, networkMonitor)
@@ -77,5 +76,4 @@ import org.junit.Test
listOf(value(true)), listOf(value(true)),
) )
} }
} }
features/messages/impl/src/main/kotlin/io/element/android/features/messages/impl/timeline/components/TimelineEventTimestampView.kt
-1
View File
@@ -73,4 +73,3 @@ internal fun TimelineEventTimestampViewPreview(@PreviewParameter(TimelineItemEve
object TimelineEventTimestampViewDefaults { object TimelineEventTimestampViewDefaults {
val spacing = 16.dp val spacing = 16.dp
} }
libraries/matrix/api/src/main/kotlin/io/element/android/libraries/matrix/api/timeline/Timeline.kt
-1
View File
@@ -162,5 +162,4 @@ interface Timeline : AutoCloseable {
waveform: List<Float>, waveform: List<Float>,
progressCallback: ProgressCallback? progressCallback: ProgressCallback?
): Result<MediaUploadHandler> ): Result<MediaUploadHandler>
} }
libraries/matrix/impl/src/main/kotlin/io/element/android/libraries/matrix/impl/timeline/RustTimeline.kt
+2 -4
View File
@@ -263,9 +263,8 @@ class RustTimeline(
override suspend fun sendMessage(body: String, htmlBody: String?, mentions: List<Mention>): Result<Unit> = withContext(dispatcher) { override suspend fun sendMessage(body: String, htmlBody: String?, mentions: List<Mention>): Result<Unit> = withContext(dispatcher) {
messageEventContentFromParts(body, htmlBody).withMentions(mentions.map()).use { content -> messageEventContentFromParts(body, htmlBody).withMentions(mentions.map()).use { content ->
runCatching { runCatching<Unit> {
inner.send(content) inner.send(content)
Unit
} }
} }
} }
@@ -298,7 +297,7 @@ class RustTimeline(
mentions: List<Mention>, mentions: List<Mention>,
): Result<Unit> = ): Result<Unit> =
withContext(dispatcher) { withContext(dispatcher) {
runCatching { runCatching<Unit> {
when { when {
originalEventId != null -> { originalEventId != null -> {
val editedEvent = specialModeEventTimelineItem ?: inner.getEventTimelineItemByEventId(originalEventId.value) val editedEvent = specialModeEventTimelineItem ?: inner.getEventTimelineItemByEventId(originalEventId.value)
@@ -314,7 +313,6 @@ class RustTimeline(
inner.getEventTimelineItemByTransactionId(transactionId.value).use { inner.getEventTimelineItemByTransactionId(transactionId.value).use {
inner.redactEvent(item = it, reason = null) inner.redactEvent(item = it, reason = null)
} }
Unit
} }
else -> { else -> {
error("Either originalEventId or transactionId must be non null") error("Either originalEventId or transactionId must be non null")