Make SyncState values match SyncServiceState values.
This commit is contained in:
parent
1f243dcb54
commit
c04fcfc352
7 changed files with 13 additions and 13 deletions
|
|
@ -164,7 +164,7 @@ class LoggedInFlowNode @AssistedInject constructor(
|
||||||
syncService.syncState,
|
syncService.syncState,
|
||||||
networkMonitor.connectivity
|
networkMonitor.connectivity
|
||||||
) { syncState, networkStatus ->
|
) { syncState, networkStatus ->
|
||||||
syncState == SyncState.InError && networkStatus == NetworkStatus.Online
|
syncState == SyncState.Error && networkStatus == NetworkStatus.Online
|
||||||
}
|
}
|
||||||
.distinctUntilChanged()
|
.distinctUntilChanged()
|
||||||
.collect { restartSync ->
|
.collect { restartSync ->
|
||||||
|
|
|
||||||
|
|
@ -30,7 +30,7 @@ open class LoggedInStateProvider : PreviewParameterProvider<LoggedInState> {
|
||||||
}
|
}
|
||||||
|
|
||||||
fun aLoggedInState(
|
fun aLoggedInState(
|
||||||
syncState: SyncState = SyncState.Syncing,
|
syncState: SyncState = SyncState.Running,
|
||||||
) = LoggedInState(
|
) = LoggedInState(
|
||||||
syncState = syncState,
|
syncState = syncState,
|
||||||
permissionsState = createDummyPostNotificationPermissionsState(),
|
permissionsState = createDummyPostNotificationPermissionsState(),
|
||||||
|
|
|
||||||
|
|
@ -84,8 +84,8 @@ fun SyncStateView(
|
||||||
|
|
||||||
private fun SyncState.mustBeVisible() = when (this) {
|
private fun SyncState.mustBeVisible() = when (this) {
|
||||||
SyncState.Idle -> true
|
SyncState.Idle -> true
|
||||||
SyncState.Syncing -> false
|
SyncState.Running -> false
|
||||||
SyncState.InError -> false /* In this case, the network error banner can be displayed */
|
SyncState.Error -> false /* In this case, the network error banner can be displayed */
|
||||||
SyncState.Terminated -> false
|
SyncState.Terminated -> false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,7 @@ package io.element.android.libraries.matrix.api.sync
|
||||||
|
|
||||||
enum class SyncState {
|
enum class SyncState {
|
||||||
Idle,
|
Idle,
|
||||||
Syncing,
|
Running,
|
||||||
InError,
|
Error,
|
||||||
Terminated,
|
Terminated,
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -144,7 +144,7 @@ class RustMatrixClient constructor(
|
||||||
client.setDelegate(clientDelegate)
|
client.setDelegate(clientDelegate)
|
||||||
rustSyncService.syncState
|
rustSyncService.syncState
|
||||||
.onEach { syncState ->
|
.onEach { syncState ->
|
||||||
if (syncState == SyncState.Syncing) {
|
if (syncState == SyncState.Running) {
|
||||||
onSlidingSyncUpdate()
|
onSlidingSyncUpdate()
|
||||||
}
|
}
|
||||||
}.launchIn(sessionCoroutineScope)
|
}.launchIn(sessionCoroutineScope)
|
||||||
|
|
|
||||||
|
|
@ -24,8 +24,8 @@ internal fun RoomListServiceState.toSyncState(): SyncState {
|
||||||
return when (this) {
|
return when (this) {
|
||||||
RoomListServiceState.INIT,
|
RoomListServiceState.INIT,
|
||||||
RoomListServiceState.SETTING_UP -> SyncState.Idle
|
RoomListServiceState.SETTING_UP -> SyncState.Idle
|
||||||
RoomListServiceState.RUNNING -> SyncState.Syncing
|
RoomListServiceState.RUNNING -> SyncState.Running
|
||||||
RoomListServiceState.ERROR -> SyncState.InError
|
RoomListServiceState.ERROR -> SyncState.Error
|
||||||
RoomListServiceState.TERMINATED -> SyncState.Terminated
|
RoomListServiceState.TERMINATED -> SyncState.Terminated
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -33,8 +33,8 @@ internal fun RoomListServiceState.toSyncState(): SyncState {
|
||||||
internal fun SyncServiceState.toSyncState(): SyncState {
|
internal fun SyncServiceState.toSyncState(): SyncState {
|
||||||
return when (this) {
|
return when (this) {
|
||||||
SyncServiceState.IDLE -> SyncState.Idle
|
SyncServiceState.IDLE -> SyncState.Idle
|
||||||
SyncServiceState.RUNNING -> SyncState.Syncing
|
SyncServiceState.RUNNING -> SyncState.Running
|
||||||
SyncServiceState.TERMINATED -> SyncState.Terminated
|
SyncServiceState.TERMINATED -> SyncState.Terminated
|
||||||
SyncServiceState.ERROR -> SyncState.InError
|
SyncServiceState.ERROR -> SyncState.Error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -26,11 +26,11 @@ class FakeSyncService : SyncService {
|
||||||
private val syncStateFlow = MutableStateFlow(SyncState.Idle)
|
private val syncStateFlow = MutableStateFlow(SyncState.Idle)
|
||||||
|
|
||||||
fun simulateError() {
|
fun simulateError() {
|
||||||
syncStateFlow.value = SyncState.InError
|
syncStateFlow.value = SyncState.Error
|
||||||
}
|
}
|
||||||
|
|
||||||
override suspend fun startSync(): Result<Unit> {
|
override suspend fun startSync(): Result<Unit> {
|
||||||
syncStateFlow.value = SyncState.Syncing
|
syncStateFlow.value = SyncState.Running
|
||||||
return Result.success(Unit)
|
return Result.success(Unit)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue